在同一通道上使用和发布消息
channel.basicConsume(RPC_QUEUE_NAME, false, consumer);
channel.basicPublish("", props.getReplyTo(), replyProps, response.getBytes());
我是否应该使用两种不同的渠道来消费和发布消息？
共有1个答案
根据Rabbitmq java api指南-https://www.Rabbitmq.com/api-guide.html
在共享通道上的一个线程中消费并在另一个线程中发布可能是安全的。
在“通道和并发注意事项（线程安全）”一节中提到。
-
我们在基于服务的应用程序中使用作为一种事件总线。send方法和消息处理程序基于spring-messaging的类（从Spring-Integration4.0(+)开始）。事件是对实体的更改，需要由其他服务接收。 问题是：spring-messaging类被spring-amqp视为任意对象负载，因为它不被识别为spring-amqp。这会导致以下问题： 默认消息格式是序列化的Java对象。sp
-
看起来，PublishBuildArtifacts任务在发布环境中不可用。 https://docs.microsoft.com/de-de/azure/devops/pipelines/tasks/utility/publish-pipeline-artifact?view=azure-德沃斯 但是，当我们的客户从Azure存储库（通用软件包）中获取新的工件版本时，有机会通过发布管道发布这些工件
-
我正在为我的Discord服务器创建一个bot。 我的服务器中有一个新的用户通道。当新用户加入时，我想向这个频道发送欢迎消息。但是，我不知道如何才能访问新用户的渠道。
-
问题内容： 我有下面的代码使用来将消息发布到队列中。该是越来越创建，但该消息无法被看到的队列。我也没有看到任何错误。 BasicApplication.java Producer.java 问题答案： 您使用了错误的方法；该方法的第一个参数是。 使用。
-
是否可以通过机器人自动向频道发送
-
是否可以通过单个TCP连接同时发送各种东西，如消息和文件？ 例如，我想在文件发送过程中发送文本命令。有没有可能不让连接变慢太多？如果这是可能的，我将如何实现这一点？我需要用每个数据包的描述ID在数据包中发送它吗？ 还是最好打开两个单独的连接？