RabbitMq入门到精通-Peer discovery backend rabbit_peer_discovery_classic_stopped TCP listener on [::]:5672

2023-11-08

 

2023-01-07 16:05:00.683333+08:00 [info] <0.223.0> Running boot step definition_import_worker_pool defined by app rabbit
2023-01-07 16:05:00.683411+08:00 [info] <0.281.0> Starting worker pool 'definition_import_pool' with 8 processes in it
2023-01-07 16:05:00.684025+08:00 [info] <0.223.0> Running boot step cluster_name defined by app rabbit
2023-01-07 16:05:00.684115+08:00 [info] <0.223.0> Initialising internal cluster ID to 'rabbitmq-cluster-id-2BDa_5BtXZBC6Al_WblSVQ'
2023-01-07 16:05:00.686253+08:00 [info] <0.223.0> Running boot step direct_client defined by app rabbit
2023-01-07 16:05:00.686390+08:00 [info] <0.658.0> Resetting node maintenance status
2023-01-07 16:05:00.686556+08:00 [info] <0.658.0> Ready to start client connection listeners
2023-01-07 16:05:00.731797+08:00 [info] <0.676.0> started TCP listener on [::]:5672
2023-01-07 16:05:00.809250+08:00 [info] <0.658.0> Server startup complete; 0 plugins started.
2023-01-07 16:13:08.887815+08:00 [noti] <0.61.0> SIGTERM received - shutting down

2023-01-07 16:13:08.888382+08:00 [info] <0.223.0> Peer discovery backend rabbit_peer_discovery_classic_config does not support registration, skipping unregistration.
2023-01-07 16:13:08.888521+08:00 [info] <0.676.0> stopped TCP listener on [::]:5672
2023-01-07 16:13:08.915922+08:00 [info] <0.1000.0> Closing all connections in vhost '/' on node 'rabbit@172-11-114-3' because the vhost is stopping
2023-01-07 16:13:08.915967+08:00 [info] <0.621.0> Stopping message store for directory '/var/lib/rabbitmq/mnesia/rabbit@172-11-114-3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent'
2023-01-07 16:13:08.958450+08:00 [info] <0.621.0> Message store for directory '/var/lib/rabbitmq/mnesia/rabbit@172-11-114-3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent' is stopped
2023-01-07 16:13:08.958632+08:00 [info] <0.617.0> Stopping message store for directory '/var/lib/rabbitmq/mnesia/rabbit@172-11-114-3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient'
2023-01-07 16:13:08.962221+08:00 [info] <0.617.0> Message store for directory '/var/lib/rabbitmq/mnesia/rabbit@172-11-114-3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient' is stopped

看日志在16:05 都是启动的

16:13分钟 自己断了

什么原因呢?

分析发现 原来改了hostname hostnamectl set-hostname waa01

导致rabbitmq stop

重启rabbitmq server

systemctl restart rabbitmq-server

查看

/var/lib/rabbitmq/mnesia 下生成三个文件

rabbit@waa01  

rabbit@waa01-feature_flags  

rabbit@waa01-plugins-expand  

rabbit@waa01.pid

Mnesia 是一个分布式数据库,使用它来存储有关用户交换器队列绑定的信息。 但是,消息不存储在数据库中。

日志目录 /var/log/rabbitmq/

rabbit@waa01.log  

rabbit@waa01_upgrade.log

2023-01-12 10:02:37.874450+08:00 [info] <0.224.0> Running boot step direct_client defined by app rabbit
2023-01-12 10:02:37.874579+08:00 [info] <0.224.0> Running boot step rabbit_management_load_definitions defined by app rabbitmq_management
2023-01-12 10:02:37.874664+08:00 [info] <0.471.0> Resetting node maintenance status
2023-01-12 10:02:37.900930+08:00 [info] <0.530.0> Management plugin: HTTP (non-TLS) listener started on port 15672
2023-01-12 10:02:37.901092+08:00 [info] <0.558.0> Statistics database started.
2023-01-12 10:02:37.901191+08:00 [info] <0.557.0> Starting worker pool 'management_worker_pool' with 3 processes in it
2023-01-12 10:02:37.901589+08:00 [info] <0.471.0> Ready to start client connection listeners
2023-01-12 10:02:37.936511+08:00 [info] <0.582.0> started TCP listener on [::]:5672
2023-01-12 10:02:38.008024+08:00 [info] <0.471.0> Server startup complete; 3 plugins started.
2023-01-12 10:02:38.008024+08:00 [info] <0.471.0>  * rabbitmq_management
2023-01-12 10:02:38.008024+08:00 [info] <0.471.0>  * rabbitmq_web_dispatch
2023-01-12 10:02:38.008024+08:00 [info] <0.471.0>  * rabbitmq_management_agent

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

