Stream协议连接socket为何关闭以及如何打开

Question

目前，我有很多日志消息

[warn] <0.7396.12> Stream protocol connection socket #Port<0.65372> closed
[warn] <0.7421.12> Stream protocol connection socket #Port<0.65377> closed
[warn] <0.7438.12> Stream protocol connection socket #Port<0.65380> closed
[warn] <0.7459.12> Stream protocol connection socket #Port<0.65383> closed
[warn] <0.7480.12> Stream protocol connection socket #Port<0.65386> closed
[warn] <0.7499.12> Stream protocol connection socket #Port<0.65390> closed
[warn] <0.7522.12> Stream protocol connection socket #Port<0.65394> closed
 [warn] <0.7547.12> Stream protocol connection socket #Port<0.65400> closed
[warn] <0.7564.12> Stream protocol connection socket #Port<0.65403> closed
[warn] <0.7585.12> Stream protocol connection socket #Port<0.65406> closed
 [warn] <0.7608.12> Stream protocol connection socket #Port<0.65410> closed
[warn] <0.7625.12> Stream protocol connection socket #Port<0.65413> closed
[warn] <0.7650.12> Stream protocol connection socket #Port<0.65418> closed
[warn] <0.7671.12> Stream protocol connection socket #Port<0.65421> closed
[warn] <0.7688.12> Stream protocol connection socket #Port<0.65424> closed
[warn] <0.7709.12> Stream protocol connection socket #Port<0.65427> closed

，我不知道有什么问题，

我在集群模式下运行 3 个节点，

我创建了流队列，即 x-queue-type: 流，

我在绑定中添加了交换，它定向到这个队列，但我不知道它是否均匀，问题

如何打开流协议连接套接字？

提供更多背景信息。 Logstash 也在使用它，但不断出现

[WARN ][logstash.inputs.rabbitmq ][main][some-queue] Error while setting up connection, will retry {:exception=>MarchHare::NotFound, :message=>"NOT_FOUND - no exchange 'some_exchange' in vhost '/'", :cause=>java.io.IOException}
    
[WARN ][logstash.inputs.rabbitmq ][main][some-queue] RabbitMQ connection was closed {:url=>"amqp://guest:XXXXXX@localhost:5672/", :automatic_recovery=>true, :cause=>com.rabbitmq.client.ShutdownSignalException: clean connection shutdown; protocol method: #method<connection.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)}

Answer 1

流队列分为两部分：

1. Core-Stream 队列
2. Stream Plugin

第一个是rabbitmq 3.9内置的
第二个可以使用以下方式启用：

rabbitmq-plugins enable rabbitmq_stream

如果您想要 UI 插件：

rabbitmq-plugins enable rabbitmq_stream_management

Answer 2

记录设置连接时出错，将重试 {:exception=>MarchHare::NotFound, :message=>"NOT_FOUND - vhost '/' 中没有交换 'some_exchange'", :cause=>java. io.IOException} 是由于我在运行logstash后创建了exchange而引起的。我应该在运行logstash 之前创建交换。