问题标签 [rabbitmq-exchange]

我目前正在寻找构建一个消息服务，用户可以在其中私下发送和接收消息。我可能需要多用户聊天，但在大多数情况下，我只希望单个收件人能够阅读发送给他们的消息。

通过查看 RabbitMQ，使用一个交换器并在每个用户登录时为每个用户创建一个队列并在注销时销毁每个队列是否有意义？为每个用户创建队列是否存在重大性能问题，或者是否有更好的选择？

我正在构建一个 REST API，并计划让用户通过端点 (/send) 向其他人发送消息，并通过 websockets 或类似的东西订阅他们自己的消息流。我可能也会将消息存储在 MongoDB 中，以便用户可以访问他们以前的所有消息。任何关于结构的建议都值得赞赏。

我有多个 RabbitMQ 服务器。

我需要一个接口（使用 JSP），我可以在其中管理（删除队列/交换/消息）所有这些服务器。

在内部，我将调用 curl 命令来执行操作。

示例：创建队列

如何使用 curl 删除/移动队列中的消息？

请先看看我的代码。

这是我的测试类，它正在创建 2000 个线程并且这些线程正在发送消息。

消息发送者

这是我的主要消息发送者类

消息传递使用的我的配置类

我的问题：

1. 正如我在服务器上看到的，一些线程正在成功传递消息，而其他线程则没有。

2. rabbitTemplate 监听器完全不确定（

   rabbitTemplate.setReturnCallback(new ReturnCallback() {

我需要听众每次都工作，因为在此基础上我会尝试再次发送消息

我可以看到有时消息被传递了 5 次，因为messageSentFlag是错误的，并且只有在 Confirm 侦听器中才会变为 true。

3. 请告诉我如何删除队列？因为我有 8000 个队列，我在 rabbitAdmin 中看到了一种删除队列的方法，但它需要队列的名称，而我的队列只是任何随机队列（UUID）

请提供您的想法，我该如何改进它或者有什么解决方法？对于我的应用程序，多线程环境是必须的。

提前致谢。

是否可以使用 RabbitMQ 主题交换来实现以下场景。

假设我有两个队列：

Queue1：路由键 MainRoute.Route1

Queue2：路由键 MainRoute.Route2

当我使用路由键发布消息时：

MainRoute.Route1 -> Queue1

MainRoute.Route2 -> Queue2

MainRoute -> Queue1 和 Queue2

是否有可能在不实施一些特殊的过滤、路由过程的情况下实现这一点？

如果不能，请您就问题的可能解决方案提出建议。

谢谢你。

我是 RabbitMQ 的菜鸟。我开始使用它，到目前为止它一直在为我的目的服务。在我的设置中应该有大约 10 个消费者。我想知道如果一条消息杀死了多个消费者/工作人员，我如何检查并删除该消息，因为我绝对不希望我的所有工作人员都因为消息损坏而失败。非常感谢任何建议，只是为了更新我正在使用 Java

我尝试在 stackoverflow install rabbitmq-server上关注此链接，但它不起作用。出现错误 No package rabbitmq-server-3.3.4-1.noarch.rpm 可用。

得到错误

我正在以这种方式从 RabbitMQ（java 客户端）读取数据。

我可以在没有while循环的情况下读取队列中的所有数据吗？

我有一个从 RabbitMQ 队列接收订单的业务流程。我正在考虑不确认它（意思是，将它留在队列中）可能很长时间（> 10分钟），然后才删除它（确认）或不删除它（不确认）。这有意义吗？在 RabbitMQ 任务之上处理长时间运行的处理的最佳方法是什么？

我已经编写了服务器-客户端应用程序。
服务器端服务器将在直接交换中使用路由密钥key1
初始化队列queue1 。 在初始化和声明之后，只要有人在上面写，它就会消耗数据。

客户端

客户端将使用路由密钥key1在该交换上发布一些数据。
此外，在我发布之前，我已将 mandotory 标志设置为 true。

问题

当我首先启动服务器时一切都很好。但是当我首先启动客户端并使用路由密钥发布数据时出现问题。当客户端发布数据时，经纪人也不例外。

当
我在不存在的队列上发布数据时，我想要异常或错误。

我的 rabbitMQ 服务一启动就崩溃了。该服务在过去两年中运行良好，但突然停止工作。我看了看日志，看到了这个：

所以我决定运行以下命令：

它给出以下错误：

如何设置 set_vm_memory_high_watermark 的值