zoukankan      html  css  js  c++  java
  • rabbitmq python

    import pika

    connection = pika.BlockingConnection(pika.ConnectionParameters(
    'localhost',9672))
    channel = connection.channel()
    channel.queue_declare(queue='hello')
    channel.basic_publish(exchange='',
    routing_key='hello',
    body='Hello World!')
    print " [x] Sent 'Hello World!'"
    connection.close()

    $ sudo rabbitmqctl list_queues

    channel.queue_declare(queue='hello')
    def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)
    channel.basic_consume(callback,
    queue='hello',
    no_ack=True)
    print ' [*] Waiting for messages. To exit press CTRL+C'
    channel.start_consuming()

    send.py:

    !/usr/bin/env python

    import pika

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

    channel.queue_declare(queue='hello')

    channel.basic_publish(exchange='',
    routing_key='hello',
    body='Hello World!')
    print " [x] Sent 'Hello World!'"
    connection.close()

    receive.py:

    !/usr/bin/env python

    import pika

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

    channel.queue_declare(queue='hello')

    print ' [*] Waiting for messages. To exit press CTRL+C'

    def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)

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

    channel.start_consuming()

  • 相关阅读:
    oracle对中文的排序
    sql语句分页
    一些简单的PGSQL 操作
    angularJSngSelect
    angular+ionic返回上一页并刷新
    C语言博客作业02循环结构
    c语言第一次作业顺序、分支结构
    C语言博客作业03函数
    C语言博客作业02循环结构
    第零次作业
  • 原文地址:https://www.cnblogs.com/mayidudu/p/6185550.html
Copyright © 2011-2022 走看看