agent_zmq下載 - agent_zmq原始碼下載

agent_zmq

其他源碼

下載

代理_zmq

專為測試 ZeroMQ 應用程式而設計的代理框架

用法

代理類型

代理類型對應測試中的底層 ZMQ Socket 類型

ZMQ_SUB

連線或綁定到本地地址
包括用於檢查的訊息緩存

ZMQ_PUB

連線或綁定到本地地址
發布

ZMQ_請求

連線或綁定到本地地址
發布請求，回傳回應

ZMQ_REP

連線或綁定到本地地址
監聽請求，發送回應

ZMQ_DEALER

連線或綁定到本地地址
監聽請求，發送回應

配置

在您的專案內部，在config/zmq_agents.rb中聲明您的代理，如下所示：

 require 'agent_zmq'

AgentZMQ . define_ZMQ_SUB :my_sub_agent do | a |
  a . socket_opts << { ZMQ :: SUBSCRIBE => 'com.connamara.BODPosition' }
  a . end_point_type = :bind
  a . end_point = 'tcp://*:5556'
end

AgentZMQ . define_ZMQ_PUB :my_pub_agent do | a |
  a . end_point_type = :connect
  a . end_points = [ 'tcp://127.0.0.1:5558' , 'tcp://127.0.0.1:5559' ]
end

AgentZMQ . define_ZMQ_REQ :my_req_agent do | a |
  a . end_point_type = :connect
  a . end_point = 'tcp://127.0.0.1:5552'
end

AgentZMQ . define_ZMQ_REP :my_rep_agent do | a |
  a . reply = Proc . new { | msg | "ok" }
  a . end_point_type = :bind
  a . end_point = 'tcp://*:5552'
end

啟動、停止和重置

 require 'agent_zmq'
AgentZMQ . start
at_exit { AgentZMQ . stop }

您可能希望在測試之間重置代理狀態，而無需停止和啟動。這可以透過AgentZMQ.reset來完成

尋找您的代理人

透過設定檔中給定的名稱取得代理

 my_agent = AgentZMQ . agents_hash [ :my_sub_agent ]

代理介面

ZMQ_SUB

該代理提供訊息緩存

 all_messages_received = my_sub_agent . messages_received

# returns and removes the last message received from the cache
last_message_received = my_sub_agent . pop

reset時，子代理快取被清除

ZMQ_PUB

publish方法採用包含一個或多個部分的單一訊息

 my_pub_agent . publish "single part message"
my_pub_agent . publish [ "part 1" , "part 2" ]

ZMQ_請求

publish方法採用包含一個或多個部分的單一訊息。代理會阻塞，直到收到回應並作為訊息部分數組返回

 response = my_req_agent . publish "single part message"
response = my_pub_agent . publish [ "part 1" , "part 2" ]

ZMQ_REP

與ZMQ_SUB代理程式一樣，ZMQ_REP提供訊息緩存

 all_messages_received = my_rep_agent . messages_received

# returns and removes the last message received from the cache
last_message_received = my_rep_agent . pop

當收到請求時，代理將回覆reply過程的輸出。該過程的傳回值可以是多部分訊息的形式。