RabbitMq入门到精通-Peer discovery backend rabbit_peer_discovery_classic_stopped TCP listener on [::]:5672 的相关文章

  • 如何在nodejs中验证rabbitmq?

    错误 握手被服务器终止 403 ACCESS REFUSED 消息 ACCESS REFUSED 使用身份验证拒绝登录 旋转机制平原 有关详细信息 请参阅代理日志文件 我单独尝试了 authMechanism PLAIN AMQPLAIN
  • 无法从 docker 将 RabbitMQ 连接到我的应用程序 [重复]

    这个问题在这里已经有答案了 我目前被这个问题困扰了大约一周 确实找不到合适的解决方案 问题是 当我尝试连接到 dockerized RabbitMQ 时 它每次都会给出相同的错误 wordofthedayapp wordofthedayap
  • RabbitMQ 中多个消费者如何订阅同一主题并获取同一消息

    首先 我知道类似问题已经有答案了here https stackoverflow com questions 10620976 rabbitmq amqp single queue multiple consumers for same m
  • Celery 任务状态取决于 CELERY_TASK_RESULT_EXPIRES

    据我所知 任务状态完全取决于 CELERY TASK RESULT EXPIRES 设置的值 如果我在任务完成执行后检查此间隔内的任务状态 则返回的状态为 AsyncResult task id state 是正确的 如果没有 状态将不会更
  • 如何使用 Celery、RabbitMQ 和 Django 确保每个用户的任务执行顺序?

    我正在运行 Django Celery 和 RabbitMQ 我想要实现的是确保与一个用户相关的任务按顺序执行 具体来说 一次执行一个 我不希望每个用户执行任务并发 每当为用户添加新任务时 它应该取决于最近添加的任务 如果此类型的任务已为此
  • 定义具有多种消息类型的消息传递域

    到目前为止 我见过的大多数 F 消息传递示例都使用 2 4 种消息类型 并且能够利用模式匹配将每条消息定向到其正确的处理函数 对于我的应用程序 由于处理和所需参数的不同性质 我需要数百种独特的消息类型 到目前为止 每个消息类型都是其自己的记
  • RabbitMQ Java 客户端自动重新连接

    当我的应用程序失去与 RabbitMQ 的连接时 我将其连接工厂设置为自动尝试并重新连接 ConnectionFactory factory new ConnectionFactory factory setUsername usernam
  • AMQP如何克服直接使用TCP的困难?

    AMQP如何克服直接使用TCP发送消息时的困难 或者更具体地说 在发布 订阅场景中 在 AMQP 中 有一个代理 该代理接收消息 然后完成将消息路由到交换器和队列的困难部分 您还可以设置持久队列 即使客户端断开连接 也可以为客户端保存消息
  • RabbitMQ - 如何死信/处理过期队列中的消息?

    我有一个队列x expires放 我遇到的问题是我需要对队列中的消息进行进一步处理IF队列过期 我最初的想法是设置x dead letter exchange在队列中 但是 当队列过期时 消息就会消失而不会进入死信交换 如何处理死信或以其他
  • RabbitMQ - 无法联系统计数据库。消息速率和队列长度将不会显示

    我已经设置了一个兔子经纪人集群 并且在管理门户插件中我收到以下消息 无法联系统计数据库 消息速率和队列长度将不会显示 我已经搜索过这个错误 但谷歌并不友善 任何人都可以阐明这一点吗 我最近在旧安装的RabbitMQ 2 8 7 上遇到了同样
  • PHPUnit RabbitMQ:为创建连接函数编写测试

    我面临以下问题 我编写了一个函数 根据所需参数创建连接对象 AMQPConnection 现在我想编写相应的单元测试 我只是不知道在没有运行 RabbitMQ 代理的情况下如何做到这一点 这是有问题的函数 public function g
  • Celery 设计帮助:如何防止并发执行任务

    我对 Celery AMQP 相当陌生 正在尝试提出一个任务 队列 工作人员设计来满足以下要求 我有多种类型的 每用户 任务 例如 TaskA TaskB TaskC 这些 每用户 任务中的每一个都为系统中的一个特定用户读取 写入数据 因此
  • EasyNetQ 模型关闭

    我使用 EasyNetQ 实现了一个简单的 RabbitMQ 客户端 连接后 我收到一条通知 队列模型关闭 这是我的代码 var bus RabbitHutch CreateBus String Format host 0 hostName
  • 具有延迟的简单可扩展工作/消息队列

    我需要设置一个作业 消息队列 并可以选择为任务设置延迟 以便空闲工作人员不会立即拾取它 而是在一定时间后 可能因任务而异 我研究了几个 Linux 队列解决方案 rabbitmq gearman memcacheq 但它们似乎都没有提供开箱
  • 使用多线程使用rabbitmq消息队列(Python Kombu)

    我有一个带有单个队列的 RabbitMQ 交换 我希望创建一个运行多个线程并尽快通过该队列工作的守护进程 工作 涉及与外部服务的通信 因此每个消费者内部都会发生相当多的阻塞 因此 我希望有多个线程都处理来自同一队列的消息 我可以通过在主线程
  • 如何让Spring RabbitMQ创建一个新的队列?

    根据我对rabbit mq的 有限 经验 如果您为尚不存在的队列创建新的侦听器 则会自动创建该队列 我正在尝试将 Spring AMQP 项目与rabbit mq 一起使用来设置侦听器 但出现错误 这是我的 xml 配置
  • 使用主题交换运行多个 Celery 任务

    我正在用 Celery 替换一些自制代码 但很难复制当前的行为 我期望的行为如下 创建新用户时 应向tasks与交换user created路由键 该消息应该触发两个 Celery 任务 即send user activate email
  • 具有 2 个队列的 Spring AMQP 项目

    我正在开发一个涉及 2 个队列和多个与它们交互的侦听器的项目 流动 新的 HTTP 请求到达服务器 然后将其转换为一个对象 该对象将成为消息 该消息必须在两个队列中发布 我有两种类型的侦听器 它们从每个队列获取消息 然后我做任何我想做的事情
  • RabbitMQ React Native 发送示例

    我正在尝试将 RabbitMQ 与 React Native 结合使用 我找不到关于这个主题的例子 我关注了这个伟大的 answer https stackoverflow com a 49559976 8565152我已从模拟器连接到服务
  • Celery未注册任务KeyError

    我通过在终端中执行以下命令来启动工作程序 celery A cel test worker loglevel INFO concurrency 10 n worker1 h 然后我收到一条长循环错误消息 指出 celery 已收到未注册的任

随机推荐