producer-consumer 相关问题

生产者 - 消费者问题（也称为有界缓冲问题）是多进程同步问题的经典示例。该问题描述了两个进程，生产者和使用者，他们共享一个用作队列的通用固定大小缓冲区。

的RabbitMQ AMQP - 听ACK从消费信息

我在同一台机器上生产商和经纪商。生产者发送消息如下所示：信道= connection.createChannel（）; //创建一个持久的队列（如果尚未存在）channel.queueDeclare（...

rabbitmq amqp producer-consumer

回答 1 投票 4

生产者消费者问题如何发生饥饿

请举例说明饥饿发生的生产者消费者情景。

java multithreading producer-consumer

回答 1 投票 -4

Java中的信号量。生产者 - 消费者问题

我正在测试信号量的使用与典型的生产者 - 消费者问题，其中我只有一个生产者和一个消费者。生产者一次添加一个产品，消费者可以退出......

java semaphore producer-consumer

回答 2 投票 0

在Kafka / RabbitMQ中的每个消息确认

我们有一个工作的rabbitmq。实现，由于数量，我们计划切换到kafka。我有一点怀疑。在RabbitMQ中，当消费者从Q消息中消息时...

apache-kafka rabbitmq producer-consumer

回答 4 投票 1

Java 8函数式编程 - 需要在类上编写泛型函数

我想创建一个接受类似set的方法（nodeStatus，status，NodeStatus :: setStatus，Status :: valueOf）; set（nodeStatus，errorCode，NodeStatus :: setErrorCode，ErrorCode :: valueOf）; ...

java lambda functional-programming producer-consumer

回答 2 投票 3

消费者/生产者样式记录器中的同步错误

我看到很多这样的问题，但没有人帮助我，所以我发布了我的。我为多线程日志记录做了一个记录器。只有一个线程（在创建第一个记录器时创建。）处理日志...

c++ multithreading logging producer-consumer condition-variable

回答 1 投票 0

扩展分区时的Kafka主题排序

考虑您的生产者为系统用户创建消息，并且它们的顺序在用户级别中很重要。我的制作人，添加消息到主题有两个分区，我...

apache-kafka kafka-consumer-api producer-consumer

回答 1 投票 1

生产者消费者计划在Java中使用wait（）和notify（）

我正在使用低级同步和wait（）和notify（）在Java中执行经典的Producer-Consumer问题。我知道有更好的实现使用java.util.concurrent包中的结构...

java multithreading producer-consumer

回答 4 投票 1

同一组的kafka消费者如何在他们之间共享消息？

比如，有一个消费者群体。（具有相同组ID的消费者）。消费者组正在从经纪人那里消费主题A.主题A有4个分区，该组中有4个消费者。每个......

apache-kafka kafka-consumer-api producer-consumer

回答 1 投票 0

H2O生成器java线程锁，可重入锁

我想通过三线连续产生h2o第一个线程将产生h，第二个产生h，第三个产生o。我怎么能用锁，消费者生产者包com ....

java multithreading locking producer-consumer

回答 2 投票 0

Java如何避免在循环中使用Thread.sleep（）

从我的主要我开始两个线程称为生产者和消费者。两者都包含while（true）循环。生产者循环是UDP服务器，因此它不需要睡眠。我的问题出现在Consumer循环中。 ...

java producer-consumer

回答 3 投票 1

当多个生产者向Broker写入相同的消息时，Broker会做什么？还有一个相关的问题（由于150个字符的限制）

生产者A将消息写入Broker A（分区1），生产者B将相同的消息写入Broker A（分区1）。消息或经纪人会怎么样？我猜是因为有相同的......

apache-kafka producer-consumer kafka-producer-api producer

回答 1 投票 0

C ++生产者消费者陷入僵局

我正在尝试创建一个生产者 - 消费者计划，消费者必须继续运行直到所有生产者都完成，然后消耗队列中剩下的东西（如果还剩下什么），然后......

c++ multithreading producer-consumer condition-variable

回答 1 投票 0

如何创建Consumer Producer队列

我有一个Producer，它生成一个带有属性类型的POJO。只能有两种类型，“A”和“B”。我有一个消费者的线程池。每当我从制片人那里收到“B”型的消息时，......

java producer-consumer queuing

回答 2 投票 1

生产者和消费者在发送视频文件时通常如何工作？

根据我的理解，当我想向Kafka经纪人发送电影（4GB）时，一个制作人将发送一个4GB字节的视频文件（序列化它）并将其发送给kafka经纪人和许多想要...的消费者。

apache-kafka kafka-consumer-api producer-consumer kafka-producer-api producer

回答 2 投票 4

如何编写Java多线程代码用于替代生产者和消费者方法。它应该有3个生产者（P1，P2，P3）和1个消费者（C1）

我能否获得实现这一目标的明确方法。我使用了join并等待替代生产者和消费者执行。在一次采访中询问了这个问题。他不喜欢我的解决方案。一世 ...

java multithreading synchronized synchronous producer-consumer

回答 1 投票 0

Amazon SQS如何处理不向同一服务的不同实例发送相同的消息？

我有一个队列（在这种情况下是Amazon SQS）并且有N个运行相同服务的节点正在消耗来自SQS的消息。我怎样才能确保在任何时间点，不超过一个......

message-queue distributed-computing amazon-sqs producer-consumer

回答 1 投票 1

动物园管理员是卡夫卡必须的吗？

在Kafka中，我想只使用单个代理，单个主题和一个具有一个生产者和多个消费者的分区（每个消费者从代理获得自己的数据副本）。鉴于......

partitioning apache-zookeeper producer-consumer apache-kafka broker

回答 6 投票 80

卡夫卡制片人表现不佳

我和kafka制作人有问题。其实我正在使用spring kafka，并通过KafkaTemplate发送消息：默认KafkaProducerFactory defaultKafkaProducerFactory = new ...

apache-kafka messaging producer-consumer kafka-producer-api spring-kafka

回答 2 投票 0

没有获得kafka consumer jmx metrics的records-lag-max值

我正在运行启用了JMX的java kafka流应用程序。我试图获取消费者滞后，但为应用程序拥有的所有消费者获得无限。我正在寻找下面的jmx ......

apache-kafka monitoring jmx metrics producer-consumer

回答 1 投票 0

producer-consumer 相关问题

最新问题