java - ActiveMq Broker : WARN [Transport:203] Transport Connection to: StompSocket_1661562307 failed: java. io.IOException 中的错误:已关闭 1006:null

Question

我使用嵌入式代理 ActiveMq 并从 JavaScript 应用程序连接到它。使用的协议(protocol)是 STOMP over WebSocket。 Spring 的 XML 配置:

<amq:broker id="broker" useJmx="false" persistent="false" brokerId="1" brokerName="locHost">
    <amq:transportConnectors>
        <amq:transportConnector name="websocket" uri="ws://0.0.0.0:6661"/>
    </amq:transportConnectors>
</amq:broker>



<!-- JMS ConnectionFactory to use, configuring the embedded broker using XML -->
<amq:connectionFactory id="jmsFactory" brokerURL="vm://localhost"/>


<bean id="jmsConnectionFactory"
      class="org.springframework.jms.connection.SingleConnectionFactory"
      depends-on="broker"
      p:targetConnectionFactory-ref="jmsFactory"
      />

<jms:listener-container
        container-type="default"
        connection-factory="jmsConnectionFactory"
        >
    . . . . .
    <jms:listener destination="toggle"     ref="consumer" method="toggle"      response-destination="toggle"/>

    . . . . .

</jms:listener-container>

还有一些这种形式的听众(其中之一):

@Component
public class Consumer {
   . . . . .
   public String toggle(String message)  {

        return "Responce" + message; 
   }

   . . . . .
}

一些监听器正在工作，但有些监听器下有异常类型:

09:33:25,196 WARN  [Transport:203] Transport Connection to: StompSocket_1661562307 failed: java.io.IOException: closedOut 1006:null

并且消息未到达收件人手中。我们可以做什么？

Answer 1

您正在运行哪个版本的 AMQ？

您是否尝试过使用 stomp 格式的 URL:

<transportConnectors>
   <transportConnector name="stomp" uri="stomp://localhost:61613"/>
</transportConnectors>

URL 以 stomp:// 开头

查看更多详细信息Apache Documentation