如何在namedPipeWrapper中在服务器和客户端之间推送消息?

问题描述

我根据文档 Named Pipe Wrapper 编写了客户端和服务器端,但不幸的是只有 server.ClientConnected 运行,而 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 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();

解决方法

基于documentation

为了测试管道的性能,最好将 ExampleCLI 项目转换为两个客户端和服务器项目,并将 SomeClass 模型移动到一个新的类库中。当模型可序列化时,您的问题就会出现。这就是不调用 server.ClientMessageclient.ServerMessage 的原因。

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...