Apache ActiveMQ/Artemis PeriodicRotatingFileHandler - 腾讯云开发者社区

文章/答案/技术大牛

发布

Activemq Artemis安装

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 执行 ${

1.4K3 0

activemq artemis源码阅读，读取消息

编译代码代码版本选用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/

4223 1

您找到你想要的搜索结果了吗？

是的

没有找到

聊聊artemis的ConnectionLoadBalancingPolicy

/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...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java

6301 0

聊聊artemis的ConnectionLoadBalancingPolicy

-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...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java

6660 0

聊聊artemis的QuorumManager

/main/java/org/apache/activemq/artemis/api/core/client/ClusterTopologyListener.java public interface...-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

6231 0

聊聊artemis的QuorumManager

-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...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConnectVoteHandler.java

7430 0

聊聊artemis的confirmationWindowEnabled

-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/ChannelImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat

7523 0

聊聊artemis的confirmationWindowEnabled

序本文主要研究一下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

7750 0

聊聊artemis的ExpiryScanner

-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...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java public

6350 0

聊聊artemis的scheduledDeliveryTime

activemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl...-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

5960 0

聊聊artemis的ActiveMQMetricsPlugin

src/main/java/org/apache/activemq/artemis/core/server/metrics/ActiveMQMetricsPlugin.java public interface...-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

5235 0

聊聊artemis的persistenceEnabled

/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImpl.java public class ConfigurationImpl...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java...-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/persistence/impl/journal/AbstractJournalStorageManager.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageManager.java

4072 0

聊聊artemis的callFailoverTimeout

/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java public class...-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

6212 0

聊聊artemis的individualAcknowledge

2.11.0/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java public...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientMessageImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java

7950 0

聊聊artemis的scheduledDeliveryTime

-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...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ScaleDownHandler.java

9092 0

聊聊artemis的SessionProducerCreditsMessage

序本文主要研究一下artemis的SessionProducerCreditsMessage apache-activemq-camel-cxf-and-servicemix-overview-5-...apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java public...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQSessionContext.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/spi/core/remoting/SessionContext.java...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java

5780 0

聊聊artemis的SlowConsumerReaperRunnable

-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java private...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java...-2.11.0/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol...-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/RemotingConnectionImpl.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/management/impl/ManagementServiceImpl.java

3602 0

聊聊artemis的SlowConsumerReaperRunnable

activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/SlowConsumerPolicy.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java private...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java...-2.11.0/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/management/impl/ManagementServiceImpl.java

4250 0

聊聊artemis的persistenceEnabled

/src/main/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImpl.java public class ConfigurationImpl...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java...-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/persistence/impl/journal/AbstractJournalStorageManager.java...-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageManager.java

7430 0

聊聊artemis的ExpiryScanner

5152 0

点击加载更多

Activemq Artemis安装

activemq artemis源码阅读，读取消息

聊聊artemis的ConnectionLoadBalancingPolicy

聊聊artemis的ConnectionLoadBalancingPolicy

聊聊artemis的QuorumManager

聊聊artemis的QuorumManager

聊聊artemis的confirmationWindowEnabled

聊聊artemis的confirmationWindowEnabled

聊聊artemis的ExpiryScanner

聊聊artemis的scheduledDeliveryTime

聊聊artemis的ActiveMQMetricsPlugin

聊聊artemis的persistenceEnabled

聊聊artemis的callFailoverTimeout

聊聊artemis的individualAcknowledge

聊聊artemis的scheduledDeliveryTime

聊聊artemis的SessionProducerCreditsMessage

聊聊artemis的SlowConsumerReaperRunnable

聊聊artemis的SlowConsumerReaperRunnable

聊聊artemis的persistenceEnabled

聊聊artemis的ExpiryScanner

相关资讯

热门标签

活动推荐

运营活动

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