qpid相关内容

AMQP 1.0 的实现在哪里?等待有意义吗?

我正在研究找出适合我们未来产品的消息传递解决方案,但我真的无法弄清楚这一点. 有很多 AMQP 0.9.1 实现(RabbitMQ、Apache Qpid、OpenAMQ 等等),但没有 AMQP 1.0 实现,尽管 1.0 已在 2011 年 10 月完成.好吧,除了 SwiftMQ [1]. 阅读 1.0 后,它似乎与 1.0 之前的规范大相径庭,因此似乎可以理解的是,对运行良好的 ..
发布时间:2022-01-11 17:42:11 其他开发

ZeroMQ、RabbitMQ 和 Apache Qpid 之间的性能比较

我的应用程序需要高性能消息总线,因此我正在评估 ZeroMQ、RabbitMQ 和 Apache Qpid 的性能.为了测量性能,我正在运行一个测试程序,该程序使用其中一个消息队列实现发布 10,000 条消息,并在同一台机器上运行另一个进程来使用这 10,000 条消息.然后我记录发布的第一条消息和收到的最后一条消息之间的时间差. 以下是我用于比较的设置. RabbitMQ:我使用了 ..
发布时间:2022-01-11 17:08:18 其他开发

带有JMS的Azure Service Bus的计划消息

我想使用JMS将计划的消息发送到Azure服务总线.我的代码基于 org.apache.qpid.jms.message.JmsMessage .我已经找到了解决给定问题的一种解决方案,但是它使用的是 org.apache.qpid.proton.message.Message ,该代码具有 .getMessageAnnotations(),该代码可以进行编辑消息注释,并添加一些可由Azure S ..
发布时间:2021-04-13 19:38:34 Java开发

将无代理的AMQP写入MQTT适配器

我想实现一个从amqp到mqtt的适配器,该适配器将接收amqp消息,获取其有效负载并将其作为mqtt消息发布到我的mqtt代理.因此,适配器必须能够 在端口上听 确认连接请求 接收amqp消息 确认他们 使用mqtt发布 在我的生态系统中,我想为传入消息提供不同的协议,但是我只想运行一个mqtt代理.我想避免其他经纪人.我在这里 amqp"1.0允许无代理点对点通信".我想这 ..
发布时间:2021-04-03 20:05:19 Java开发

如何使用SOCKS代理或Java中的任何其他代理通过SSL创建与AMQP队列的连接

使用SOCKS代理或任何其他代理,对于无法直接访问Internet或防火墙禁止amqps连接端口的环境,有什么方法可以使用org.apache.qpid.jms.JmsConnectionFactory通过SSL连接到amqp队列. 我已经尝试在可以使用Internet的环境中使用org.apache.qpid.jms.JmsConnectionFactory通过SSL连接到amqp队列.它 ..
发布时间:2021-04-03 20:05:16 Java开发

qpid-proton-0.17.0的链接错误

构建qpid-proton-0.17.0程序时,出现此链接错误: 对质子:: event_loop :: inject(std :: function)的未定义引用 这是我的建造方式: g ++ -std = c ++ 14 myprog.cpp -o myprog -lqpid-质子-cpp -lboost_system -lcrypto -lssl 我想念图书馆 ..
发布时间:2021-04-03 20:05:00 其他开发

在Qpid Broker中创建Exchange和队列

嗨,我正在使用嵌入式代理Qpid测试Spring集成项目.但是问题是我如何在qpid中进行队列和交换.我以为Rabbit-config.xml会在qpid代理中进行队列和交换,但无济于事.我的流程是创建队列,并在qpid代理中进行交换,将消息传递给它们,绑定到这些队列的入站amqp适配器将获得消息,我可以继续进行测试 错误:队列:在VirtualHost“默认"上找不到"push.custo ..
发布时间:2020-07-05 01:41:43 其他开发

在Spring Azure qPID JMS代码中跟踪内存泄漏

