-
1 votesanswersviews
使用Google协议缓冲区和Protobuf-C从C到C#传输双重属性的问题#
我试图通过QPID(一个消息传递系统)将对象作为序列化字符串从C语言发送到C# . 我目前有一个Google原型文件: package Serializable; message Order_ser { optional int32 openord = 1 [default = 0]; optional int32 oldord = 2 [default = 0]; ... -
3 votesanswersviews
ActiveMQ 5.10 / QPid 0.28 / AMQP 1.0性能问题
我正在尝试使用OpenWire和AMQP与ActiveMQ进行性能基准测试,并获得巨大的吞吐量变化 Using Openwire 持久消息大小:43个字节,无压缩,200个并发连接,吞吐量大约为9006 msgs / sec . 持久消息大小:1580字节,无压缩,200个并发连接,吞吐量约为3678.86 msgs / sec . 有 not much load on CPU 小于5%所以我可以... -
7 votesanswersviews
QPID - Spring CachingConnectionFactory - 重新连接
spring 配置 <bean id="jmsQueueConnectionFactory" class="org.apache.qpid.client.AMQConnectionFactory"> <constructor-arg index="0" value="amqp://gue... -
2 votesanswersviews
Qpid - 向具有不同性能特征的消费者负载均衡消息
我有以下场景: 我正在将100条消息推送到2个消费者共享的队列中 . 两个订户都以预先获取模式和显式模式订阅队列 . 处理完每条消息后,每个订阅者都接受该消息以将其从队列中删除 . 伪代码看起来像: OnMessageTransfer(message) : DoSomethingWithMessage(message) Session.MessageAccept(message) ... -
0 votesanswersviews
AMQP QPID中的网络流量
QPID AMQP 我有一个问题重新调整网络流量 . 假设我在机器A上有一个发布者 . Qpid代理正在机器B上运行 . 我们有两个订户机器C和机器D(他们都订阅相同的主题) . 现在想象一下拓扑在哪里A - > B - > X - > C | D(发布者A连接到B,订阅者C和D连接到Broker通过和中间节点X)A发布的消息与C和D的主题相匹配将被两者接收 . 我想知道... -
1 votesanswersviews
AMQP上的ServiceBus关闭了消费者
我们有ServiceBus和Java JMS QPID客户端0.26的本地安装 . 似乎SB中存在错误 - 它在 生产环境 者关闭连接时向消费者发送END命令 . 生产环境 者和消费者都必须在同一台机器上运行 . 首先启动侦听队列的消费者: static void consumeFromQueueForStackOverflow(Connection connection, Context co... -
4 votesanswersviews
具有RabbitMQ客户端身份验证异常的QPID代理
我正在使用Java QPID代理进行测试 . 我能够使用质子客户端发送和接收消息,但使用匿名身份验证 . 我感兴趣的是打开身份验证测试,并了解质子客户端不支持(尚未) . 因此我下载了rabbitMQ客户端jar . 我正在使用密码文件身份验证(QPID附带) . 我像这样设置我的RabbitMQ客户端连接工厂: connectionFactory = new ConnectionFactory(... -
0 votesanswersviews
AMQP(Qpid)一对多排队
我有一个 生产环境 者,一个队列和N个消费者 . 制片人创造由消费者执行的“工作” . 我想使用拉模型,其中消费者从队列中拉出作业,当它完成前一个作业时,不推动循环模型,其中作业被等于消费者 . 我的消费者使用相同的代码,但是当我运行它时,第一个连接并接收所有作业 . 即使在调试中查看它,第一个获取所有内容,但第二个等不会获得任何消息(即使它在第一个执行接收之前执行接收,它返回一些作业) . 连接... -
1 votesanswersviews
Spring AMQP使用noLocal使用者发送和接收临时队列
使用临时队列发送和接收时,会创建使用 noLocal 属性设置为 true 的使用者(请参阅RabbitTemplate#doSendAndReceiveWithTemporary method line 1297 of version 1.7.4.RELEASE) . 根据javadocs for the basicConsume method,当此属性设置为 true 时,则"the... -
0 votesanswersviews
生产环境 者(设备)和Messaging Server(Apache Qpid或RabbitMQ)之间的负载 balancer
最近我开始研究一个需要实现Messaging的项目,可行的选项有:Apache Qpid或RabbitMq,My Task是这样的: +A+ >>.[Millions Devices (Producers) -- Connected to -- Messaging Server (Clustered -- Qpid or RabbitMQ) ] { LOAD BALANCING) 然后... -
0 votesanswersviews
Azure EventHub上的Qpid接收器
我已经基于Azure EventHub工作了应用程序 . 现在我需要编写连接到现有基础架构的java接收器 . 现有配置: 事件中心> SomeName>使用者组> SomeGroupName 在管理控制台中,我看不到任何QUEUE或TOPIC定义 . 分析工作的c#代码我可以看到hub-name group-name足以连接 . 我重建了url,允许我通过java连接(到目前为... -
0 votesanswersviews
使用QPid和golang包装器Electron连接到AMQP 1.0 Azure EventHub
我想使用Electron golang包装器为Qpid proton-c库连接到Azure EventHub . 我将以下SASL详细信息组合到构建连接字符串所需的host / port / namespace / path但由于某种原因我不断收到错误消息: connection reset by peer . package main import ( "fmt"...