命名管道包装库工作示例
Named-pipe-wrapper library working example
我需要一个工作示例,说明如何在简单的客户端和服务器实现中使用 [Named-Pipe-Wrapper] 库 v1.4。
我在 1 个客户端和服务器之间获取 Named-Pipe-Wrapper 库 v1.4 到 send/receive 消息时遇到困难。
我可以看到我的客户端已连接,但客户端和服务器之间发送的消息没有通过。
我做错了什么?
我选择这个库是因为它似乎很容易在客户端和服务器之间传递强类型对象,而无需处理所述对象的序列化和反序列化。
下面是我为了测试目的而整理的代码。
class Program
{
static void Main(string[] args)
{
var server = new NamedPipeServer<Message>("MyPipe");
server.ClientConnected += delegate (NamedPipeConnection<Message, Message> conn)
{
Console.WriteLine("Client {0} is now connected!", conn.Id);
};
server.ClientMessage +=
delegate (NamedPipeConnection<Message, Message> conn, Message message)
{
Console.WriteLine("Client {0} message received !", conn.Id);
Console.WriteLine("Client {0} says: {1}", conn.Id, message.Text);
conn.PushMessage(new Message() { Text = "HELLO from server" });
};
server.Start();
var client = new NamedPipeClient<Message>("MyPipe");
client.ServerMessage +=
delegate (NamedPipeConnection<Message, Message> conn, Message message)
{
Console.WriteLine("Server says: {0}", message.Text);
};
client.Start();
//client.WaitForConnection(1000);
client.PushMessage(new Message() { Text = "HELLO from client" });
Console.ReadLine();
}
}
public class Message
{
public string Text { get; set; }
}
更新
如果我使用本机数据类型,这会起作用,但是当我将简单的 classes 与本机类型一起使用时,它不起作用。
更新 2
我放在一起的代码是合理的,但要求我在消息 class.
上添加 [serializable] 属性
您的消息 class 需要 [serializable] 属性。
我需要一个工作示例,说明如何在简单的客户端和服务器实现中使用 [Named-Pipe-Wrapper] 库 v1.4。
我在 1 个客户端和服务器之间获取 Named-Pipe-Wrapper 库 v1.4 到 send/receive 消息时遇到困难。 我可以看到我的客户端已连接,但客户端和服务器之间发送的消息没有通过。
我做错了什么?
我选择这个库是因为它似乎很容易在客户端和服务器之间传递强类型对象,而无需处理所述对象的序列化和反序列化。
下面是我为了测试目的而整理的代码。
class Program
{
static void Main(string[] args)
{
var server = new NamedPipeServer<Message>("MyPipe");
server.ClientConnected += delegate (NamedPipeConnection<Message, Message> conn)
{
Console.WriteLine("Client {0} is now connected!", conn.Id);
};
server.ClientMessage +=
delegate (NamedPipeConnection<Message, Message> conn, Message message)
{
Console.WriteLine("Client {0} message received !", conn.Id);
Console.WriteLine("Client {0} says: {1}", conn.Id, message.Text);
conn.PushMessage(new Message() { Text = "HELLO from server" });
};
server.Start();
var client = new NamedPipeClient<Message>("MyPipe");
client.ServerMessage +=
delegate (NamedPipeConnection<Message, Message> conn, Message message)
{
Console.WriteLine("Server says: {0}", message.Text);
};
client.Start();
//client.WaitForConnection(1000);
client.PushMessage(new Message() { Text = "HELLO from client" });
Console.ReadLine();
}
}
public class Message
{
public string Text { get; set; }
}
更新 如果我使用本机数据类型,这会起作用,但是当我将简单的 classes 与本机类型一起使用时,它不起作用。
更新 2 我放在一起的代码是合理的,但要求我在消息 class.
上添加 [serializable] 属性您的消息 class 需要 [serializable] 属性。