ActiveMQ Artemis:从smallrye-reactive-messaging (AMQP)以编程方式创建队列
基础概念
ActiveMQ Artemis 是一个高性能、支持多种协议的消息代理，适用于企业级应用。它支持 AMQP（高级消息队列协议），使得不同系统之间可以进行可靠的消息传递。SmallRye Reactive Messaging 是一个用于构建响应式微服务的框架，它提供了对 AMQP 协议的支持。
相关优势
- 高性能：ActiveMQ Artemis 设计用于高吞吐量和低延迟的消息传递。
- 多协议支持：除了 AMQP，还支持 MQTT、STOMP 等多种消息协议。
- 可扩展性：支持集群部署，能够处理大规模的消息负载。
- 响应式编程：与 SmallRye Reactive Messaging 结合，可以构建响应式微服务，提高系统的弹性和可维护性。
类型
- 队列（Queue）：用于存储消息，支持点对点的消息传递。
- 主题（Topic）：用于发布/订阅模式，支持一对多的消息传递。
应用场景
- 微服务架构：用于不同微服务之间的异步通信。
- 事件驱动架构：用于事件的发布和订阅。
- 系统集成：用于不同系统之间的数据同步。
编程方式创建队列
以下是一个使用 SmallRye Reactive Messaging 和 ActiveMQ Artemis 以编程方式创建队列的示例：
import io.smallrye.reactive.messaging.annotations.Channel;
import io.smallrye.reactive.messaging.annotations.Emitter;
import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.eclipse.microprofile.reactive.messaging.Outgoing;
import javax.enterprise.context.ApplicationScoped;
@ApplicationScoped
public class MessageProcessor {
@Channel("my-queue")
Emitter<String> emitter;
@Incoming("source-channel")
@Outgoing("my-queue")
public String process(String message) {
// 处理消息逻辑
return message.toUpperCase();
}
public void sendMessage(String message) {
emitter.send(message);
}
}遇到的问题及解决方法
问题：无法连接到 ActiveMQ Artemis 服务器
原因：
- 配置错误：连接 URL 或凭证配置不正确。
- 网络问题：防火墙阻止了连接。
- 服务器未启动：ActiveMQ Artemis 服务器未启动或崩溃。
解决方法：
- 检查配置：确保连接 URL 和凭证正确无误。
- 检查网络：确保防火墙允许连接，并且网络连接正常。
- 检查服务器状态：确保 ActiveMQ Artemis 服务器已启动并运行正常。
示例代码
import io.smallrye.reactive.messaging.annotations.Channel;
import io.smallrye.reactive.messaging.annotations.Emitter;
import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.eclipse.microprofile.reactive.messaging.Outgoing;
import javax.enterprise.context.ApplicationScoped;
@ApplicationScoped
public class MessageProcessor {
@Channel("my-queue")
Emitter<String> emitter;
@Incoming("source-channel")
@Outgoing("my-queue")
public String process(String message) {
// 处理消息逻辑
return message.toUpperCase();
}
public void sendMessage(String message) {
emitter.send(message);
}
}参考链接
通过以上信息，您可以更好地理解 ActiveMQ Artemis 和 SmallRye Reactive Messaging 的结合使用，以及如何在实际应用中创建和使用队列。
相关·内容
我的Quarkus微服务正在使用smallrye反应式消息传递库中的AMQP连接器来生成发送到从运行的ActiveMQ Artemis代理的消息 Docker镜像。=localhostamqp-username=adm
mp.messaging.outgoing.task-finished.connector=smallrye-amqp ActiveMQ A
浏览 104提问于2021-03-01得票数 0
回答已采纳
我们使用JBoss EAP7.3和嵌入式ActiveMQ。我有一个用例，需要以编程方式暂停队列。我找到的唯一完整的示例是中的堆栈溢出。他的解决方案如下所示：
String eapObjectName = "org.apache.activemq.artemis:broker=\"default\",component=addresses它运行在运行ActiveMQ Artemis代理的同一个ActiveMQ</em
浏览 6提问于2022-02-25得票数 0
回答已采纳
我已经将Apache ActiveMQ嵌入到我的java 8服务器端项目中。它工作正常，而且我能够从预先配置的队列中发送和使用消息。现在，我需要能够根据请求以编程方式从队列中删除消息。在阅读了一些文档之后，我发现Apache ActiveMQ有一个名为Artemis的子项目，它似乎提供了所需的功能。但我有点搞不懂怎么做。是Artemis在ActiveMQ之上的某种插件，我只需要添加
浏览 4提问于2016-02-23得票数 0
回答已采纳
使用点对点发送/接收的嵌入式Artemis代理发送和接收消息的。此示例是自包含的，不需要使用XML或任何其他外部文件进行进一步配置。在本例中，将使用以下行在此代理下创建一个新的核心队列：
QueueConfiguration coreQueueConfiguration = new QueueConfiguration(QUEUE_NAMEorg.apache.activemq.artemis.api.core.QueueConfiguration类由Artemis项目提供，以
浏览 5提问于2021-12-31得票数 3
回答已采纳
我们使用.NET客户端使用AMQPNetLite库连接到ActiveMQ Artemis。我需要设置预确认模式，并从文档中了解到，这可以在connector中的broker.xml文件中设置。
浏览 7提问于2019-12-11得票数 0
回答已采纳
1回答
我必须运行同一个应用程序的两个实例，该应用程序从‘Quee-1’读取消息，然后将它们写回另一个队列‘queue -2’。但是，由于有多个使用者读取、处理和发送已处理的消息到队列-2，队列2中的消息顺序可能会丢失。
因此，我的任务是确保消息以与从队列1读取消息相同的顺序传递到队列2。我已经实现了从Apache camel到队列2中重新排序消息的重新排序器模式。重新排序器工作良好，但结果是数据传输开销，因为骆驼路线在本地
浏览 2提问于2017-11-16得票数 0
回答已采纳
然后，我看到它成功地连接到master-0 (我看到创建了队列，并且使用者计数> 0)。然而，主-0上的队列是空的，而主-1中的同一个队列仍然有15条消息，并且没有附加到它上。除了更改connector-ref以匹配代理之外，其他经纪人的信任也是相同的：
<?xml version="1.0"?<connector name="activemq-artemis-slave-0">tcp:/
浏览 6提问于2021-05-21得票数 3
回答已采纳
下载Artemis2.13.0，预先创建一个多播地址测试，然后在这个地址上创建一个多播队列123，使用控制台向123队列发送1条消息
spring.artemis.mode=native=123456 Spring
浏览 0提问于2020-06-06得票数 2
除了更改connector-ref以匹配代理之外，其他经纪人的信任也是相同的：<!-- AMQP Acceptor.Listens on default AMQP port for AMQP traffic.-->
<acceptor name="amqp">tcp://0.0.0.0:5672?<connector name="
浏览 9提问于2021-05-11得票数 3
回答已采纳
我们正试图从Artemis 5.x升级到最新的ActiveMQ (2.17)，但是我们的一个应用程序给我们带来了麻烦。我们
浏览 43提问于2021-03-06得票数 0
4回答
StackOverflowers朋友，有没有办法在ActiveMQ中以编程方式删除队列或主题？我使用的是ActiveMQ的标准持久性，并且我的应用程序要求在启动时动态地重新创建所有新队列(除非队列中存储了消息，在这种情况下，队列应该仍然存在)。
我还通过会话以编程方式创建了所有队列。是否有一个等同于该过程的过程，仅删除队
浏览 0提问于2010-06-14得票数 6
1回答
first项目是一个遗留的Dotnet项目，使用Apache库来使用来自ActiveMQ队列的消息。队列通常是通过SSL在生产中连接的，但在本地开发时，我已经通过TCP进行了连接，所有这些都可以正常工作，并按预期的方式主动连接和排队列。一旦消息退出队列，它们就会使用JsonConvert DeserializeObject方法反序列化。
第二个项目是一个NodeJS项目，我创建这个项目是为了将消息放到队列中。我使用AMQP 以
浏览 8提问于2022-11-25得票数 1
在互联网上摸索了这么多之后，我发现无法使用WildFly 10中的JMS和ActiveMQ (Artemis)推送到远程消息队列的示例配置令人惊讶。<subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0"> <security-settingjava:jboss/DefaultJMSConnectionFact
浏览 1提问于2016-09-02得票数 7
3回答
我目前正在使用ActiveMQ来满足我的消息传递需求；除了几个db故障之外，它运行得很好。然而，我至少考虑尝试一下RabbitMQ。但在此之前，我想了解以下几点：
RabbitMQ与ActiveMQ有什么不同之处？RabbitMQ比ActiveMQ做的更好还是更糟？使用ActiveMQ，我只需将一个连接工厂bean连接到一个JmsTemplate中，并使用DefaultMessageListener bean将队列连接到它们各自的处理程序。
浏览 0提问于2011-08-12得票数 52
2回答
在云连接方面，MQTT和AMQP有什么区别？我需要在云连接/协作方面对这两个协议进行比较。我发现了一些AMQP效果更好的证据，但我仍然需要找出其中的区别。
浏览 7提问于2016-09-21得票数 30
回答已采纳
本质上，我的用例要求在午夜附近的某个时间点生成400万到500万条消息，这些消息计划在预定义的预定时段(例如上午11点、下午3点、下午6点)以分组的形式离开。可以更早地从其他消息写入队列，因此可以按顺序将计划好的消息交织在一起。而且，由于消息的数量相当大，我可以看到所使用的地址内存正在最大化，并且在队列的分页目录上创建了多个文件。当我的jms应用程序开始使用来自指定队列的消息时，就会出现我的问题，尽管它在某个时候开始以非常快的速度使用数据，但它会阻塞并失去响应。] AM
浏览 1提问于2021-03-31得票数 0
我使用activemq进行spring引导，我希望迁移到artemis，以改进集群和节点的使用。}
我读过，artemis将它的地址模型更改为地址、队列和路由类型()，而不是队列、主题和虚拟主题()，就像在activemq中那样。我读了更多的书，但我想我看错了，我现在可以迁移了。我尝试了类似于上面的方法，所以我从Maven导入了，并希望像以前一样使用它，但是使用FQQN (完全限定<
浏览 0提问于2020-03-29得票数 1
回答已采纳
我遇到了一个对我来说不同寻常的代理行为(ActiveMQ-ArtemisVersion2.17.0)。
主要问题。
浏览 4提问于2021-04-05得票数 1
回答已采纳
不幸的是，我找不到办法：
jndi.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory表面
浏览 3提问于2020-03-18得票数 2
回答已采纳
在ActiveMQ Artemis 1.5.6中，通过Jolokia调用listAllSubscriptions of 可以获取主题的所有订阅，例如：
.../jolokia/exec/org.apache.activemq.artemis:type=Broker,brokerName="broker-name",module=JMS,serviceType=Topic,name="topic-name"/listAllSubscription
浏览 2提问于2021-07-22得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
