RabbitMQ -- Hello world-低调大师

RabbitMQ -- Hello world

2017-11-21 507

RabbitMQ使用AMQP通信协议（AMQP是一个提供统一消息服务的应用层标准协议，基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同开发语言等条件的限制。）。

安装

具体教程参考：http://www.rabbitmq.com/tutorials/tutorial-one-python.html

安装python的开发库

sudo pip install pika==0.9.8

安装rabbitmq服务

sudo apt-get install rabbitmq-server

启动rabbit服务

rabbitmq-server start

Hello World

发送

通过使用pika第三方库来连接，本例中为localhost本地连接。
通过queue_declare来创建一个消息队列
发送消息basic_publish
关闭链接close

#!/usr/bin/env python
# coding=utf-8

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

channel.basic_publish(exchange='', routing_key='hello', body='hello world!')

print 'Sent "hello world"'

connection.close()

接收

通过使用pika第三方库来连接，本例中为localhost本地连接。
通过queue_declare来创建一个消息队列（推荐，由于接收之前消息队列有可能并没有创建过）
指定消息队列和回调函数basic_consume
开始接受消息start_consuming

#!/usr/bin/env python
# coding=utf-8

import pika

def callback(ch, method, properties, body):
print 'receive %r'%body

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

channel.basic_consume(callback, queue='hello', no_ack=True)

channel.start_consuming()

本文转自cococo点点博客园博客，原文链接：http://www.cnblogs.com/coder2012/p/4338367.html，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/382721

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

云计算的基本原理和概念

云计算(Cloud Computing)是分布式处理(Distributed Computing)、并行处理 (Parallel Computing)和网格计算 (Grid Computing)的发展，或者说是这些计算机科学概念的商业实现。云计算的基本原理是，通过使计算分布在大量的分布式计算机上，而非本地计算机或远程服务器中，企业数据中心的运行将更与互联网相似。这使得企业能够将资源切换到需要的应用上，根据需求访问计算机和存储系统。这可是一种革命性的举措，打个比方，这就好比是从古老的单台发电机模式转向了电厂集中供电的模式。它意味着计算能力也可以作为一种商品进行流通，就像煤气、水电一样，取用方便，费用低廉。最大的不同在于，它是通过互联网进行传输的。云计算的蓝图已经呼之欲出：在未来，只需要一台笔记本或者一个手机，就可以通过网络服务来实现我们需要的一切，甚至包括超级计算这样的任务。从这个角度而言，最终用户才是云计算的真正拥有者。云计算的应用包含这样的一种思想，把力量联合起来，给其中的每一个成员使用。从最根本的意义来说，云计算就是利用互联网上的软件和数据的能力。对于云...

2017-11-22

605

【新闻快讯】11月13日美国时间，CNCF在旧金山正式对外发布Kubernetes软件一致性项目，并对外公布了包括睿云智合WiseCloud在内的全球32家率先通过认证测试的平台产品及Kubernetest分发版。这意味着，睿云智合的容器云平台产品在云原生领域受到国际权威机构认可。 CNCF和KubernetesConformanceProgram CNCF基金会由谷歌联合其他20家公司在2015年成立，现在是隶属于Linux基金会的非营利性组织。CNCF致力于开源云原生云项目的管理，旨在发展合作伙伴和开源社区，共同推动Kubernetes以及容器计算的发展，其成员包括Docker、Google、Intel、RedHat、IBM等国际知名科技公司。 KubernetesConformanceProgram是CNCF刚刚推出的Kubernetes分发版或云平台的一致性测试项目。通过测试的Kubernetes的认证平台产品可以为企业组织带来信心。意味着他们所使用的平台产品紧跟Kubernetes快速发展的步伐，同时也表明他们可以使用原生Kubernetes最新的通用功能。该计划还包括提供强...

2017-11-22

521

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。