申请人：@背着山的西加加 申请感言：准备申请吧主，希望能通过，谢谢大家支持

如题

如题，发现节点异常断开时（如断电），rabbitmq上会出现残留的假连接，导致节点间相互传输时指令被抢占，应该怎么解决比较好

大家好，我们公司新上的一套系统中，供应商同时使用了rabbitMQ和KAFKA。我是这方面的小白，但是，我的疑问是同是消息队列，这两者有什么区别，又又什么优劣呢？希望大师指点。谢谢。

请教各位大神rabbitmq推送数据是否只能以字节的形式推送呢

我现在有一个direct类型的exchange，请问一个消息可以通过这种类型的exchange发送给两个队列吗？

兄弟们我想请教一个问题，就是消费者在消费的过程中，时间可能会很长，后面的消息就一直等待着当前处理完，能不能超过某个时间就放弃，直接处理下一条消息

老哥们 mq集群部署，报错了，哪位大神能帮忙指点一下呀

我用官网的RabbitMQ Cluster Kubernetes Operator在k8s集群里启动了一个rabbit的集群，添加了ingress，映射的是RabbitMQ Cluster Kubernetes Operator生成的ClusterIP的Service的15672，hosts文件也加了，但是访问域名会直接跳转到buydomains.com，有哪位大神知道咋回事儿么

大佬们，我这有个业务要求rabbitmq的消费速度很高，ack的话直接导致大量消息堆积，不ack的话消费速度比生产速度还高。但是又要保证消费顺序，不ack的话偶尔会出现顺序错乱的情况。你们有遇到过类似需求吗？求教啊~

我在没有启用web插件的时候可以正常启动 但是一旦开启web插件（rabbitmq-plugins enable rabbitmq_management）后启动就报错了，想问下这是什么问题

以前有一个队列名字叫A1，后来我想改程A2，发现改了之后A1,A2都存在，A1没有消费者。这种情况是什么原因？是不是要重启MQ服务？

com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error; protocol method: #method<connection.close>(reply-code=504, reply-text=CHANNEL_ERROR - second 'channel.open' seen, class-id=20, method-id=10)

根据 dockerhub 中的文档,可以通过修改 /etc/rabbitmq/enabled_plugins 来开启模块, 所以可以将配置文件映射出来,在 docker 启动前上传 enabled_plugins 配置即可方便的开关模块; 测试环境:树莓派-4b UbuntuServer 64-bit docker-compose.yml ```yml # 创建目录脚本 # mkdir -p /usr/local/docker/rabbitmq/{data,logs,conf} && chmod -R 777 /usr/local/docker/rabbitmq/ && cd /usr/local/docker/rabbitmq/ # # docker-compose up -d # docker-compose down # docker-compose restart # 在 conf/enabled_plugins 内添加 模块 rabbitmq_mqtt,rabbitmq_stomp

应用场景：用户下订单 发送端生成一个订单号发送到接收端进行业务处理 接收端获取队列消息进行业务处理然后 通过basicAck返回。 这个时候发送端通过waitForConfirms能知道发送的消息是否被接收端接受到，但是我不知道订单是否下单成功，我该怎么获取业务处理结果呢？

rabbitmq消费者为啥已经取了队列里面的值没有进handleDelivery，打了断点一步一步释放断点，就可以进handleDelivery，这是怎么回事啊？求大佬解释下，完全就是打了断点一步一步才打印出来

为什么我使用硬盘模式服务都没有问题但是改成ram模式直接在加入集群启动start_app的时候rabbitmq直接不运行了

2021年RabbitMQ入门到精通 余胜军(通俗易懂版本)_哔哩哔哩 (゜-゜)つロ 干杯~-bilibili转自:https://www.bilibili.com/video/BV1dt4y1z7vG?p=31&share_sourc

我是学习Java的，刚开始学习的时候，觉得还是可以的，并没有想象中的那么难，

我是学习Java的，刚开始学习的时候，觉得还是可以的，并没有想象中的那么难，

因使用.net4.0系统，只找到这一个版本支持.net3.5，发现ConnectionFactory factory = new ConnectionFactory();和factory.CreateConnection();没办法使用集群ip，求助大神帮忙。

我是学习Java的，刚开始学习的时候，觉得还是可以的，并没有想象中的那么难，

为什么设置的消息的过期，队列中还存在消息，不是应该自动删除吗 场景： 订单超时未付款自动取消

学习编程的时候，刚开始真心觉得还可以的，

mq是通过zookeeper转发的，tomcat通过mq接收其他系统推送过来的数据，tomcat日志里经常出现： CachingConnectionFactory.shutdownCompleted(281) | Channel shutdown: connection error ； SimpleMessageListenerContainer.redeclareElementsIfNecessary(975) | Failed to check/redeclare auto-delete queue(s).org.springframework.amqp.AmqpIOException: java.io.IOException。但是我看数据推送正常的、难道会自动重连？

分享贴子

据我了解，消息中间件MQ一般用于企业内部不同业务系统间的消息集成，如果用于不同企业间的消息集成是否存在一些比如安全性或者其他方面的一些问题，消息中间件MQ适合暴露于公网么

问题如标题，

之前遇到过这种问题，rabbitmqctl status报错，替换了3处的cookie文件，就解决了，今天又遇到了，但是替换了还是报错，，网上的帖子无非都是说替换cookie或者更改登录身份，都没解决。。。。菜鸟特来吧里求助。。。。

如题

大佬有解吗

[0x7FFAD779C980] ANOMALY: meaningless REX prefix used 看图

File "D:\PycharmProjects\rabbitDemo\venv\lib\site-packages\pika\adapters\blocking_connection.py", line 359, in __init__ self._impl = self._create_connection(parameters, _impl_class) File "D:\PycharmProjects\rabbitDemo\venv\lib\site-packages\pika\adapters\blocking_connection.py", line 450, in _create_connection raise self._reap_last_connection_workflow_error(error) pika.exceptions.AMQPConnectionError 报这个错，看不懂，。要求是带SSL登录的，但是脚本不知道怎么传SSL

在创建mq的xml文件的时候，每次执行（在主配置文件中有引用）到消息模板（rabbit:template id这个标签）的地方就会执行失败，监听器报错！

通过ChannelAwareMessageListener实现消息监听多条queue，我知道这边可以手动确认ack，但是我想回复消息给监听到的queue的生产者，比如本次消息的处理结果，这个需要怎么做，有没有大神指导一下

我现在一个队列上有2个消费者，有没有方法把消费者给删了

求指教！！rabbitmq怎么修改默认的5672端口，按照网上说的方法试了，怎么修改都是5672。。。。

26岁，在北京，之前对编程比较感兴趣也自学了一段时间，但是觉得还是需要系统的学习一下，所以报了个培新机构去学，NND，现在毕业两个月了，投了一百多分简历我发现没人要我！！我真的认为我自己学的不差，唉，但是总归起来，还是培训学的太初级了，就是个初级程序员，对培训也不相信了，都是为了规模而拉低了质量

rabbitmq的消费者获取了队列里面的东西，队列里面的消息已经被取走了，但是为什么没有进入重写的handleDelivery这个方法

我有一个6台机器的rabbitmq集群，每个他队列都做了镜像 其中有一个机器挂了（A机）。我将其重新启动 但现在出一个现像。原来在A上的队列都附加到其他节点上了 现在没有任务一个队列在A机上。包括镜像的对像 我如何才能将队列做一个平衡。重新让A机上负载一些队列