activemq介绍 ActiveMQ是开源的，支持多种协议(CORE,AMQP,MQTT,JMS...), 基于java的消息系统(或消息中间件)。...它支持业界标准协议，这样有利于客户端的选择(从c,c++,python,.net等) 当期有2个版本的ActiveMQ ActiveMQ "Classic" ActiveMQ Artemis 因为Artemis...是下一代的ActiveMQ,所以后面介绍基于Artemis。...ActiveMQ Artemis 下一代高性能，非阻塞架构，基于事件驱动的消息系统 特性： 提供实现JMS 1.1 & 2.0 的客户端,包含JNDI 通过共享存储和网络复制提供高可用 简单&强大的协议无感知的寻址模型...(addressing model) 灵活的集群用于分布式负载 基于日志的低延迟持久化 方便从ActiveMQ 5迁移 使用 下载Artemis,并解压 创建Broker Instance 执行 ${
编译代码 代码版本选用2.26.0的分支代码编译花了17分钟 梳理流程 测试用例 org/apache/activemq/artemis/jms/tests/TopicTest.java @Testpublic...= null) { body.resetReaderIndex(); } } 最后都去文本读取在这个方法里 org.apache.activemq.artemis.api.core.SimpleString...org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl#receive(long, boolean) 获取消息重点还是得看这段代码...closed && toWait > 0) { 然后从buffer里面读取byte数组 org.apache.activemq.artemis.api.core.SimpleString#readSimpleString...引用 https://activemq.apache.org/components/artemis/documentation/hacking-guide/
8.集成属性 键 默认值 描述 spring.activemq.broker-url ActiveMQ代理的URL。默认情况下自动生成。...spring.activemq.password 经纪人的登录密码。 spring.activemq.pool.block-if-full true 在请求连接且池已满时是否阻止。...spring.activemq.send-timeout 0ms 等待消息的时间发送了响应。将其设置为0以永远等待。 spring.activemq.user 经纪人的登录用户。...spring.artemis.embedded.enabled true 如果Artemis服务器API可用，是否启用嵌入式模式。...spring.artemis.mode Artemis部署模式，默认情况下自动检测。 spring.artemis.password 经纪人的登录密码。
如果搞个服务器装就太辛苦了，所以就想到了 NAS，我们的 NAS 上已经装了 Docker，我们直接运行一个 Activemq Artemis 的镜像不就好了。...然后输入 activeMq 进行查找。选择已经找到的镜像，然后单击页面上部的下载按钮。选择最新版本。直接单击应用就好。我们可以看到在界面中，提示进行正在下载，在这里根据你网络的情况可能需要点时间。...访问消息服务器ActiveMQ Artemis 的管理界面使用的端口是 8161。直接访问上面的地址。...使用的登录用户名和密码是在你创建容器的时候默认输入的，如果你没有改过，用户名密码都为：artemis上图就显示的是当前正在运行的消息服务器。...https://www.isharkfly.com/t/synology-nas-docker-activemq-artemis/14879
Server QoS 0 QoS 1 QoS 2 auth bridge $SYS SSL dynamic topics cluster websockets plugin system 2lemetry...✔ ✔ ✔ ✔ ✔ § ✔ ✔ ✔ ✔ ✘ Apache ActiveMQ ✔ ✔ ✔ ✔ ✘ ✘ ✔ ✔ ✔ ✔ ✔ Apache ActiveMQ Artemis ✔ ✔ ✔ ✔ ✘ ✘ ✔ ✔
序 本文主要研究一下artemis的ConnectionLoadBalancingPolicy ServerLocatorImpl.selectConnector activemq-artemis-2.11.0.../artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/ConnectionLoadBalancingPolicy.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/RandomConnectionLoadBalancingPolicy.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java
33.1.1 ActiveMQ支持 当ActiveMQ在类路径上可用时，Spring Boot也可以配置 ConnectionFactory 。...ActiveMQ配置由 spring.activemq.* 中的外部配置属性控制。...将 org.apache.activemq:artemis-jms-server 添加到您的应用程序可让您使用嵌入模式。 Artemis配置由 spring.artemis.* 中的外部配置属性控制。...这些可以指定为逗号分隔列表以使用默认选项创建它们，或者您可以分别为 高级队列和主题配置定义 org.apache.activemq.artemis.jms.server.config.JMSQueueConfiguration...或 org.apache.activemq.artemis.jms.server.config.TopicConfiguration 类型的bean。
序 本文主要研究一下artemis的ConnectionLoadBalancingPolicy th (3).jpeg ServerLocatorImpl.selectConnector activemq-artemis...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/ConnectionLoadBalancingPolicy.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/RandomConnectionLoadBalancingPolicy.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java
序 本文主要研究一下artemis的callFailoverTimeout establishNewConnection activemq-artemis-2.11.0/artemis-core-client...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQClientProtocolManager.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/RemotingConnectionImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ChannelImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
序 本文主要研究一下artemis的confirmationWindowEnabled confirmationWindowEnabled activemq-artemis-2.11.0/artemis-core-client...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientProducerImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat
序 本文主要研究一下artemis的QuorumManager th (1).jpeg ClusterTopologyListener activemq-artemis-2.11.0/artemis-core-client...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterController.java
序 本文主要研究一下artemis的QuorumManager ClusterTopologyListener activemq-artemis-2.11.0/artemis-core-client/src...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterController.java
序 本文主要研究一下artemis的connectionTtlCheckInterval connectionTtlCheckInterval activemq-artemis-2.11.0/artemis-server.../src/main/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImpl.java public class ConfigurationImpl...this; } //...... } ConfigurationImpl定义了connectionTtlCheckInterval属性，默认为2000 RemotingServiceImpl activemq-artemis...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImpl.java...; } //...... } ConfigurationImpl定义了connectionTtlCheckInterval属性，默认为2000 RemotingServiceImpl activemq-artemis...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java...connectionTtlCheckInterval创建了FailureCheckAndFlushThread，并执行failureCheckAndFlushThread.start()方法 FailureCheckAndFlushThread activemq-artemis...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
序 本文主要研究一下artemis的ExpiryScanner pe_mco_diagram.png startExpiryScanner activemq-artemis-2.11.0/artemis-server...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/PostOfficeImpl.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java class...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public
序 本文主要研究一下artemis的DelayedAddRedistributor exchanges-topic-fanout-direct.png addRedistributor activemq-artemis...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java protected...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public
序 本文主要研究一下artemis的ActiveMQMetricsPlugin ActiveMQMetricsPlugin activemq-artemis-2.11.0/artemis-server/...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/metrics/plugins/SimpleMetricsPlugin.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/metrics/plugins/LoggingMetricsPlugin.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/deployers/impl/FileConfigurationParser.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/metrics/MetricsManager.java
序 本文主要研究一下artemis的scheduledDeliveryTime HDR_SCHEDULED_DELIVERY_TIME activemq-artemis-2.11.0/artemis-core-client...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/PostOfficeImpl.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public
序 本文主要研究一下artemis message的priority priority activemq-artemis-2.11.0/artemis-core-client/src/main/java.../org/apache/activemq/artemis/core/message/impl/CoreMessage.java public class CoreMessage extends RefCountMessage...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public...-2.11.0/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityLinkedList.java...-2.11.0/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityLinkedListImpl.java
序 本文主要研究一下artemis的confirmationWindowEnabled introduction-to-apache-activemq-artemis-6-638.jpg confirmationWindowEnabled...activemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientProducerImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
