博客首页 → MQ

最新文章列表

activemq-topic

http://wangxinchun.iteye.com/blog/2146172 http://wangxinchun.iteye.com/blog/2146120 http://wangxinchun.iteye.com/blog/2145998 http://wangxinchun.iteye.com/blog/2145958 http://wangxinchun.iteye.com/blog ...
mqPublishersubscriber 
王新春 评论(0) 有748人浏览 2014-10-21 21:46

activemq-queue-Browser

其他相关： http://wangxinchun.iteye.com/blog/2145998 http://wangxinchun.iteye.com/blog/2145958 对于mq队列中的消息，有时候需要做监控或者问题跟踪要看看mq的数据，又要保证看后数据不会删除（比如：p2p 一旦consumer.receive 后mq不会发送其他consumer），mq提供了查看消息的功能。 最关键 ...
mqBrowser 
王新春 评论(0) 有1135人浏览 2014-10-21 19:08

activemq-queue-MessageListener

其他相关文章： http://wangxinchun.iteye.com/blog/2145998 http://wangxinchun.iteye.com/blog/2145958 activemq 中消费者获取消息有两种方式： 1、通过MessageConsumer.receive(TIMEOUT) 方法拉消息。 2、通过MessageConsumer.setMessageListener(n ...
mq推消息Messagelistener 
王新春 评论(0) 有686人浏览 2014-10-21 18:55

activemq-queue-selector

序上一篇：http://wangxinchun.iteye.com/blog/2145958 对于consumer而言，receive消息的时候，可以根据关键字筛选自己感兴趣的消息，当然可以定义不同的Destination 队列来承载这些消息，但是一般情况下，同一个队列可以保存一个主题的消息，减少队列的个数，为此新增了consumer的receive时的过滤功能。 case如下： 消息消费者： ...
mqactivemqsetStringProperty 
王新春 评论(0) 有1241人浏览 2014-10-21 16:00

activemq-queue

mq意为：消息队列。其中active mq 是apache的一个顶级开源项目，是jms的一个标准实现。 为什么要用mq? 1、通信，mq最本质的需求就是机器间的通信，即消息传递。 2、系统解耦，异步通信。mq消息的发送，不需要等待对方的返回，吞吐量高。 3、生产者和消费者的消息通信可靠性保证。一旦消息到了mq，消息的接收有保障。 mq消息传递的两种模式： 1、PTP：Point to Point ...
mqactivemq 
王新春 评论(0) 有1324人浏览 2014-10-21 14:53

ActiveMQ

