activemq笔记 Java

activemq笔记

activemq笔记 activeMq的安装.启动和停止 下载ActiveMq的tar安装包, 解压到响应目录下, 使用bin目录下的./activemq start启动, ./activemq stop停止 activemq和spring-boot整合 配置类 @EnableJms @Configuration public class ActiveMQ4Config { @...
阅读全文
ActiveMQ - 消息持久化 Java

ActiveMQ - 消息持久化

消息存储 ActiveMQ有点对点和发布订阅两种方式,这两种的消息存储还是有稍微一点区别。 点对点 队列的存储比较简单,就是先进先出(FIFO),只有当该消息已被消费和确认可以删除消息存储。如果没有被确认,其他消费者是不能获取消息的。 看看下面的例子: 生产者发送了10条消息: public static void main(String[] args) { ...
阅读全文
SpringBoot 实践系列-集成 RocketMQ Spring

SpringBoot 实践系列-集成 RocketMQ

RocketMQ 简介:Apache RocketMQ是一个分布式消息传递和流媒体平台,具有低延迟、高性能和可靠性、万亿级容量和灵活的可伸缩性。它提供了多种功能,具体参考: github.com/apache/rock… 。 官方指导手册快速开始中提到,RocketMQ 安装需要具体以下条件: 64bit OS, 推荐使用 Linux/Unix/Mac 64bit JDK 1.8...
阅读全文
ActiveMQ架构设计与最佳实践,需要一万字 软件架构

ActiveMQ架构设计与最佳实践,需要一万字

原创:小姐姐味道(微信公众号ID:xjjdog),欢迎分享,转载请保留出处。 xjjdog 以前写过很多关于消息队列的文章。今天介绍一下ActiveMQ。 其他的可以参考这些链接。 分布式消息系统,设计要点。画龙画虎难画骨 Kafka基础知识索引 360度测试:KAFKA会丢数据么?其高可用是否满足需求? 使用多线程增加kafka消费能力 开源一个ka...
阅读全文
rocketMQ(4.6.1)系列教程--namesrv 篇 编程技术

rocketMQ(4.6.1)系列教程--namesrv 篇

Namesrv Namesrv 架构设计 namesrv 作用 namesrv 充当服务注册中心的作用,向 producer、consumer 提供 broker 的信息,并将不可用的 broker 及时剔除。有点类似 eureka-server 的作用。与 eureka-server 不大一样的是, namesrv 集群之间信息不共享 ,也无法同步。broker 注册的时候,是同时...
阅读全文
综合对比 Kafka、RabbitMQ、RocketMQ、ActiveMQ 四个分布式消息队列 编程技术

综合对比 Kafka、RabbitMQ、RocketMQ、ActiveMQ 四个分布式消息队列

来源: http://t.cn/RVDWcfe 一、资料文档 Kafka:中。有kafka作者自己写的书,网上资料也有一些。rabbitmq:多。有一些不错的书,网上资料多。zeromq:少。没有专门写zeromq的书,网上的资料多是一些代码的实现和简单介绍。rocketmq:少。没有专门写rocketmq的书,网上的资料良莠不齐,官方文档很简洁,但是对技术细节没有过多的描述。activ...
阅读全文
RocketMq源码篇-NameSrv(三) 编程技术

RocketMq源码篇-NameSrv(三)

即上一篇,理论上先写这篇文章,rocketMq的注册中心没有使用zk来做,为了减少依赖,采用自己实现的NameSrv。NameSrv 来保存Broker、Topic的元数据。broker启动会向namesrv发送心跳,namesrv会定时检测 broker的可用性,并移除不可用的broker。采用netty长连接的定时任务来进行监听。对于生产者和消费者来说,它提供了broker的查询服务。 Na...
阅读全文
Loading...