RabbitMQ生产者线程池
共有1个答案
每个线程应该有一个通道，而不是一个连接。您应该只有一个连接。
没有“发布者线程”的限制，但是您可以在每个通道一次发送一条消息。
通过考虑您使用的是类似的代码
channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
-
问题内容： 我想看看使用多线程生产者而不是单线程生产者会有多少时间差异。我在本地计算机上设置了ActiveMQ，编写了生产者类，该类将初始化并在其构造函数中启动JMS连接。我将消息限制设置为3M，将所有消息推送到ActiveMQ大约花费了50秒。我只发送了一个字符串“ hello world” 3M次。 然后，我使用了相同的生产者对象（一个连接但有多个会话），并使用线程大小为8的ExecutorS
-
下面是代码，我面临的问题是recordRead变量告诉线程应该从哪里开始读取记录的起点。但是我如何为每个线程设置不同的值？例如，对于thread1，它应该是0，recordsToRead应该是300，对于thread2，recordsToRead应该是300+300=600，对于最后一个线程，它应该是600以及更高的结束。pagesize=50pagesize、recordRead和recordT
-
我有一个生产者-消费者模式的多线程任务。可能有许多生产者和一个消费者。我使用ArrayBlockingQueue作为共享资源。 Producer类中的run（）方法： Consumer类中的run（）方法： main（）方法： 现在，当队列为空时，我有消费者结束条件。但是可能会有一段时间队列变成空的，但是一些生产者线程仍然在工作。所以我只需要在完成所有生产者线程之后才完成消费者线程（但它们的数量事
-
我有两个线程的问题，似乎没有正确同步。我基本上有一个布尔值名为“已占用”。当没有线程启动时，它被设置为false。但是当一个线程启动时，线程集被占用是真的，我有一个类，它有线程（run），它们调用下面的函数。 这是一个模拟银行的示例，它接收一个金额（初始余额），然后随机执行取款和存款。我的教授提到了一些关于从取款线程到存款线程的信号？这是怎么回事？在提取线程中，它应该运行到余额为2低，并等待存款线
-
问题内容： 我想创建某种线程应用程序。但是我不确定在两者之间实现队列的最佳方法是什么。 因此，我提出了两个想法（这两个想法可能都是完全错误的）。我想知道哪种更好，如果它们都烂了，那么实现队列的最佳方法是什么。我关心的主要是这些示例中队列的实现。我正在扩展一个内部类的Queue类，它是线程安全的。下面是两个示例，每个示例有4个类。 主班 消费阶层 生产者类别 队列类 要么 主班 消费阶层 生产者类别