消息机制 测试代码如下： @RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(locations={"classpath:spring/applicationContext.xml"})public class UserMqTest {    @Autow ...
jmsactivemqmq消息机制 
sky10198866 评论(0) 有768人浏览 2014-09-16 15:11

jafka学习之LogManager

       今天终于要讲到LogManager了，在讲LogManager之前，我们还是先来看下几个基本概念和jafka的存储结构。             下面是一个网友画的图:               从这个里面可以看到，消息队列跟路径下，每个topic的每个分区都是一个目录，里面是一个一个的文件，都以jafka结尾       那下来，我们看下类的实现。        ...
kafakjafakmq 
asialee 评论(1) 有3926人浏览 2014-08-29 23:20

jafka学习之Send

       Send这块是比较好理解的，它的作用就是produer或者consumer给broker发消息后的响应，先来看下类图。              从这个来看，最上层是一个Trasmission，里面有三个断言，来描述消息的发送情况。        Send接口封装写socket的channel，在AbstractSend里面封装具体的发送逻辑。        其他的就不详 ...
kafkajafkamq 
asialee 评论(0) 有1250人浏览 2014-08-26 06:44

jafka学习之RequestHandler

        RequestHandler从代码来看是比较简单的一个组件，在producer和consumer和broker打交道的过程中，均有一些请求数据，这个里面相当于自定义了一个简单的通讯协议，RequestKeys枚举就是具体的命令的映射类。        这个组件直接来看类图就很明白了，就不详细讲解了。  
kafkajafkamq 
asialee 评论(0) 有1098人浏览 2014-08-26 06:42

ZeroMQ3 for MySQL

mysql-zmq-plugin ZeroMQ / ØMQ for MySQL http://zeromq.org/event:zeromq-for-mysql Build # yum install zeromq3-devel # cmake . # make && make install
netkillermysqlzeromqgccmq 
netkiller.github.com 评论(0) 有917人浏览 2014-07-22 20:01

你可能并不需要消息队列

我是一个极简主义者，我不喜欢过早或者没必要地让软件复杂化。而往软件系统中添加组件就是严重增加复杂性的一种做法。我们来拿消息队列举个例子。 消息队列是一个能让你获得容错性，分布式，解耦等架构能力的系统。纸上谈兵的话，它看起来还不错。 或许消息列队在你的应用中有不少适用的场景。你可以看下这篇关于消息队列优点的文章，看看到底有哪些合适的场景。但可不要因为说"能解耦那太好了”就轻易使用它。我们 ...
MQ 
deepinmind 评论(3) 有2486人浏览 2014-07-07 23:58

kestrel 源码分析之四 Journal消息持久化类

上文我们看到PersistentQueue类的实现，它就代表每个消息队列在服务其中的实现，另外我们会看到每个PersistentQueue类包含一个Journal对象，该对象主要是负责队列的持久化操作。对于文件的读写我们用Java NIO来实现。下面我们来看一看主要的几个方法 def fillReadBehind(gotItem: QItem => Unit)(gotCheckpoint: ...
MQScalaKestrel消息中间件 
tjuxiaoqiang 评论(0) 有914人浏览 2014-07-06 00:19

kestrel 源码分析之三 PersistentQueue对应一个内存中的队列

PersistentQueue类主要用于在内存中维护一个队列，该类是Kestrel的核心类，是真正对于一个队列的维护。我们看到上文中QueueCollection中主要是调用下面的setup ...
ScalaKestrel消息中间件MQ 
tjuxiaoqiang 评论(0) 有1987人浏览 2014-07-05 23:14

kestrel 源码分析之一 综述

Kestrel 是Twitter内部使用的，用scala语言实现的一个消息队列中间件。而且核心代码只用了两千多行，能够支持事务，并且支持消息的持久化，Kestrel底层的通信是通过netty实现的，支持memcached协议。下面我们来分析一下kestrel的几个核心实现类，并讨论一下它是如何支持事务和消息的持久化。而Kestrel的消息的持久化是通过Java NIO实现。 下面是Kestrel的 ...
中间件scalamemcachedMQ 
tjuxiaoqiang 评论(0) 有1411人浏览 2014-07-05 17:22

kafka的单机部署(针对kafka_2.8.0-0.8.0.)版本

本部署使用的版本为kafka_2.8.0-0.8.0。 参考了http://blog.csdn.net/itleochen/article/details/17451455这篇博文； 并根据官网介绍http://kafka.apache.org/documentation.html#quickstart完成。 废话少说，直接上步骤 1.下载kafka_2.8.0-0.8.0.tar.gz htt ...
kafkamq部署 
sesame84 评论(0) 有2873人浏览 2014-06-10 17:00

RocketMQ3.1.1最新版

好吧吐槽归吐槽，但是淘宝的RocketMQ的作者还是灰常的给力，在了解到3.1.0依赖了淘宝内部包，我们普通的程序员不能编译的情况，赶紧的发出了更新去掉了淘宝的内部不开源的依赖，这样子。 好废话就到这里。 下载 https://codeload.github.com/alibaba/RocketMQ/zip/v3.1.1 解压 使用maven管理的依赖，电脑上配置好maven直接编译就OK啦 ...
JAVAMQ 
247687009 评论(0) 有1047人浏览 2014-06-02 00:56

ActiveMQ视频课程

本人打算利用业余时间录制一套ActiveMQ的视频，如果有对ActiveMQ感兴趣的童鞋，可以加入技术讨论群346336999，一起来学习研究； 视频课程提纲如下：     一、 基础篇   第一讲：ActiveMQ的介绍与安装（视频录制完成）   介绍什么是ActiveMQ，为什么需要它，在什么场景下使用它。   安装运行ActiveMQ，执行第一个hello word  ...
activeMQMQActiveMQ视频消息中间件ActiveMQ视频教程 
taike 评论(0) 有1839人浏览 2014-05-09 21:20

RabbitMQ学习一. 在windows下安装配置

1.下载并安装erlang，http://www.erlang.org/download.html，最新版是R15B01（5.9.1）。由于我机器是64位的Win7，所以找到otp_win64_R15B01.exe下载并安装。 2.配置环境变量 增加一个系统环境变量ERLANG_HOME配置为C:\Program Files\erl5.9.1 3.下载RabbitMQ，最新版是2.8.1，htt ...
JavaMQRabbitMQ 
zyjustin9 评论(1) 有8049人浏览 2014-03-18 09:58

MQ 初级阶段

它提供了强大、 安全、 稳定的消息传递主干， 在世界屡获殊荣。 它帮您搭建企业服务总线(ESB)的基础传输层。 IBM WebSphere MQ为SOA提供可靠的消息传递。 ...
MQ 
maomide_fannao 评论(0) 有337人浏览 2014-03-17 01:09

Sping整合ActiveMQ（三.简单Queue通信）

Sping整合ActiveMQ（一.简单Queue通信） 简单配置：只作JMSTemplate和Destination的配置，进行简单的消息传送 1.Pom文件： <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/ ...
JavaMQActiveMQSpring 
zyjustin9 评论(0) 有1542人浏览 2014-03-10 09:21

最近博客热门TAG

Java(141747) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54918) .net(54785) Web(54513) 工作(54116) Linux(50906) Oracle(49876) 应用服务器(43288) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37268) 数据结构(36423)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics