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

标签 c# named-pipes

我根据文档写了客户端和服务器端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> 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();

最佳答案

基于 documentation

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

关于c# - 我如何在 namedPipeWrapper 中在服务器和客户端之间推送消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/66877297/

相关文章:

named-pipes - WINE 和 Windows 命名管道

c# - 如何更新 JSON 字符串中的属性值?

c# - 找不到命名元素

c# - VS2015 当前不会命中断点。没有为该文档加载任何符号

c - 如何解锁wgetch?

c++ - 为什么我的缓冲区在多次 read() 之后保存相同的数据?

nginx - 当我使用命名管道作为日志文件并删除并重新创建管道时,nginx 会发生什么情况?

java - 从管道读取的无限循环线程进入一个timed_waiting

c# - 为什么这个 Actor 是不可能的?

c# - 队列 ForEach 循环抛出 InvalidOperationException