我正在尝试在我们非常小的和简单的Spring Boot应用程序中跟踪和识别导致内存泄漏的根本原因. 它使用以下内容: -Spring Boot 2.2.4 -azure-servicebus-jms-spring-boot-starter 2.2.1 -MSSQL 功能: 该应用程序仅调度Azure ServiceBus队列并存储数据,并将数据发送到其他目标. 这是一个小型应用程序,因 ..

python-qpid-proton示例,向azure发送消息不起作用

我正在尝试使用python-qpid-proton版本0.9.1将消息发送到Azure服务总线队列. examples/python/messenger/中的示例接受格式为amqps://:@/的地址,因此我可以成功地将消息发送到我在Azure上拥有的队列中.问题是我无法控制很多事情,也就是说,我真的看不到发送是否失败. ..
发布时间:2020-07-05 01:40:32 Python

RabbitMQ的集成测试

当前,我正在处理某些与RabbitMQ交互的Spring Boot 2.x应用程序. 我想创建一个集成测试来测试整个应用程序.逻辑,包括与Rabbit互动.到目前为止,我需要轻巧的AMQP标准独立实现来使Spring Boot与其配合使用,包括发送&接收消息.我在这里 但它需要RabbitMQ在对我的IT不太有利的地方运行.还有其他成熟的轻量级独立AMQP实现吗? 首先感谢您的协助. ..
发布时间:2020-07-05 01:39:23 其他开发

NET的AMQP V1.0客户端

我正在考虑使用RabbitMQ或ActiveMQ之类的产品.我看到这些产品在一定程度上对AMQP v1.0提供了一定程度的支持. 但是,我正在努力寻找将AMQP 1.0与.NET结合使用的客户端.到目前为止,我遇到的唯一一个是Apache Qpid.但是,必须安装所有依赖项并进行构建,而不仅仅是使用诸如NuGet之类的方法来获取客户端库,这似乎有点麻烦,并且没有使我对支持向前发展充满信心. ..
发布时间:2020-07-05 01:38:16 C#/.NET

订阅/侦听Azure Event Hub的python脚本?

我有兴趣从Python脚本监听事件中心,并在检测到入站消息时执行一些代码. 在Ubuntu上,将Python 2.7与 https://pypi.python.org一起使用/pypi/python-qpid-proton/0.10 和示例“接收器"脚本,我尝试订阅一个看起来像这样的URI: amqps://:@.servicebus ..
发布时间:2020-07-05 01:37:07 Python

AMQP 1.0的实现在哪里?等待会有意义吗?

我正在做研究,以确定可以为我们的未来产品选择哪种消息传递解决方案,而我真的无法弄清楚这一解决方案. 有很多AMQP 0.9.1实现(RabbitMQ,Apache Qpid,OpenAMQ,仅举几例),但没有AMQP 1.0实现,尽管1.0已于2011年10月完成.嗯,除了SwiftMQ [1]. 从1.0开始阅读,似乎与1.0之前的规范有很大的出入,因此可以理解,对于工作良好的东西进 ..
发布时间:2020-07-05 01:37:01 其他开发

使用Qpid通过SSL与AMQP 1.0代理进行通信

我使用的是ActiveMQ 5.8.0,它支持AMQP 1.0作为队列代理。我正在尝试使用Qpid AMQP1.0客户端jms库从Java客户端与之通信,但是看不到指定密钥库和信任库信息的方法。 通过通过Java VM选项(例如-Djavax.net.ssl.keyStore)传入SSL凭据成功配置了客户端,但是对于我的最终解决方案,这不是可接受的方法...我需要能够指定此信息 我目前 ..
发布时间:2020-06-01 19:20:44 Java开发

ZeroMQ,RabbitMQ和Apache Qpid之间的性能比较

我的应用程序需要高性能的消息总线,因此我正在评估ZeroMQ,RabbitMQ和Apache Qpid的性能.为了衡量性能,我正在运行一个测试程序,该程序使用消息队列实现之一发布10,000条消息,并在同一台计算机上运行另一个进程以消耗这10,000条消息.然后,我记录发布的第一条消息和收到的最后一条消息之间的时间差. 以下是我用于比较的设置. RabbitMQ:我使用了“扇出"类型交 ..
发布时间:2020-05-09 01:24:30 其他开发