快速和最佳的生产者/消费者队列技术 BlockingCollection 与并发队列
我在 C# 3.0 中使用 Generic.Queue 和 Monitor.Enter,wait,exit for wait 在消费队列之前(等待元素入队).现在我正在转向 C# 4. 谁能告诉我哪一个是快速且最好的，尤其是避免锁定.. BlockingCollection 与 concurrentQueue 或其他任何东西... 注意.我不想限制我的制作人 提前致谢..
..
producer相关内容
与 CDI 的 InjectionPoint 等效的 Spring DI 是什么?
我想创建一个 Spring 的 bean 生产者方法，它知道是谁调用了它，所以我从以下代码开始: @Configuration公共类 LoggerProvider {@豆角，扁豆@Scope("原型")公共记录器produceLogger() {//知道是什么 bean/组件调用了这个生产者类克拉兹 = ...返回 LoggerFactory.getLogger(clazz);}} 我如何获得
..
Kafka 集群 - 生产者
我有几个关于 Kafka 的问题.如果有人可以通过回复其中之一来帮助我，我将不胜感激. 先谢谢你:) Q1) 我知道分区在 Kafka Broker 之间分开.但分裂是基于什么?.例如，如果我有 3 个代理和 6 个分区，如何确保每个代理将有 2 个分区?Kafka 目前是如何进行这种拆分的? Q2) 当生产者发送一条新消息时，消息的默认格式是什么?Avro 格式 ?例如，如何将
..
Karaf - Kafka OSGI 包 - 生产者问题
我正在尝试在 apache Karaf 4.0.3 版中为 Kafka 制作人创建一个简单的包. 这是我的Java代码 Properties props = new Properties();props.put("bootstrap.servers", "localhost:9092");props.put("acks", "all");props.put("重试", 0);props.p
..
我们如何在防火墙/代理后面配置 kafka 生产者?
我们在 AWS 上安装了单节点 kafka.我们能够在这种环境中运行 kafka 生产者和消费者.但是，当我们的客户尝试向我们的 kafka 代理发送消息(在 AWS 环境之外)时，他们的消息被困在了他们的防火墙中. 因此客户端 kafka 生产者设置在防火墙/代理后面，我们的客户端如何在绕过代理后通过 kafka 发送消息. 解决方案 首先检查问题是否确实是客户端防火墙问题，与不正
..
Spring Cloud Producer 异常 - java.lang.IllegalStateException:生产者关闭后无法执行操作
Spring Cloud Producer 抛出异常 - java.lang.IllegalStateException: Producer 关闭后无法执行操作 嗨我们给出了一个基于spring cloud的微服务应用.在该应用程序中，我们在向 Kafka 生成消息时遇到错误.我们正在使用以下 Spring Cloud 版本. Spring Cloud 版本 格林威治.SR1
..
Kafka 集群 - 生产者
我有几个关于 Kafka 的问题.如果有人可以通过回复其中之一来帮助我，我将不胜感激. 先谢谢你:) Q1) 我知道分区在 Kafka Broker 之间分开.但分裂是基于什么?.例如，如果我有 3 个代理和 6 个分区，如何确保每个代理将有 2 个分区?Kafka 目前是如何进行这种拆分的? Q2) 当生产者发送一条新消息时，消息的默认格式是什么?Avro 格式 ?例如，如何将
..
无法建立到节点 -1 的连接.经纪人可能不可用.(org.apache.kafka.clients.NetworkClient)
我已经安装了 Kafka 并做了一些基本的测试.我可以使用 Kafka-broker/bin 文件夹下提供的脚本创建主题. 但是当我试图在每次运行时生成低于 WARNing 的消息时.并且不会生成任何消息.请指教. [root@node2 bin]# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test_
..
生成消息时找不到主题:UNKNOWN_TOPIC_OR_PARTITION
我有一个两节点的 Kafka 集群(EC2 实例)，其中每个节点都用作单独的代理.当我使用以下命令在领导者实例上运行生产者时: kafka-console-producer.sh --broker-list localhost:9092 --topic 测试 我收到以下错误. 测试消息[2017-01-09 13:22:39,483] 获取关联 ID 为 0 的元数据时出现警告错误:{t
..
Karaf - Kafka OSGI 包 - 生产者问题
我正在尝试在 apache Karaf 4.0.3 版中为 Kafka 制作人创建一个简单的包. 这是我的Java代码 Properties props = new Properties();props.put("bootstrap.servers", "localhost:9092");props.put("acks", "all");props.put("重试", 0);props.p
..
Spring Kafka异步发送调用块
我使用的是 Spring-Kafka 1.2.1 版，当 Kafka 服务器关闭/无法访问时，异步发送调用会阻塞一段时间.这似乎是TCP超时.代码是这样的: ListenableFuture>future = kafkaTemplate.send(topic, key, message);future.addCallback(new ListenableFutureCallback>() {@覆
..
从 docker 主机外部与 kafka docker 容器交互
我已经构建了一个 kafka docker 容器并使用 docker-compose 对其进行编排. 调用 docker ps 我得到以下输入: 容器 ID 图像命令创建状态端口名称5bde6f76246e hieutrtr/docker-kafka:0.0.1 "/start.sh" 大约一个小时前 Up 大约一个小时 7203/tcp, 0.0.0.0:32884->9092/tcp
..
控制台生产者中的领导者不可用 Kafka
我正在尝试使用 Kafka. 所有配置都正确完成，但是当我尝试从控制台生成消息时，我不断收到以下错误 WARN 获取相关 ID 为 39 的元数据时出错:{4-3-16-topic1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient) Kafka 版本:2.11-0.9.0.0 解决方案 它可能与 server
..
启用CDI注入由生产者方法创建的bean
生产者方法对于以编程方式创建实例并将其发布到上下文中非常有用.问题是CDI不会注入由 new 创建并由生产者方法返回的实例的所有属性.在Weld文档中，我读到这是故意的行为，但是在许多情况下，在那些bean中注入将非常有用. 是否有一种变通方法，可以注入到此类bean中? 解决方案 首先，我要问为什么您将Producers用于仍然需要注入的bean. 此外，您需要从BeanMa
..
生产者消费者中的死锁
I have following classes : package com.akshu.multithreading; public class ThreadResource { static int a; static boolean Value =false; public synchronized int getA()
..
CDI-生产者和合格者不在生产对象上
想象有一个SessionFactory的生产者(例如): @Produces public SessionFactory produceSessionFactory(){} 不，我还有第二个生成器，它可以生成其他对象，可以说是DatabaseObject，并且需要对SessionFactory的引用: @Produces public DatabaseObject produceD
..
无法建立与节点-1的连接.经纪人可能不可用. (org.apache.kafka.clients.NetworkClient)
我已经安装了Kafka并进行了一些基本测试.我可以使用Kafka-broker/bin文件夹下提供的脚本来创建主题. 但是，当我每次运行此命令时，如果试图生成低于WARNing的消息.而且没有消息产生.请指教. [root@node2 bin]# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test_
..
CDI-Unit @Produces无法正常工作
首先，我根据 http://jglue.org/cdi-unit进行了深入搜索-user-guide/生成要注入到单元测试中的东西应该可以正常工作. 我的设置: @RunWith(CdiRunner.class) public abstract class CdiUnitBaseTest extends DBUnitBaseTest { @Produces public Ent
..
我的产品消费者挂起
请复制下面的程序，然后尝试在您的IDE中运行.这是一个简单的Producer消费者实现-当我使用一个Producer和一个Consumer线程时，它运行良好，但当每个使用2个消费者线程时却失败.请让我知道该程序挂起的原因或其他问题. import java.util.LinkedList; import java.util.Queue; public class PCQueue { p
..
如何使用python asyncio编码consumer.producer?
我的Python版本是3.6.1 我写了一些东西来用Python asyncio实现消费者生产者模型. 但这并没有按预期工作. 全部创建了四个事件，但没有任何打印输出. async def consumer(queue, id): while True: val = await queue.get() print('{} get a val
..