# 基于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消费模型 些基本概念 • Broker • Connection • Channel • Virtual host • Exchange • Queue • Binding ### 4. MaxQ - AMQP实现架构  - 按照协议spec自动生成frame

Concurrency settings • Task result backend settings • Database backend settings • AMQP backend settings • Cache backend settings • Tokyo Tyrant backend settings • Redis Periodic Task Server - celery.bin.celerybeat Celery Initialize - celery.bin.celeryinit caqmadm: AMQP API Command-line Shell - celery.bin.camqadm Internals Celery Deprecation Timeline Internals: 6 \[2009-04-28 2:13 P.M CET]| |0.0.1.0 \[2009-04-24 11:28 A.M CET]| |interesting Links| |celery.| |AMQP| |RabbitMQ| ## I ndices and tables • Index • Module Index • Search Page ## Getting Started Release:

ActiveMQ Artemis. ## 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 ActiveMQ implementations on the server so you can use respective clients for these protocols: 1. Stomp 2. OpenWire 3. AMQP JMS semantics are implemented by a JMS facade layer on the client side. The Apache ActiveMQ Artemis

6. AMQP ..... 15 6.1. Examples ..... 15 6.2. Message Conversions ..... 15 6.3. Intercepting and changing messages ..... 16 6.4. AMQP and security ..... 16 6.5. AMQP and destinations destinations ..... 16 6.6. AMQP and Multicast Addresses (Topics) ..... 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. Limitations

Architecture 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 ActiveMQ

Architecture 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 ActiveMQ

simplest applications you can make: from celery import Celery app = Celery('hello', broker='amqp://guest@localhost/') @app.task def hello(): return 'hello world' ## • Highly Available prefork • (multiprocessing), • Eventlet, gevent • solo (single threaded) ## • Result Stores • AMQP, Redis • Memcached, • SQLAlchemy, Django ORM • Apache Cassandra, • Elasticsearch ## • Serialization requires the development versions of kombu [https://pypi.python.org/pypi/kombu/], amqp [https://pypi.python.org/pypi/amqp/], billiard [https://pypi.python.org/pypi/billiard/], and vine [https://pypi.python

simplest applications you can make: from celery import Celery app = Celery('hello', broker='amqp://guest@localhost/') @app.task def hello(): return 'hello world' ## • Highly Available prefork • (multiprocessing), • Eventlet, gevent • solo (single threaded) ## • Result Stores • AMQP, Redis • Memcached, • SQLAlchemy, Django ORM • Apache Cassandra, • Elasticsearch ## • Serialization requires the development versions of kombu [https://pypi.python.org/pypi/kombu/], amqp [https://pypi.python.org/pypi/amqp/], billiard [https://pypi.python.org/pypi/billiard/], and vine [https://pypi.python

simplest applications you can make: from celery import Celery app = Celery('hello', broker='amqp://guest@localhost/') @app.task def hello(): return 'hello world' ## • Highly Available prefork • (multiprocessing), • Eventlet, gevent • solo (single threaded) ## • Result Stores • AMQP, Redis • Memcached, • SQLAlchemy, Django ORM • Apache Cassandra, • Elasticsearch ## • Serialization requires the development versions of kombu [https://pypi.python.org/pypi/kombu/], amqp [https://pypi.python.org/pypi/amqp/], billiard [https://pypi.python.org/pypi/billiard/], and vine [https://pypi.python

simplest applications you can make: from celery import Celery app = Celery('hello', broker='amqp://guest@localhost/') @app.task def hello(): return 'hello world' ## • Highly Available prefork (multiprocessing), • Eventlet, gevent • threads/single threaded ## • Result Stores o AMQP, Redis o memcached, MongoDB ○ SQLAlchemy, Django ORM ○ Apache Cassandra ## • Serialization version ## With pip The Celery development version also requires the development versions of kombu, amqp and billiard. You can install the latest snapshot of these using the following pip commands: $ pip