软件简介

StreamNative 和中国移动开源了 “AoP”(AMQP on Pulsar)。

AoP 将 AMQP 协议处理插件引入 Pulsar broker。这样一来,Apache Pulsar 就支持原生 AMQP 协议。

与 KoP 相似,AoP 是一种可插拔的协议处理插件。

将 AoP 协议处理插件添加到现有 Pulsar 集群后,用户不用修改代码就可以将现有的 RabbitMQ 应用程序和服务迁移到 Pulsar。

这样,RabbitMQ 应用程序就可以使用 Pulsar 的强大功能,例如利用 Apache BookKeeper 保存事件流和 Pulsar 分层存储特性。

展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (0)

加载中
更多评论
01/21 11:21

AoP (AMQP on Pulsar) 2.7.0.4 更新

StreamNative 和中国移动开源了 “AoP”(AMQP on Pulsar)。AoP 将 AMQP 协议处理插件引入 Pulsar broker。这样一来,Apache Pulsar 就支持原生 AMQP 协议。 与 KoP(https://hub.streamnative.io/protocol-handlers/kop/0.2.0)相似,AoP 是一种可插拔的协议处理插件。 将 AoP 协议处理插件添加到现有 Pulsar 集群后,用户不用修改代码就可以将现有的 RabbitMQ 应用程序和服务迁移到 Pulsar。 这样,RabbitMQ 应用程序就可以使用 ...

2
3
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
2020/09/09 18:30

AMQP on Pulsar 的设计与应用一览

本期 TGIP-CN 直播,我们邀请到了来自中国移动云能力中心的张浩,他在 AMQP on Pulsar 项目中参与了很多,也一起协助推进了项目的开发与更新。 接下来的内容主要基于此次直播中关于 AoP 的一些介绍和细节干货。 相关背景 首先一个很重要的问题,就是我们移动内部为什么要自己做 AMQP 消息队列?答案很明显。 一是为了满足内部组件的需求,中国移动是 OpenStack 的重度使用用户,而 OpenStack 中默认使用 RabbitMQ 作为 RPC 通信...

0
0
2020/09/09 18:00

AMQP on Pulsar 的设计与应用一览

本期 TGIP-CN 直播,我们邀请到了来自中国移动云能力中心的张浩,他在 AMQP on Pulsar 项目中参与了很多,也一起协助推进了项目的开发与更新。 接下来的内容主要基于此次直播中关于 AoP 的一些介绍和细节干货。 相关背景 首先一个很重要的问题,就是我们移动内部为什么要自己做 AMQP 消息队列?答案很明显。 一是为了满足内部组件的需求,中国移动是 OpenStack 的重度使用用户,而 OpenStack 中默认使用 RabbitMQ 作为 RPC 通信...

1
0
2020/06/17 18:00

StreamNative 和中国移动宣布开源 AoP: Apache Pulsar 支持原生 AMQP 协议

我们很高兴地宣布 StreamNative 和中国移动开源了 “AoP”(AMQP on Pulsar)。AoP 将 AMQP 协议处理插件引入 Pulsar broker。这样一来,Apache Pulsar 就支持原生 AMQP 协议。 与 KoP(https://hub.streamnative.io/protocol-handlers/kop/0.2.0)相似,AoP 是一种可插拔的协议处理插件。 将 AoP 协议处理插件添加到现有 Pulsar 集群后,用户不用修改代码就可以将现有的 RabbitMQ 应用程序和服务迁移到 Pulsar。 这样,RabbitMQ ...

1
0
2020/06/17 18:30

StreamNative 和中国移动宣布开源 AoP: Apache Pulsar 支持原生 AMQP 协议

我们很高兴地宣布 StreamNative 和中国移动开源了 “AoP”(AMQP on Pulsar)。AoP 将 AMQP 协议处理插件引入 Pulsar broker。这样一来,Apache Pulsar 就支持原生 AMQP 协议。 与 KoP(https://hub.streamnative.io/protocol-handlers/kop/0.2.0)相似,AoP 是一种可插拔的协议处理插件。 将 AoP 协议处理插件添加到现有 Pulsar 集群后,用户不用修改代码就可以将现有的 RabbitMQ 应用程序和服务迁移到 Pulsar。 这样,RabbitMQ ...

0
0
发表了博客
2018/04/03 13:29

AMQP

1. 什么是AMQP? 在异步通讯中,消息不会立刻到达接收方,而是被存放到一个容器中,当满足一定的条件之后,消息会被容器发送给接收方,这个容器即消息队列,而完成这个功能需要双方和容器以及其中的各个组件遵守统一的约定和规则,AMQP就是这样的一种协议,消息发送与接受的双方遵守这个协议可以实现异步通讯。这个协议约定了消息的格式和工作方式。 2. 为什么使用AMQP 为什么使用AMQP或者AMQP解决了什么问题? 在分布式的...

0
0
2016/12/09 16:30

AMQP

安装Erlang 安装RabbitMQ 新建Spring Boot项目,依赖为AMQP 发送信息及目的地定义 package com.amqp; import org.springframework.amqp.core.Queue; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot....

0
0
发表于云计算专区
2015/12/08 19:40

amqp协议

AMQP协议 博客分类: 其它 网络协议Exchange应用服务器网络应用算法 当前各种应用大量使用异步消息模型,并随之产生众多消息中间件产品及协议,标准的不一致使应用与中间件之间的耦合限制产品的选择,并增加维护成本。AMQP是一个提供统一消息服务的应用层标准协议,基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同开发语言等条件的限制。 当然这种降低耦合的机制是基于与上层产品,语言无关的协议...

0
5
2015/02/25 14:41

AMQP协议

当前各种应用大量使用异步消息模型,并随之产生众多消息中间件产品及协议,标准的不一致使应用与中间件之间的耦合限制产品的选择,并增加维护成本。AMQP是一个提供统一消息服务的应用层标准协议,基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同开发语言等条件的限制。 当然这种降低耦合的机制是基于与上层产品,语言无关的协议。AMQP协议是一种二进制协议,提供客户端应用与消息中间件之间异步、...

0
0
发表了博客
2019/05/17 12:11

AMQP协议

AMQP介绍 AMQP是什么 AMQP(高级消息队列协议)是一个网络协议。rabbitmq是基于AMQP标准开发的。 AMQP模型简介 AMQP的工作过程如下图:消息(message)被发布者(publisher)发送给交换机(exchange),交换机常常被比喻成邮局或者邮箱。然后交换机将收到的消息根据路由规则分发给绑定的队列(queue)。最后AMQP代理会将消息投递给订阅了此队列的消费者,或者消费者按照需求自行获取。 交换机和交换机类型 交换机是用来发送消息...

0
0
发表了博客
2019/05/13 19:53

AMQP协议

定义 AMQP:Advanced Message Queuing Protocol,高级消息协议。 RabbitMQ就是AMQP协议的erlang实现,AMQP的模型架构和RabbitMQ的模型架构是一样的,生产者将消息送给交换器,交换器和队列绑定。当生产者发送消息时所携带的RoutingKey与绑定时的BindingKey相匹配时,消息即被存入相应的队列之中,消费者可以订阅相应的队列来获取消息。 AMQP协议本身包括三层:   ❤ Module Layer:位于协议的最高层,主要定义了一些供客户端调...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
0 评论
6 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部