我已经写了一个小应用程序,它创建了一个命名管道服务器和一个连接到它的客户机。您可以将数据发送到服务器,并且服务器成功读取数据。
我需要做的下一件事是从服务器接收消息,所以我有另一个线程,它产生并等待传入的数据。
问题是,当线程等待传入数据时,您无法再向服务器发送消息,因为它挂起了WriteLine
调用,因为我假设管道现在正在检查数据。
是不是因为我处理得不好?或者命名管道不应该这样使用?我看到的命名管道的例子似乎只有一个方向,客户端发送,服务器接收,尽管你可以指定管道的方向为In
,Out
或两者兼而有之。
任何帮助,指针或建议将不胜感激!
下面是到目前为止的代码:
// Variable declarations
NamedPipeClientStream pipeClient;
StreamWriter swClient;
Thread messageReadThread;
bool listeningStopRequested = false;
// Client connect
public void Connect(string pipeName, string serverName = ".")
{
if (pipeClient == null)
{
pipeClient = new NamedPipeClientStream(serverName, pipeName, PipeDirection.InOut);
pipeClient.Connect();
swClient = new StreamWriter(pipeClient);
swClient.AutoFlush = true;
}
StartServerThread();
}
// Client send message
public void SendMessage(string msg)
{
if (swClient != null && pipeClient != null && pipeClient.IsConnected)
{
swClient.WriteLine(msg);
BeginListening();
}
}
// Client wait for incoming data
public void StartServerThread()
{
listeningStopRequested = false;
messageReadThread = new Thread(new ThreadStart(BeginListening));
messageReadThread.IsBackground = true;
messageReadThread.Start();
}
public void BeginListening()
{
string currentAction = "waiting for incoming messages";
try
{
using (StreamReader sr = new StreamReader(pipeClient))
{
while (!listeningStopRequested && pipeClient.IsConnected)
{
string line;
while ((line = sr.ReadLine()) != null)
{
RaiseNewMessageEvent(line);
LogInfo("Message received: {0}", line);
}
}
}
LogInfo("Client disconnected");
RaiseDisconnectedEvent("Manual disconnection");
}
// Catch the IOException that is raised if the pipe is
// broken or disconnected.
catch (IOException e)
{
string error = "Connection terminated unexpectedly: " + e.Message;
LogError(currentAction, error);
RaiseDisconnectedEvent(error);
}
}
2条答案
按热度按时间w41d8nur1#
不能从一个线程读取同一个管道对象,并在另一个线程上写入该对象。因此,虽然您可以创建一个协议,其中侦听位置根据您发送的数据而变化,但您不能同时做到这两点。要做到这一点,在两端都需要一个客户端和服务器管道。
wfveoks02#
关键点是:
参数
PipeOptions.Asynchronous
指出了异步读写流的框架。