基于amqp实现的golang消息队列MaxQ# 基于amqp实现的golang消息队列 MaxQ 2017-07-01 张培培 饿了么-基础框架组 ## 内容 1. 队列 2. IPC消息队列 3. AMQP协议 4. MaxQ架构模型 5. MaxQ相关特性 6. 使用场景和案例 ### 1. 队列  跟消息队列相比,有哪些共性? ### 3. AMQP(Advanced Message Queuing Protocol)协议 • 七层应用协议 • 定义Broker实现 • 生产消费轻耦合 • 生产消费状态记录 • Push/Pull消费模型 • 消费者流控 • 事务支持  - 按照协议spec自动生成frame encode/decode • Exchange接口化 • Queue接口化——MaxQ集群0 码力 | 22 页 | 1.45 MB | 2 年前3
SOFAMesh的通用协议扩展## SOFA MESH 的通用协议扩展 邵俊雄(熊啸) 2018.08.25 ## AGENDA • SOFA MESH 介绍 • SERVICE MESH 落地的问题 • SOFA MESH 的通用落地方案 • DNS 服务寻址方案 • X-PROTOCOL 通用协议 · 问答 ## SOFA MESH • 从 ISTIO 克隆并保持同步更新 - 使用 SOFA-MOSN 代替 Controller Pattern 通过 CRD 扩展新的能力 ## MESH 落地碰到的问题 • 客户端服务发现与负载均衡无法与 ISTIO 一起工作 • ENVOY 不支持微服务使用的通信协议 - RPC 服务使用的接口,方法,参数语义无法匹配 ISTIO 的路由模型 • 一个应用上部署了多个 RPC 服务,每个服务有自己的版本 ## I STIO 控制平面路由的抽象模型 VirtualHost 服务的路由规则 XDS 适配 • 开发 DUBBO 协议支持 ## SOFA MESH 的统一解决方案 • 采用 Kubernetes Native 方式落地微服务应用 • 使用 INTERFACE 作为 DNS 来寻址服务 • 开发一个通用协议处理框架 - 避免为不同的微服务框架修改 PILOT 代码 • 通过插件的方式按需支持新的协议 • 对应用代码无侵入性 • 为微服务框架提供轻量化客户端0 码力 | 28 页 | 4.73 MB | 1 年前3
Greenplum分布式事务和两阶段提交协议## Greenplum分布式事务 和两阶段提交协议 钉钉直播 | 10月21日 20:00 - 21:00 #### Greenplum中文社区 https://cn.greenplum.org 博文·资料·文档·项目 ## 全新的问答论坛 #### https://cn.greenplum.org/askgp ## GREENPLUM DATABASE $ ^{®} $  ..... 16 6.7. AMQP and Coordinations - Handling Transactions ..... 17 6.8. AMQP scheduling message delivery ..... 17 Expiry transfer ..... 17 6.10. Filtering on Message Annotations ..... 18 6.11. Configuring AMQP Idle Timeout ..... 18 6.12. Web Sockets ..... 19 7. STOMP ..... 20 7.1. Limitations0 码力 | 537 页 | 11.11 MB | 1 年前3
Apache ActiveMQ Artemis 2.1.0 User ManualArchitecture 1.6 Using the Server 1.7 Address Model 1.8 Using JMS 1.9 Using Core 1.10 Using AMQP 1.11 Mapping JMS Concepts to the Core API 1.12 The Client Classpath 1.13 Examples 1.14 Routing RESTful interface. ## AMQP AMQP is a specification for interoperable messaging. It also defines a wire format, so any AMQP client can work with any messaging system that supports AMQP. AMQP clients are available available in many different programming languages. Apache ActiveMQ Artemis implements the AMQP 1.0 specification. Any client that supports the 1.0 specification will be able to interact with Apache ActiveMQ0 码力 | 407 页 | 1.93 MB | 2 年前3
共 1000 条
- 1
- 2
- 3
- 4
- 5
- 6
- 100
相关搜索词
MaxQAMQP协议消息队列GolangZookeeperSOFAMeshService MeshX-PROTOCOLMultiplexingSidecar代理事务分布式事务两阶段提交协议Write Ahead Logging (WAL)GreenplumIstio七层协议扩展服务发现流量管理模型xDS协议Rust HTTP协议栈终端通信场景Ylong HTTP客户端库异步IO状态机IBC协议跨链互操作Solana合约链Rust语言IBC协议实现CeleryRabbitMQAMQPTaskCelerydApache ActiveMQ ArtemisprotocolsOpenWireJMSMessage Oriented MiddlewareMQTTSTOMP













