이 프로그램의 스레드가 잠금 단계에서 작동 할 것으로 예상했습니다. 그러나 송신자는 수신자가 따라 가기를 기다리기 전에 ~ 60000 개의 메시지를 보냅니다. HWM에 대해 내가 잘못 이해 한 점은 무엇입니까? 수신자 스레드를 시작하지 않으면 두 번째 메시지를 보내려고 할 때 보낸 사람이 차단됩니다. public static void main(String[
질문은 제목에 있지만 조금 자세히 설명하고 있습니다. Sun/Oracle NIO API 또는 Netty와 같은 프레임 워크를 사용하여 Java에서 NIO 응용 프로그램을 작성하는 경우 연결된 호스트/포트에 바인드 된 서버가없는 경우에도 클라이언트를 가입자로 "연결"할 수 있습니까? 에? 내가 실제로하고 싶은 것은 서버가 죽었지 만 온라인 상태 일 때 메시지
CentOS를 실행하는 VM에 0MQ를 설치했으며 C 기반 애플리케이션이 행복하게 작동합니다. 그러나 JZMQ 바인딩을 통해 Java 응용 프로그램을 작동시킬 수 없습니다. 다음과 같은 오류가 발생합니다. java -Djava.library.path=/usr/local/lib -jar AidApps.jar receive localhost:9007
Star
JZMQ (java binding of zmq) 소켓이 연결되어 있는지 확인하는 방법이 있습니까? ZContext zmqContext = new ZContext();
ZMQ.Socket workerSocket = zmqContext.createSocket(ZMQ.DEALER);
workerSocket.setIdentity("ID".getBytes());
내 Centos에서 Zmq를 사용하고 있습니다. 내 임무는 하나의 생산자와 다수의 소비자가있는 ZMQ를 사용하여 자바 프로그램을 작성하는 것이다. 생산자가 100 개의 메시지를 보내고 4 명의 소비자가있는 경우 모든 소비자는 각각 25 개의 메시지를 공유해야합니다. 어떻게해야합니까?