IT教程

RabbitMQ消息队列(九):Publisher的消息确认机制

songhua.gao 发布于 2017-03-17

       在前面的文章中提到了queue和consumer之间的消息确认机制:通过设置ack。那么Publisher能不到知道他post的Message有没有到达queue,甚至更近一步,是否被某个Consumer处理呢?毕竟对于一些非常重要的数据,可能Publisher需要...

阅读(14)评论(0)赞 (0)

RabbitMQ消息队列的小伙伴: ProtoBuf(Google Protocol Buffer)

2

darida 发布于 2017-03-17

     什么是ProtoBuf?      一种轻便高效的结构化数据存储格式,可以用于结构化数据串行化,或者说序列化。它很适合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列化结构数据格式。目前提供了 C++、Java、Pyt...

阅读(18)评论(0)赞 (1)

RabbitMQ消息队列(七):适用于云计算集群的远程调用(RPC)

1

songhua.gao 发布于 2017-03-17

在云计算环境中,很多时候需要用它其他机器的计算资源,我们有可能会在接收到Message进行处理时,会把一部分计算任务分配到其他节点来完成。那么,RabbitMQ如何使用RPC呢?在本篇文章中,我们将会通过其它节点求来斐波纳契完成示例。 1. 客户端接口 Client interf...

阅读(18)评论(0)赞 (1)

RabbitMQ消息队列(六):使用主题进行消息分发

1

邓龙华 发布于 2017-03-17

在上篇文章RabbitMQ消息队列(五):Routing 消息路由 中,我们实现了一个简单的日志系统。Consumer可以监听不同severity的log。但是,这也是它之所以叫做简单日志系统的原因,因为是仅仅能够通过severity设定。不支持更多的标准。 比如syslog u...

阅读(12)评论(0)赞 (0)

RabbitMQ消息队列(五):Routing 消息路由

3

刘莉莉 发布于 2017-03-17

上篇文章中,我们构建了一个简单的日志系统。接下来,我们将丰富它:能够使用不同的severity来监听不同等级的log。比如我们希望只有error的log才保存到磁盘上。 1. Bindings绑定 上篇文章中我们是这么做的绑定: channel.queue_bind(exchan...

阅读(18)评论(0)赞 (0)

RabbitMQ消息队列(三):任务分发机制

2

hanze 发布于 2017-03-17

在上篇文章中,我们解决了从发送端(Producer)向接收端(Consumer)发送“Hello World”的问题。在实际的应用场景中,这是远远不够的。从本篇文章开始,我们将结合更加实际的应用场景来讲解更多的高级用法。 当有Consumer需要大量的运算时,RabbitMQ S...

阅读(22)评论(0)赞 (0)

RabbitMQ消息队列(二):”Hello, World“

3

xiaoli.he 发布于 2017-03-17

本文将使用Python(pika 0.9.8)实现从Producer到Consumer传递数据”Hello, World“。 首先复习一下上篇所学:RabbitMQ实现了AMQP定义的消息队列。它实现的功能”非常简单“:从Producer接收数据然后传递到Consumer。它能保...

阅读(15)评论(0)赞 (0)

RabbitMQ消息队列(一): Detailed Introduction 详细介绍

1

邓龙华 发布于 2017-03-17

1. 历史 RabbitMQ是一个由erlang开发的AMQP(Advanced Message Queue )的开源实现。AMQP 的出现其实也是应了广大人民群众的需求,虽然在同步消息通讯的世界里有很多公开标准(如 COBAR的 IIOP ,或者是 SOAP 等),但是在异步消...

阅读(31)评论(0)赞 (0)

Dubbo多注册中心

Harries 发布于 2016-11-30

同时向2个注册中心,注册服务,这样,2个注册中心都拥有此服务 同样,不同的服务可以注册到不同的注册中心,比如:CRM有些服务是专门为国际站设计的,有些服务是专门为中文站设计的(官方文档举得例子) <?xml version=”1.0″ encodin...

阅读(209)评论(0)赞 (0)

WebService CXF学习(高级篇3):WS-Security

Harries 发布于 2016-10-12

这一节我们来探讨一下WebService安全问题,如果所有系统都运行在一个封闭的局域网内,那么可以不考虑网络攻击,拒绝服务,消息篡改,窃取等问题。但通常情况都接入互联网,那么我就得考虑信息安全问题,像前面那样直接将消息裸传,肯定不行。那么,我们就得给消息加密。CXF可以结合WSS...

阅读(262)评论(0)赞 (0)

WebService CXF学习(高级篇2):CXF+Spring+Hibernate

Harries 发布于 2016-10-12

前一节仅仅只讲了与spring整合,没有涉及到数据库,而且是直接将Java象传递到服务端。这一节我起到一个回顾前面章节的作用。用在客户端运用JABX将JAVA对象编组成XML文件,在客户端将XML解组成JAVA并存入数据库。下面我们就着手开发这个Demo: 服务端开发 第一步,编...

阅读(290)评论(0)赞 (0)

WebService CXF学习(高级篇1):整合Spring框架

Harries 发布于 2016-10-12

通过前面两节的讲解,相信你对CXF框架开始有一些认识了。在当今项目开发中,Spring框架基上都用到过,那么它怎么与CXF结合呢,这就是我们这一间要讲的内容。好了,闲话少说。 首先,在前面基础上再导入几个spring要用到的几个.jar包: spring-core.jar spr...

阅读(266)评论(0)赞 (0)

WebService CXF学习(进阶篇4):JAXB剖析

Harries 发布于 2016-10-12

前面几节我们讲解对象传递,但是通常情况下我们不直接传对象,因为直接传递对象安全性差,而且暴露了实体对象。所以我们选择传递XML文件,当然也可以传递JSON对象。这节我只针对传递XML,那么Java绑定成XML,服务端将XML解析成Java对象有什么工具可用吗,其实这样的工具多的是...

阅读(269)评论(0)赞 (0)

WebService CXF学习(进阶篇1):SOAP讲解

Harries 发布于 2016-10-12

 SOAP 是基于 XML 的简易协议,可使应用程序在 HTTP 之上进行信息交换。或者更简单地说:SOAP 是用于访问网络服务的协议。 您应当具备的基础知识 在继续学习之前,您需要对下面的知识有基本的了解: * XML * XML 命名空间 Why SOAP? 对于应用程序开发...

阅读(265)评论(0)赞 (0)