搜索 - 腾讯云开发者社区-腾讯云

文章/答案/技术大牛

发布

来自专栏电光石火
Activemq Artemis安装
它支持业界标准协议，这样有利于客户端的选择(从c,c++,python,.net等) 当期有2个版本的ActiveMQ ActiveMQ "Classic" ActiveMQ Artemis 因为Artemis 是下一代的ActiveMQ,所以后面介绍基于Artemis。 (addressing model) 灵活的集群用于分布式负载基于日志的低延迟持久化方便从ActiveMQ 5迁移使用下载Artemis,并解压创建Broker Instance 执行 ${ ARTEMIS_HOME}/bin/artemis create mybroker ${ARTEMIS_HOME}下载解压的目录 mybroker名字自定义可以看到生成了一个目录mybroker,里面有各种文件配置) mybroker/bin/artemis run -- xml:path/to/bootstrap.xml //关闭服务 mybroker/bin/artemis stop
1.4K30编辑于 2021-12-28
来自专栏码匠的流水账
artemis小结
序本文主要小结一下artemis的一些知识点 artemis知识点消息模型它实现了mqtt、aqmp、stomp协议，jms的api，还提供了rest的api；其模型跟aqmp很像，用address docker支持提供基于centos及ubuntu的docker文件 test支持有丰富的各种测试，比如junit(提供了专门的TestRule)、smoke、stress、timing等小结 artemis 算是系出名门，代码里头很有企业级产品的味道，还值得深入研究研究 doc Java消息服务概要 artemis doc
81120发布于 2020-02-26
来自专栏码匠的流水账
artemis小结
序本文主要小结一下artemis的一些知识点 th (58).jpeg artemis知识点消息模型它实现了mqtt、aqmp、stomp协议，jms的api，还提供了rest的api；其模型跟 docker支持提供基于centos及ubuntu的docker文件 test支持有丰富的各种测试，比如junit(提供了专门的TestRule)、smoke、stress、timing等小结 artemis 算是系出名门，代码里头很有企业级产品的味道，还值得深入研究研究 doc Java消息服务概要 artemis doc
41800发布于 2020-02-22
来自专栏码匠的流水账
聊聊artemis的ResourceLimitSettings
序本文主要研究一下artemis的ResourceLimitSettings ResourceLimitSettings activemq-artemis-2.11.0/artemis-server/ src/main/java/org/apache/activemq/artemis/core/settings/impl/ResourceLimitSettings.java public class null; //...... } ResourceLimitSettings定义了maxConnections、maxQueues属性 ActiveMQServerImpl activemq-artemis -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java ActiveMQMessageBundle.BUNDLE.queueLimitReached 小结 ResourceLimitSettings定义了maxConnections、maxQueues属性；artemis
49930发布于 2020-02-26
来自专栏码匠的流水账
聊聊artemis的callFailoverTimeout
序本文主要研究一下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
63320发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的connectionTtlCheckInterval
序本文主要研究一下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 //...... } 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
72321发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的DelayedAddRedistributor
序本文主要研究一下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
56400发布于 2020-02-20
来自专栏码匠的流水账
聊聊artemis的connectionTtlCheckInterval
序本文主要研究一下artemis的connectionTtlCheckInterval heap-blog-engineering-image2-e1551739153635.png connectionTtlCheckInterval 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 -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
54400发布于 2020-02-03
来自专栏码匠的流水账
聊聊artemis的gracefulShutdownEnabled
序本文主要研究一下artemis的gracefulShutdownEnabled th (50).jpeg gracefulShutdownEnabled activemq-artemis-2.11.0 /artemis-server/src/main/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImpl.java public -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java .await()，否则执行remotingService.getConnectionCountLatch().await(timeout) connectionCountLatch activemq-artemis -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
49900发布于 2020-01-18
来自专栏码匠的流水账
聊聊artemis的QuorumVote
序本文主要研究一下artemis的QuorumVote QuorumVote activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache /activemq/artemis/core/server/cluster/qourum/QuorumVote.java public abstract class QuorumVote<V extends */ public abstract Vote connected(); /** * called by the {@link org.apache.activemq.artemis.core.server.cluster.qourum.QuorumManager QuorumVote是个抽象类，定义了connected、notConnected、vote、getDecision、allVotesCast抽象方法 QuorumVoteServerConnect activemq-artemis -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumVoteServerConnect.java
46210发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的ServerConnectionLifeCycleListener
序本文主要研究一下artemis的ServerConnectionLifeCycleListener th (51).jpeg BaseConnectionLifeCycleListener activemq-artemis -2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/spi/core/remoting/BaseConnectionLifeCycleListener.java -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/spi/core/remoting/ServerConnectionLifeCycleListener.java -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/server/impl/ActiveMQServerImpl.java
55330发布于 2020-01-21
来自专栏码匠的流水账
聊聊artemis的BaseInterceptor
序本文主要研究一下artemis的BaseInterceptor th (49).jpeg BaseInterceptor activemq-artemis-master/artemis-core-client /src/main/java/org/apache/activemq/artemis/api/core/BaseInterceptor.java public interface BaseInterceptor BaseInterceptor定义了intercept方法，该方法返回true表示可以继续下一个interceptor，返回false表示终止packet的处理 AbstractProtocolManager activemq-artemis-master /artemis-server/src/main/java/org/apache/activemq/artemis/spi/core/protocol/AbstractProtocolManager.java
74300发布于 2020-01-12
来自专栏码匠的流水账
聊聊artemis的HAManager
序本文主要研究一下artemis的HAManager HAManager activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ha/StandaloneHAManager.java -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ha/ColocatedHAManager.java -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ha/BackupPolicy.java -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ha/ReplicaPolicy.java
62910发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的FederatedQueue
序本文主要研究一下artemis的FederatedQueue FederatedQueue activemq-artemis-2.11.0/artemis-server/src/main/java/ -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/federation/FederatedAbstract.java -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/federation/FederatedQueueConsumerImpl.java -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/client/impl/ClientConsumerImpl.java
48920发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的scheduledDeliveryTime
序本文主要研究一下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
91820发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的DiscoveryGroup
序本文主要研究一下artemis的DiscoveryGroup DiscoveryGroup activemq-artemis-2.11.0/artemis-core-client/src/main/ java/org/apache/activemq/artemis/core/cluster/DiscoveryGroup.java public final class DiscoveryGroup implements -2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/cluster/DiscoveryGroup.java -2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/JGroupsBroadcastEndpoint.java -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BroadcastGroupImpl.java
51720发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的confirmationWindowEnabled
序本文主要研究一下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
76130发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的lastValueProperty
序本文主要研究一下artemis的lastValueProperty Image%202018-09-13%20at%2012.22.09%20PM.png CoreMessage activemq-artemis -2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.java -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/MessageReferenceImpl.java message获取queue.getLastValueKey()的属性值，如果为null再读取message.getLastValueProperty() LastValueQueue activemq-artemis -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LastValueQueue.java
40800发布于 2020-02-07
来自专栏码匠的流水账
聊聊artemis的SharedNothingBackupQuorum
序本文主要研究一下artemis的SharedNothingBackupQuorum SharedNothingBackupQuorum activemq-artemis-2.11.0/artemis-server /src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/SharedNothingBackupQuorum.java true则立刻返回，否则执行voteGuard.wait(voteRetryWait)，进行重试，重试voteRetries次 SharedNothingBackupActivation activemq-artemis -2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingBackupActivation.java
32720发布于 2020-02-24
来自专栏码匠的流水账
聊聊artemis的ConnectionLoadBalancingPolicy
序本文主要研究一下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/FirstElementConnectionLoadBalancingPolicy.java -2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/RandomConnectionLoadBalancingPolicy.java
67700发布于 2020-02-19

第 2 页第 3 页第 4 页第 5 页第 6 页第 7 页第 8 页第 9 页第 10 页第 11 页

点击加载更多

Activemq Artemis安装

artemis小结

artemis小结

聊聊artemis的ResourceLimitSettings

聊聊artemis的callFailoverTimeout

聊聊artemis的connectionTtlCheckInterval

聊聊artemis的DelayedAddRedistributor

聊聊artemis的connectionTtlCheckInterval

聊聊artemis的gracefulShutdownEnabled

聊聊artemis的QuorumVote

聊聊artemis的ServerConnectionLifeCycleListener

聊聊artemis的BaseInterceptor

聊聊artemis的HAManager

聊聊artemis的FederatedQueue

聊聊artemis的scheduledDeliveryTime

聊聊artemis的DiscoveryGroup

聊聊artemis的confirmationWindowEnabled

聊聊artemis的lastValueProperty

聊聊artemis的SharedNothingBackupQuorum

聊聊artemis的ConnectionLoadBalancingPolicy

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