消息中间件
关注
分享
扫一扫
一点一点学习消息中间件
bestcxx
向外思考，向上生长，锲而不舍，金石可镂
展开
-
3.1、初识 Kafka 的逻辑结构和物理结构
文章目录·前言·Kafka集群 逻辑结构延伸出的几个问题Kafka 集群如果由多个 Kafka 服务组成，如何存储 topic？一个 topic 可以被多个consumer 消费吗？·Kafka 相关 物理结构broker 表示服务器partiton 表示一个文件夹partiton 由一个或多个 segment 组成延伸思考·参考文档·前言如果你有了解过 ActiveMQ 你会很直接的想到 t...原创 2019-12-12 23:41:49 · 587 阅读 · 0 评论 -
3、初识 Kafka 及安装和启动
文章目录·认识 Kafka官网基本介绍特性介绍四个主要的 API 接口·Kafka 的安装和启动官方文档下载安装包解压启动·认识 Kafka官网Apache Kafka基本介绍Kafka®用于构建实时数据管道(pipelines)和流应用程序。它具有横向可扩展性、容错性、极快的速度，并在数千家公司的生产中运行。(图片来自官网)特性介绍以下内容主要来自于官网一个拥有三个主要能...原创 2019-12-11 23:51:02 · 241 阅读 · 0 评论 -
2.9、ActiveMQ ——消息选择器 Selector
消息选择器可以让客户端直接消费自己想要的消息，而忽略自己不想要的消息，这样可以使用一个Queue或者Topic来完成不同场景下的工作。但是一定要注意Queue类型中，一旦一个Queue由不同的选择器条件消费者处理，其中一个的处理速率会影响另一个。 如果客户端没有指定条件选择，那么对于这个消费者来说生产者端的条件设置不会有实际的作用。原创 2019-07-14 11:06:37 · 574 阅读 · 0 评论 -
2.8、ActiveMQ 原生模式下 Topic 的持久化订阅
package com.bestcxx.stu.jms.del;import javax.jms.Connection;import javax.jms.DeliveryMode;import javax.jms.JMSException;import javax.jms.MessageConsumer;import javax.jms.MessageProducer;import ...原创 2019-07-12 09:10:33 · 447 阅读 · 0 评论 -
2.7、ActiveMQ 原生模式下 Queue 和 Topic 的 ACK 规律
文章目录前言特别声明感受原生ActiveMQ中的 ack创建 session 时的两个入参连接ActiveMQ的一个小窍门生产者的 ack 规律生产者 session 开启事务代码运行结果在ActiveMQ 提供的管理后台查看生产者 session 不开启事务代码运行结果在ActiveMQ 提供的管理后台查看消费者的 ack 规律消费者 session 开启事务代码在ActiveMQ 提供的管理后...原创 2019-07-10 08:31:56 · 418 阅读 · 0 评论 -
2.6、ActiveMQ 的消息确认机制-ACK
文章目录前言ACK (Acknowledgement) 确认字符JMS 定义了四种 ACK 类型ActiveMQ 比 ACK 多一种 ACK 类型JmsTemplate 不支持 CLIENT_ACKNOWLEDGE 模式?前言体能状态先于精神状态,习惯先于决心,聚焦先于喜好ACK (Acknowledgement) 确认字符在消息中间件中进行消息的发送和接收是一个非常常见的场景,那么...原创 2019-05-25 21:48:11 · 1283 阅读 · 0 评论 -
2.5、 使用监听器容器自动获取 ActiveMQ中的消息
文章目录前言往期回顾化繁为简的表述监听器容器代码自定义监听器Bean 集合：各位看注释xml 配置文件测试类前言体能状态先于精神状态，习惯先于决心，聚焦先于喜好。往期回顾ActiveMQ 的系列文章已经搁置很久没有继续了，https://blog.csdn.net/bestcxx/column/info/23061之前已经测试了queue类型和topic类型的消息的发送和接收，但是...原创 2019-05-11 22:46:36 · 531 阅读 · 0 评论 -
2.3、使用 JmsTemplate 向 ActiveMQ 获取 Queue 类型消息
文章目录前言为什么不将发送和接收写到同一篇文章中？发送和接收的联系和区别-本质上是对某一个 ActiveMQQueue 的操作读取 Queue 中的消息类的声明方法一:receive方法二:使用 receiveAndConvert 处理 Java 对象消息测试方法验证 Queue 消息的三个特性参考资料前言在上一篇文章中(https://blog.csdn.net/bestcxx/artic...原创 2018-10-20 18:17:17 · 1214 阅读 · 0 评论 -
2.4、使用 JmsTemplate 向 ActiveMQ 发送和获取 Topic 类型消息
文章目录前言回顾 Queue 类型消息的发送和请求过程ActiveMQTopic 和 JmsTemplateTopic 类型消息的特性前言本篇文章的内容会非常之少，因为 Topic 类型的数据的发送和接收本身在代码上并没有太大的差别，唯一的差别在于声明 JmsTemplate 时注入的是 ActiveMQQueue 还是 ActiveMQTopic，所以本文仅就这部分差别进行阐述，并且强调一...原创 2018-10-20 18:32:25 · 2409 阅读 · 0 评论 -
2.2、使用 JmsTemplate 向 ActiveMQ 发送 Queue 类型消息
文章目录前言发送类的编写创建 类 JmsTemplateQueueProduct方法一 send方法二 convertAndSend使用 convertAndSend 发送 Java 对象测试代码先看下 http://localhost:8161/admin/queues.jsp参考资料[1].《Spring 实战 第4版》[2].https://blog.csdn.net/winter_che...原创 2018-10-20 12:45:07 · 3910 阅读 · 0 评论 -
2.1、ActiveMQ + JmsTemplate 的基本概念
文章目录前言Maven 依赖认识 ActiveMQConnectionFactory 和 PooledConnectionFactory认识 ActiveMQQueue 和 ActiveMQTopic队列 Bean - ActiveMQQueue 的声明主题 Bean - ActiveMQTopic 的声明认识 JmsTemplate为一个主题创建 JmsTemplate为一个队列创建 JmsTe...原创 2018-10-13 11:58:57 · 1451 阅读 · 0 评论 -
2、初识 ActiveMQ 及 安装和启动
文章目录ActiveMQ 有众多版本ActiveMQ 支持多个平台解压即安装认识默认的两个端口启动 ActiveMQ访问 ActiveMQ 管理页面默认的访问者 admin 和 user 的配置ActiveMQ 有众多版本访问官方网址可以得到所有版本的下载链接http://activemq.apache.org/download-archives.htmlActiveMQ 支持多个平台...原创 2018-09-24 23:55:43 · 552 阅读 · 0 评论 -
1、初识消息中间件
引题消息中间件的定义消息中间件出现的背景消息中间件解决了什么问题？消息中间件的标准JMS 和 AMQP常见的消息中间件参考链接引题 消息中间件是什么，是一种标准，还是一种具体的工具？为什么叫消息中间件,带着这些疑问，笔者开始走进消息中间件的世界。消息中间件的定义 通俗来说，就是可以对数据信息进行异步传递的中介。从编程的角度来说...原创 2018-07-29 01:34:02 · 904 阅读 · 0 评论