AoP (AMQP on Pulsar)

Apache Pulsar 支持原生 AMQP 协议
授权协议 Apache
开发语言 Java
所属分类 服务器软件、 JMS/消息中间件
软件类型 开源软件
地区 国产
投 递 者 习胤运
操作系统 跨平台
开源组织
适用人群 未知
 软件概览

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

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

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

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

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

  • Apache Pulsar,RabbitMQ,RocketMQ 功能对比 功能为度可以分为多个子维度,例如:优先级队列,延迟队列(定时消息),死信队列,事务消息,非持久化主题、消费重试,消息回溯,消息追踪,消息保留、消息生存时间、多租户,多协议支持,跨语言支持,流量控制,消息顺序性,安全机制(身份认证,权限控制),消息幂等性,多中心等等。 RabbitMQ(3.8.4)、RocketMQ(4.7.

  • 本文由 简悦 SimpRead 转码, 原文地址 mp.weixin.qq.com 导语 新年快乐!大年初三,Apahe Pulsar 社区给您拜年啦!特此奉上年货礼包一份。 Hi 小伙伴们,感谢你加入 Apache Pulsar 社区——一个快速成长的消息流技术社区。作为 「云原生时代消息中间件之王」的 Apache Pulsar ,是 Apache 软件基金会顶级项目,集消息、存储、轻量化函

 相关资料
  • <?php use Yurun\Util\YurunHttp; use Yurun\Util\HttpRequest; // 设置默认请求处理器为 Swoole YurunHttp::setDefaultHandler(\Yurun\Util\YurunHttp\Handler\Swoole::class); // Swoole 处理器必须在协程中调用 go('test'); functio

  • WorkerMan在接口上支持各种协议,只要符合ConnectionInterface接口即可(参见定制通讯协议章节)。 为了方便开发者,WorkerMan提供了HTTP协议、WebSocket协议以及非常简单的Text文本协议、可用于二进制传输的frame协议。开发者可以直接使用这些协议,不必再二次开发。如果这些协议都不满足需要,开发者可以参照定制协议章节实现自己的协议。 开发者也可以直接基于t

  • 2)React VR构建在React原生框架上。这是否意味着React VR可以用来实现我的目标(AR导航)? 3)有人能分享他们在React Native和AR中的经验吗?然后我就有了一个清晰的开始方法。

  • 类型可变性,具体地,协变和逆变,定义了一个类型变化为另一个类型的两种情况。如果可能,你应该让泛型接口和委托支持泛型的协变和逆变。这样做可以让你的 APIs 能安全地不同方式使用。如果你不能将一个类型替换为另一个,那么就是不可变。 类型可变性是很多开发者遇到的却又不真正理解的很多问题之一。协变和逆变是类型替换的两种不同形式。如果你用声明类型的子类返回那么就是协变的。如果你用声明类型的基类作为参数传入

  • 我们正在编写一个应用程序,它必须使用HTTPS与几个服务器通信。它需要与AWS通信(使用AWS库),还需要与我们使用TLS1.2的一些内部服务通信。 我首先将HttpClient更改为使用TLS1.2SSLContext: 并且(通过spring)将这个SchemeRegistry注入到DefaultHttpClient对象中,但是这样做会从AWS得到错误,因此我假设(我可能错了)AWS不支持TL

  • 下面的代码是TCP客户端的套接字编程示例。 但当我运行该操作时,connect()作为协议不支持的地址族返回。