java – Spring 4 WebSocket远程代理配置

我设法用 Spring 4和Stomp创建简单的Websocket应用程序.请参阅我的上一个问题 here
然后我尝试使用远程消息代理(ActiveMQ).我刚开始经纪人并改变了
registry.enableSimplebroker("/topic");

registry.enableStompbrokerRelay("/topic");

它起作用了.

问题是如何配置代理?据我所知,在这种情况下,应用程序自动发现localhost上的代理:defaultport,如果我需要将应用程序指向其他机器上的其他代理,该怎么办?

解决方法

enableStompbrokerRelay方法返回一个方便的Registration实例,该实例公开了一个流畅的API.

您可以使用此流畅的API来配置您的broker中继:

registry.enableStompbrokerRelay("/topic").setRelayHost("host").setRelayPort("1234");

您还可以配置各种属性,例如代理的登录/传递凭据等.

与XML配置相同:

<websocket:message-broker>
  <websocket:stomp-endpoint path="/foo">
    <websocket:handshake-handler ref="myHandler"/>
    <websocket:sockjs/>
  </websocket:stomp-endpoint>
  <websocket:stomp-broker-relay prefix="/topic,/queue" 
      relay-host="relayhost" relay-port="1234"
      client-login="clientlogin" client-passcode="clientpass"
      system-login="syslogin" system-passcode="syspass"
      heartbeat-send-interval="5000" heartbeat-receive-interval="5000"
      virtual-host="example.org"/>
</websocket:message-broker>

有关属性认值的更多详细信息,请参见StompBrokerRelayRegistration javadoc.

相关文章

应用场景 C端用户提交工单、工单创建完成之后、会发布一条工...
线程类,设置有一个公共资源 package cn.org.chris.concurre...
Java中的数字(带有0前缀和字符串)
在Java 9中使用JLink的目的是什么?
Java Stream API Filter(过滤器)
在Java中找到正数和负数数组元素的数量