我刚开始用 C# 进行 nnanomsg 编程。对于一个简单的客户端/服务器示例,我将从以下示例开始,其中客户端与服务器连接以获取下一个数字。目前,该示例适用于 localhost,但我将网络 IP 地址硬编码以确保其正常工作。可能会有很多客户端连接到服务器,但是这个例子比现实生活中更积极地访问服务器。
客户代码:
using NNanomsg.Protocols;
using System;
using System.Text;
using System.Threading;
namespace Client {
class Program {
static void Main(string[] args) {
string connect = "tcp://127.0.1.107:9595";
while (true) {
PairSocket s = new PairSocket();
s.Connect(connect);
s.Send(Encoding.UTF8.GetBytes("Hello!"));
Console.WriteLine("Sent");
byte[] ss = null;
while (ss == null) {
ss = s.ReceiveImmediate();
Thread.Sleep(250);
}
s.Dispose();
Console.WriteLine("Received: " + Encoding.UTF8.GetString(ss));
} } } }
服务器代码:
using System;
using System.Text;
using NNanomsg.Protocols;
namespace Server {
public class Server {
public static int ITER = 0;
public static int NEXT_ID = 10001;
public static string CONNECT;
public static int PORT = 9595;
public static string QUERY;
public static string TCP = "tcp://127.0.1.107";
static void Main(string[] args) {
string bind = TCP + ":" + PORT;
Console.WriteLine("server starting...");
PairSocket s = new PairSocket();
s.Bind(bind);
while (true) {
byte[] ss = null;
ss = s.Receive();
Console.WriteLine("Received from client: " + Encoding.UTF8.GetString(ss));
byte[] b = Encoding.UTF8.GetBytes(NEXT_ID.ToString());
Console.WriteLine("Sent next id " + NEXT_ID);
s.Send(b);
NEXT_ID++;
if (NEXT_ID > 65535) { NEXT_ID = 10001; }
} } } }
一般来说,当有一个服务器和一个客户端时,这会很好地工作。但是,当我在同一台物理机器上启动第二个客户端时,它们会一起工作一段时间,可能进行 5 到 10 次迭代,然后其中一个客户端(通常是最近启动的那个)挂起。添加延迟(Thread.sleep(5000)
例如)稍微改善了这种情况,但它最终会在 50 次迭代后挂起。目前,客户端在显示“已发送”后立即停止。我还没有尝试从网络上的另一台物理机器启动客户端。
此外,我是否在循环中等待ReceiveImmediate()
或只是坐在 aReceive()
似乎并不重要。
我期望的是每个客户端都有机会向服务器发送请求并得到回复。确切的顺序并不重要,只要服务器最终响应客户端的请求即可。
我想了解它为什么挂起。我有最新版本的 DLL,1.1.5。
非常感谢您的每一点帮助。