1

次の「helloworld」jeromqPUSH -PULLクライアントとサーバーがあります。最高水準点の値を設定して初めて、メッセージをドロップせずに送信できます。

import org.jeromq.ZMQ;

    public class TestTcpServer {

    public static void main(String[] args) {

    ZMQ.Context context = ZMQ.context(1);
    ZMQ.Socket socket = context.socket(ZMQ.PULL);

    System.out.println("Binding TCP server on port 5555");

    //socket.setRcvHWM(100_000);

    socket.bind("tcp://*:5555");
    int x;
    x = 0;
    while (true) {
        x++;
        byte[] raw = socket.recv(0);
        String rawMessage = new String(raw);
        if (x > 99_997) {
            System.out.println(x);
            System.out.println(rawMessage);
        }
    }

    }

}

//client

import java.io.IOException;
import org.jeromq.ZMQ;

public class TestTcpClient {

/**
 * @param args
 * @throws InterruptedException
 * @throws IOException
 */
public static void main(String[] args) throws InterruptedException,
        IOException {
    ZMQ.Context context = ZMQ.context(1);
    ZMQ.Socket socket = context.socket(ZMQ.PUSH);
    socket.connect("tcp://localhost:5555");

    //socket.setRcvHWM(100_000);

    System.out.println("Sending 100 000 transactions over TCP...");                   long start = System.currentTimeMillis();

    for (int request_nbr = 0; request_nbr != 100_000; request_nbr++) {
        String requestString = "message";
        byte[] request = requestString.getBytes();
        boolean success = socket.send(request, 0);
        if (!success) {
            System.out.println("sending message failed!");
        }

    }
    long end = System.currentTimeMillis();
    System.out.print("Time: ");
    System.out.print(end - start);
    System.out.println(" ms");      
    socket.close();
    context.term();     
}

}

0Mqのドキュメントによると、最高水準点に達すると、PUBソケットのみがメッセージをドロップします。PUSH-PULLソケットを使用しているのに、メッセージがドロップされるのはなぜですか？

HWMはシステムの動的なプロパティであるように思われるので、このhello worldの例ではメッセージのドロップを解決できましたが、実際の状況でメッセージをドロップしないようにjeromqを頼りにできるでしょうか。

4

2 に答える 2

0

ご報告ありがとうございます。

はい、PUSH/PULL はメッセージを破棄してはなりません。

ZMTP 2.0サポートの最新の飛躍にバグがありました。

最新のスナップショットで試してください。

socket.setLinger(some_milli_seconds)また、メッセージを送信した後にアプリケーションを終了したい場合は、クライアント側で追加することをお勧めします。

于 2012-11-11T14:01:13.007 に答える
0

JeroMQ 0.3 で問題なく動作するはずです。ここで簡単なベンチマークを作成しましたhttp://nguyentantrieu.info/blog/benchmark-pubsub-jeromq-java/

于 2013-06-14T06:55:38.860 に答える