我如何在 namedPipeWrapper 中在服务器和客户端之间推送消息?
how can i push message between server and client in namedPipeWrapper?
我根据文档Named Pipe Wrapper写了客户端和服务器端,可惜只有server.ClientConnected 运行s和server.ClientMessage和client.ServerMessage没有运行。如何将消息从客户端推送到服务器,反之亦然?
型号:
[Serializable]
public class SomeClass
{
public string Request { get; set; }
public string Response { get; set; }
}
客户端:
var client = new NamedPipeClient<SomeClass>("MyServerPipe");
client.ServerMessage += delegate (NamedPipeConnection<SomeClass, SomeClass> conn, SomeClass message)
{
Console.WriteLine("Server says: {0}", message.Response);
};
// Start up the client asynchronously and connect to the specified server pipe.
// This method will return immediately while the client runs in a separate background thread.
client.Start();
Console.ReadKey();
服务器端:
var server = new NamedPipeServer<SomeClass>("MyServerPipe");
server.ClientConnected += delegate (NamedPipeConnection<SomeClass, SomeClass> conn)
{
Console.WriteLine("Client {0} is now connected!", conn.Id);
conn.PushMessage(new SomeClass { Response= "Welcome!" });
};
server.ClientMessage += delegate (NamedPipeConnection<SomeClass, SomeClass> conn, SomeClass message)
{
Console.WriteLine("Client {0} says: {1}", conn.Id, message.Request);
};
// Start up the server asynchronously and begin listening for connections.
// This method will return immediately while the server runs in a separate background thread.
server.Start();
Console.ReadKey();
要测试管道的性能,最好将 ExampleCLI
项目转换为两个客户端和服务器项目,并将 SomeClass 模型移动到新的 class 库中。当模型可序列化时,您的问题就会出现。这就是 server.ClientMessage
和 client.ServerMessage
没有被调用的原因。
我根据文档Named Pipe Wrapper写了客户端和服务器端,可惜只有server.ClientConnected 运行s和server.ClientMessage和client.ServerMessage没有运行。如何将消息从客户端推送到服务器,反之亦然?
型号:
[Serializable]
public class SomeClass
{
public string Request { get; set; }
public string Response { get; set; }
}
客户端:
var client = new NamedPipeClient<SomeClass>("MyServerPipe");
client.ServerMessage += delegate (NamedPipeConnection<SomeClass, SomeClass> conn, SomeClass message)
{
Console.WriteLine("Server says: {0}", message.Response);
};
// Start up the client asynchronously and connect to the specified server pipe.
// This method will return immediately while the client runs in a separate background thread.
client.Start();
Console.ReadKey();
服务器端:
var server = new NamedPipeServer<SomeClass>("MyServerPipe");
server.ClientConnected += delegate (NamedPipeConnection<SomeClass, SomeClass> conn)
{
Console.WriteLine("Client {0} is now connected!", conn.Id);
conn.PushMessage(new SomeClass { Response= "Welcome!" });
};
server.ClientMessage += delegate (NamedPipeConnection<SomeClass, SomeClass> conn, SomeClass message)
{
Console.WriteLine("Client {0} says: {1}", conn.Id, message.Request);
};
// Start up the server asynchronously and begin listening for connections.
// This method will return immediately while the server runs in a separate background thread.
server.Start();
Console.ReadKey();
要测试管道的性能,最好将 ExampleCLI
项目转换为两个客户端和服务器项目,并将 SomeClass 模型移动到新的 class 库中。当模型可序列化时,您的问题就会出现。这就是 server.ClientMessage
和 client.ServerMessage
没有被调用的原因。