一.kafka是什么 二.它与传统jms不同的地方. 三: 组成部分,主要是有哪些组件组成 四: Consumer和topic的关系. 1.消息队列消费者消费了重复的数据? 怎么去避免. 把kafka消费者的配置enable.auto.commit设为false，禁止kafka自动提交offset, ...
分类：
其他好文 时间：
2018-05-02 02:27:02
阅读次数：
161
1、将连接Mysql数据库的jar文件，放到ActiveMQ的lib目录下 2、修改ActiveMQ的conf目录下的active.xml文件，修改数据持久化的方式 2.1 修改原来的kshadb的持久化数据的方式 2.2 连接Mysql的配置(注意配置文件放置的位置) <!-- 用于持久化数据到M ...
分类：
数据库 时间：
2018-05-01 20:19:31
阅读次数：
232
1、ActiveMQ的本地事务 在一个JMS客户端，可以使用本地事务来组合消息的发送和接收。JMS Session接口提供了commit和rollback方法。事务提交意味着生产的所有消息被发送，消费的所有消息被确认；事务回滚意味着生产的所有消息被销毁，消费的所有消息被恢复并重新提交，除非它们已经过 ...
分类：
其他好文 时间：
2018-05-01 15:28:46
阅读次数：
194
ActiveMQ 支持两种截然不同的消息传送模型：PTP（即点对点模型）和Pub/Sub（即发布 /订阅模型），分别称作：PTP Domain 和Pub/Sub Domain。 一、PTP消息传送模型 1、PTP（使用Queue 即队列目标） 消息从一个生产者传送至一个消费者。在此传送模型中，目标是 ...
分类：
其他好文 时间：
2018-05-01 15:18:34
阅读次数：
153
消息的过期、消息的选择器和消息的优先级。 一、消息的过期 允许消息过期 。默认情况下，消息永不会过期。如果消息在特定周期内失去意义，那么可以设置过期时间。 有两种方法设置消息的过期时间，时间单位为毫秒： 1．使用消息生产者的setTimeToLive 方法为所有的消息设置过期时间。2．使用消息生产者 ...
分类：
其他好文 时间：
2018-05-01 00:37:41
阅读次数：
164
1.1 什么是ActiveMQ ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。 ...
分类：
其他好文 时间：
2018-04-29 11:45:25
阅读次数：
220
JAVA消息服务JMS规范及原理详解 一、简介 JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大 ...
分类：
编程语言 时间：
2018-04-29 01:15:44
阅读次数：
221
一、AMQP 概述 AMQP(Advanced Message Queuing Protocol)，高级消息队列协议。 简单回忆一下JMS的消息模型，可能会有助于理解AMQP的消息模型。在JMS中，有三个主要的参与者：消息的生产者、消息的消费者以及在生产者和消费者之间传递消息的通道（队列或主题）。在 ...
分类：
编程语言 时间：
2018-04-28 21:08:40
阅读次数：
241
一、ACK机制简介 ACK (Acknowledgement），即确认字符，在数据通信中，接收站发给发送站的一种传输类控制字符。表示发来的数据已确认接收无误。 JMS API中约定了Client端可以使用四种ACK_MODE,在javax.jms.Session接口中: AUTO_ACKNOWLED ...
分类：
其他好文 时间：
2018-04-23 11:12:41
阅读次数：
1526
### 消息中间件 ### **消息中间件** 1. 消息中间件的概述 2. 消息中间件的应用场景（查看大纲文档，了解消息队列的应用场景） * 异步处理 * 应用解耦 * 流量削峰 * 消息通信 ### JMS消息服务 ### **JMS的概述** 1. JMS消息服务的概述 2. JMS消息模型 ...
分类：
其他好文 时间：
2018-04-23 00:09:49
阅读次数：
164
