本月博客排行
-
第1名
龙儿筝 -
第2名
lerf -
第3名
fantaxy025025 - johnsmith9th
- xiangjie88
- zysnba
年度博客排行
-
第1名
青否云后端云 -
第2名
宏天软件 -
第3名
gashero - wy_19921005
- vipbooks
- benladeng5225
- e_e
- wallimn
- javashop
- ranbuijj
- fantaxy025025
- jickcai
- gengyun12
- zw7534313
- qepwqnp
- 解宜然
- ssydxa219
- zysnba
- sam123456gz
- sichunli_030
- arpenker
- tanling8334
- gaojingsong
- kaizi1992
- xpenxpen
- 龙儿筝
- jh108020
- wiseboyloves
- ganxueyun
- xyuma
- xiangjie88
- wangchen.ily
- Jameslyy
- luxurioust
- lemonhandsome
- mengjichen
- jbosscn
- zxq_2017
- lzyfn123
- nychen2000
- forestqqqq
- wjianwei666
- ajinn
- zhanjia
- siemens800
- Xeden
- hanbaohong
- java-007
- 喧嚣求静
- mwhgJava
最新文章列表
[转载]PHP-AMQP实践应用
原文地址:PHP-AMQP实践应用作者:dream
优点:可以解决服务器处理的并发问题。高级消息队列协议(AMQP)是一个异步消息传递所使用的应用层协议规范。作为线路层协议,而不是API(例如JMS),AMQP 客户端能够无视消息的来源任意发送和接受信息。现在,已经有相当一部分不同平台的服务器和客户端可以投入使用。(一)基本概念
RabbitMQ 是流行的开源消息队列系统,用erlang语 ...
AMQP协议(经典)
当前各种应用大量使用异步消息模型,并随之产生众多消息中间件产品及协议,标准的不一致使应用与中间件之间的耦合限制产品的选择,并增加维护成本。AMQP是一个提供统一消息服务的应用层标准协议,基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同开发语言等条件的限制。
当然这种降低耦合的机制是基于与上层产品,语言无关的协议。AMQP协议是一种二进制协议,提供客户端应用与消息 ...
rabbitmq初探
AMQP协议
AMQP 有四个非常重要的概念:虚拟机(virtual host),交换机(exchange),队列(queue)和绑定(binding)。
虚拟机: 通常是应用的外在边界,我们可以为不同的虚拟机分配访问权限。虚拟机可持有多个交换机、队列和绑定。
交换机: 从连接通道(Channel)接收消息,并按照特定的路由规则发送给队列。
队列: 消息最终的存储容器,直到消费客户端( ...
springmvc + amqp + batch + rabbitmq
最近在学习spring amqp + spring batch + rabbitmq 的一些东西,简单的就是实现向mq中写入日志,使用spring batch批量处理,当然了,在实际生产中这个例子不一定合理,基于学习需要,暂且不秋考虑!!!
因为日志是一直不断记录的,当然不一次就写完,这里使用的是quartz,定时去mq中取数据的方式,spring amqp可以使用listener的方式 ...
RabbitMQ源码解析前奏--AMQP协议
AMQP即高级消息队列协议,接下来从三个方面来浅析该协议。一、协议 AMQP协议分层类似于OSI或TCP/IP协议分层。从图中可以看出分三层:
图1 AMQP协议分层图1、Model Layer 规范服务器端Broker的行为。2、Session Layer 定义客户端与服务器端Broker的Context。3、Transport Layer 传输二进制数据流。
...
spring amqp rabbitmq 学习(三) MessageConverter
spring amqp默认使用的是SimpleMessageConverter,使用的是UTF-8编码,官网原文是这样说的
It handles text-based content, serialized Java objects,and simple byte arrays.
当contentType是以text开头的时候,它会使用UTF-8编码将消息转换为String类型
当conte ...
spring amqp rabbitmq 学习(二) 接收消息
上一篇贴出了发送信息的配置,这一篇看看接受信息的配置
applicationContext-receive.xml配置如下:
上篇中将消息发送到了名称为simpleSend的队列上,所以这里amqpTemplate中的queue定义为simpleSend,另外不管是发送消息还是接受消息都需要声明队列<rabbit:queue name="simpleSend" /& ...
spring amqp rabbitmq 学习(一) 发送消息
关于amqp的一些概念请参照http://wubin850219.iteye.com/category/152656
使用到的工具 Myeclipse、Maven
maven配置如下:
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2 ...
Distributed Semaphores with RabbitMQ
翻译自(http://www.rabbitmq.com/blog/2014/02/19/distributed-semaphores-with-rabbitmq/)
在这篇博客里面,我们将定位“在一个分布式系统里面,如何实现对特殊资源的访问控制”的问题,解决该问题的方案在计算机界广为人知,那就是被成为信号量的东东。“信号量”是在1965年Dijkstra的“Cooperating Sequenti ...
client与broker断开后重新连接
qpid的client端有可能会由于某种原因与broker断开连接,如网络连接断开,broker的节点删除等等。
公司的项目需要用java编写一个Service,用来监听broker的消息。要求如果与broker断开后,必须尝试重新连接。
那应该完成以下一个步骤:
(1)检测到client与服务器断开。
(2)如果断开,尝试重新连接。
对于(1),javax.jms.Connection对象可以 ...
QPID与AMQP简介
AMQP简介
AMQP(消息队列协议,Advanced Message Queuing Protocol)是一种消息协议 ,等同于JMS,但是JMS只是java平台的方案,AMQP是一个跨语言的协议。
AMQP 不分语言平台,最初来自JPMorgon,因为业务需要而滋生,很快从金融界推广到整个计算机界流行起来。
AMQP 目前还是一个草案,最新版本是:0.10
Publishe ...
AMQP & Nova
OpenStack中的Nova各个服务之间以松耦合的方式使用AMQP进行通信(RPC)。使用AMQP的发布/订阅模式来进行RPC有如下优势:
1)
客户端及服务端之间解耦:客户端不需要知道有哪些服务端以及服务端的地址;
2)
客户端与服务端之间完全的同步性:客户端的RPC不需要服务端正好在运行;
3)
远程调用的随机均衡:如果有 ...
Introduction to the AMQP 0-9-1 Model
About This Guide
This guide explains the AMQP 0-9-1 model used by RabbitMQ. The original version was written and kindly contributed by Michael Klishin and edited by Chris Duncan.
H ...