いくつかのデータを収集してクライアントに送信するサーバーがあります。クライアントがサーバーから送信されたデータを取得したことを確認する必要があります。ここの PUB/SUB パターンが最良の選択だと思いましたが、クライアントがデータを取得したかどうかを確認する方法がわかりませんか? 信頼できる PUB/SUB について聞いたことがありますが、実際の例はありません。
考え、提案、例、ヘルプはありますか?
単純な発行元:
import zmq
context = zmq.Context()
server_socket = context.socket(zmq.PUB)
server_socket.bind('tcp://*:5559')
while True:
server_socket.send('message')
シンプルなサブスクライバー:
import zmq
context = zmq.Context()
client_socket = context.socket(zmq.SUB)
client_socket.setsockopt(zmq.SUBSCRIBE, '')
client_socket.connect('tcp://localhost:5559')
while True:
print client_socket.recv()
この例では、サブスクライバーが「メッセージ」を受け取ったことを確認する必要があります。