Spring AMQP确保多线程环境中的消息顺序
RabbitMQ保证在相同的发布通道-
1.）我有一个单一的线程发布消息在一个单一的交换2.（我有其他线程的集合发布消息在不同的交流有时创造新的消费者为不同的交流
使用缓存连接工厂，它具有通道缓存。每次发布时，它都会进入缓存以获取通道。因为其他线程正在发布和使用，所以不能保证同一通道将被我的主线程用于后续发布。即使我有一个缓存，这也是真的。有人回避过这个问题吗？
理想情况下，我希望为publisher exchange组合提供一个专用频道，或者至少为发布提供一个专用频道。我也看不出有什么办法。当RabbitMQ有一种保证发布顺序的机制时，如果无法保证发布顺序，那么Spring AMQP中似乎存在一个重大缺陷。
共有1个答案
您必须为每个发布服务器使用专用连接（因此为：连接工厂）。
或者，您可以使用rabbitmplate。执行（）并使用回调中提供的通道发布所有消息。
-
关于Spring WebClient我有一个问题 在我的应用程序中，我需要做许多类似的API调用，有时我需要更改调用中的头（身份验证令牌）。所以问题来了，在这两个选择中，什么更好： > 为所有传入的MyService.class请求创建一个WebClient，方法是将其设置为字段，如下代码所示： 谢谢你。
-
我的 Web 应用程序中出现随机错误，我迷路了。我创建了一个库来解码代码。我尝试了很多，从未失败过测试。但突然间，它开始随机失败。由于它在单线程测试中运行良好，有时在 servlet 环境中失败时，我能想象的唯一解释是问题与多线程环境中使用的库有关。老实说，我知道多线程是一个非常复杂的问题。我担心我的库可能不是线程安全的。顺便说一下，它非常简单，它是一个具有几种静态方法的正面类。基本上，假设您正在
-
我在学习多线程时发现对象的速度变慢了。hashCode在多线程环境中，因为对于相同数量的对象，计算运行4个线程的默认哈希代码要比运行1个线程的默认哈希代码花费两倍的时间。 但根据我的理解，并行完成这项工作也需要类似的时间。 您可以更改线程数。每个线程都有相同的工作量，因此您希望在我的四核机器上运行4个线程可能需要与运行单个线程相同的时间。 我看到4x大约2.3秒，但是。1x为9秒。 我的理解是否有
-
我的程序使用ZMQ进行通信。也就是说，服务器（C、linux）创建一个XPUB套接字，然后在一个线程中读取它，在另一个线程中发布数据（写入）。 客户端（java、jzmq、linux）创建一个SUB套接字，并订阅使用它。 一段时间后，服务器端在读取线程中接收SIGABRT。 什么可能是问题的根源？在不同的线程中读/写或创建XPUB/SUB对？ 如果问题是在多线程中，那么使用XPUB套接字的正确范例
-
现在，他提出的下一个问题是为多线程环境编写单例类。然后，我写了双重检查单例类。 然后，他反对使用和双重检查，并说这是没用的。为什么要检查两次，为什么要使用synchronized？我试着用多种方案说服他。但是，他没有。 后来，我在家里尝试了下面的代码，在那里我使用了带有多个线程的简单的单例类。 那么，问题是，在多线程环境中是否有必要使用或/和双重检查方法？似乎我的第一个代码本身（没有添加任何额外的
-
如果我有多个线程，每个线程使用injector获取EntityManager对象，每个线程使用em对象选择其他类对象的列表。准备好在for循环中使用。 如果一个线程首先完成并调用clear()，这会影响其他线程吗？比如for循环会有异常？ 谢谢你。