2015-12-29 65 views
0

我有一个使用Spring的Java应用程序,它使用Websocket,只要RabbitMQ与tomcat运行在同一台计算机上,它就可以正常工作。Java Spring STOMP:设置代理IP

如何设置RabbitMQ的IP?我正在阅读文档,但我没有找到它。

我现在的配置是非常相似的one in the documentation

<beans xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:websocket="http://www.springframework.org/schema/websocket" 
    xsi:schemaLocation=" 
     http://www.springframework.org/schema/beans 
     http://www.springframework.org/schema/beans/spring-beans.xsd 
     http://www.springframework.org/schema/websocket 
     http://www.springframework.org/schema/websocket/spring-websocket.xsd"> 

    <websocket:message-broker application-destination-prefix="/app"> 
     <websocket:stomp-endpoint path="/portfolio"> 
      <websocket:sockjs/> 
     </websocket:stomp-endpoint> 
     <websocket:simple-broker prefix="/topic, /queue"/> 
    </websocket:message-broker> 

</beans> 

我怎么可以设置IP?

回答

1

嗨你正在使用简单的经纪人(< websocket:simple-broker prefix="/topic, /queue"/>)。尝试使用以下设置:

<websocket:message-broker application-destination-prefix="/app"> 
    <websocket:stomp-endpoint path="/ws"> 
     <websocket:sockjs/> 
    </websocket:stomp-endpoint> 
    <websocket:stomp-broker-relay prefix="/topic" 
      relay-host="${websocket.relay.host}" relay-port="61613" client-login="user" client-passcode="passwd" system-login="user" system-passcode="passwd" 
      heartbeat-send-interval="20000" heartbeat-receive-interval="20000"/> 
</websocket:message-broker> 

此配置将帮助您添加ip。您可能还需要添加入站和出站通道配置,因为默认通道为1。单通道响应下的负载将非常缓慢。下面 插入代码段中<websocket:message-broker> and </websocket:message-broker>标签之间:

<websocket:client-inbound-channel> 
<websocket:executor core-pool-size="50" max-pool-size="100" keep-alive-seconds="60"/> 
</websocket:client-inbound-channel> 
<websocket:client-outbound-channel> 
<websocket:executor core-pool-size="50" max-pool-size="100" keep-alive-seconds="60"/> 
</websocket:client-outbound-channel> 
<websocket:broker-channel> 
<websocket:executor core-pool-size="50" max-pool-size="100" keep-alive-seconds="60"/> 
</websocket:broker-channel> 

你也将需要添加的登录凭据的情况下,你的RabbitMQ服务器是由应用程序不同。为此,您需要更改配置文件。你可以在RabbitMQ文档中得到这个