运行服务器Java的ZeroMQ

Question

我目前正在尝试开发一种服务器，该服务器基本上应该随时从未知数量的客户端获取传入数据。即系统将有多个客户端来发送数据，服务器的工作基本上只是收集数据并将其保存到数据库中。

1. 现在我希望服务器持续运行。现在，服务器只接收一个客户端并关闭。如果我说做一段时间(true(- 围绕接收和打印消息部分的循环，它甚至不会做一次。

2. 正如我可能理解的那样，REP REQ 不是最好的模式，什么模式最好让服务器获取传入数据？

3. 使用Curve(又名Ironhouse模式(，客户端需要拥有服务器证书，假设想要将数据发送到服务器的新客户端如何访问服务器证书？我从 ZMQ 指南或其他站点找到的所有示例都只引用本地的，通常是同一类的服务器-客户端应用程序，其中客户端只是访问证书，因为它们属于同一类......但这不是一个现实的情况。

感谢所有答案，提示和建议。 谢谢。

private class ServerTask extends Thread {
public void run() {
try(ZContext context = new ZContext()){ //create context
ZAuth authenticator = new ZAuth(context); //create authenticator for incoming clients
authenticator.setVerbose(true); //get indication of what the authenticator is deciding
authenticator.allow("127.0.0.1"); //Whitelisting an adress, all other adresses will be rejected
//authenticator.configureCurve(CERTIFICATE_FOLDER); //Tell authenticator to use the certificate store in .curve
//ZCert server_cert = new ZCert(); //Create a server certificate
//writeServerCertToFile(server_cert); //write the cert so client can use it
//Create and bind server socket
ZMQ.Socket server = context.createSocket(SocketType.REP);
//server.setZAPDomain("global".getBytes());
//server.setCurveServer(true);
//server.setCurvePublicKey(server_cert.getPublicKey());
//server.setCurveSecretKey(server_cert.getSecretKey());
server.bind("tcp://*:9000");
//recieve and print message
String message = server.recvStr(0);
System.out.println("received message: " + message);
System.out.println("I should not be printed before the recieved message");

try {
System.out.println("destroys the auth and context");
authenticator.close();
context.destroy();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

Answer 1

几个月前我解决了这个问题，但如果将来会帮助使用 ZeroMQ 的人，我最终使用拉推模式将数据负载平衡到线程池。还使用 Inproc 进行前端/后端通信。这似乎是最合适的解决方案。