1、jar包依赖 因为ActiveMQ5.12后的jar包自带spring,不方便与spring整合,可以使用ActiveMQ5.11.2的jar包 (ActiveMQ默认的端口号为:8161) <!-- spring对于jms支持的jar包 --> <dependency> <groupId>or ...
分类:
编程语言 时间:
2020-05-18 00:30:29
阅读次数:
63
1 ActiveMq JMS --> java Message 2 ActiveMQ的消息形式 有2种类型: 2.1 一种是点对点的,一个生产者和一个消费者一一对应 多个生产者 Queue 多个消费者 2.2 另一种是发布、订阅模式,一个生产者产生消息并进行发送后,可以由多个消费者进行接收 多个生产 ...
分类:
其他好文 时间:
2020-05-15 09:35:18
阅读次数:
52
前言消息中间件本质上就是一种很简单的数据结构——队列,但是一条队列肯定是当不成中间件的,你必须要考虑性能、容灾、可靠性等等因素。这也给我的写作提供了一些思路,我将从队列开始,给你演示一条队列是如何进化成一个靠谱的中间件的。消息中间件的实现有很多,有新贵Kafka、RocketMq,也有老牌劲旅RabbitMq和ActiveMq,不过我最后选择了Nsq来讲解,因为它极简、清爽,用起来舒服,讲起来也好
分类:
其他好文 时间:
2020-05-14 01:54:02
阅读次数:
76
后知后觉 细思极恐 这东西是很重要的啊 也是有很大提升空间的啊 redis缓存穿透 redis支持事务? 数据库表设计 数据库的隔离级别 http协议 Linux命令 消息队列 activemq ...
分类:
其他好文 时间:
2020-05-09 19:03:46
阅读次数:
68
结构图 依赖 package com.activemq.activemqdemo.p2p; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class JMSProducer { pub ...
分类:
其他好文 时间:
2020-05-08 18:35:33
阅读次数:
58
开启firewalld服务 #service firewalld start 查看firewall的状态 #firewall-cmd --state 打开8181端口 #firewall-cmd --zone=public --add-port=8161/tcp --permanent 打开6161 ...
分类:
其他好文 时间:
2020-05-06 18:18:07
阅读次数:
119
喜欢关注个人公众号:java乐园消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题。实现高性能,高可用,可伸缩和最终一致性架构;是大型分布式系统不可缺少的中间件。目前使用较多的消息队列有ActiveMQ、RabbitMQ、Kafka、RocketMQ、MetaMQ等。springboot提供了对JMS系统的支持;springboot很方便就可以集成这些消息中间件。对
分类:
编程语言 时间:
2020-05-02 09:27:36
阅读次数:
55
大纲 (一)、异步投递与确认签收回调 (二)、延迟投递与确认投递 (三)、消费重试机制 (四)、死信队列 (一)、异步投递与确认签收回调 1.What?Why? ActiveMQ 支持同步、异步两种发送的模式将消息发送到 broker,模式的选择对发送延时有巨大的影响。producer 能达到怎样的 ...
分类:
其他好文 时间:
2020-04-22 20:15:33
阅读次数:
92
这是ActiveMQ系列的最后一篇文章,主要是关于ActiveMQ集群,这里采用的方式是:Zookeeper+LevelDB+ActiveMQ。前面2篇博客地址如下:《从入门到精通的ActiveMQ(一)》、《从入门到精通的ActiveMQ(二)》。 利用Zookeeper实现ActiveMQ的高可 ...
分类:
其他好文 时间:
2020-04-22 19:53:10
阅读次数:
62
接上一篇《从入门到精通ActiveMQ(一)》,本篇主要讨论的话题是:消息的顺序消费、JMS Selectors、消息的同步/异步接受方式、Message、P2P/PubSub、持久化订阅、持久化消息到MySQL以及与Spring整合等知识。
分类:
其他好文 时间:
2020-04-22 09:25:21
阅读次数:
77