Java Spring STOMP:设置代理 IP

Java Spring STOMP: Set broker IP

我有一个使用 Spring 的 Java 应用程序,它使用 Websocket,只要 RabbitMQ 与 tomcat 在同一台机器上运行,它就可以正常工作。

如何为 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?

您好,您使用的是简单代理 (<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。您可能还需要添加入站和出站通道配置,因为默认通道是 one.Under 加载单个通道响应会非常慢。 在 <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 文档中找到它