RabbitMQ、Rdis

# rpm -ivh erlang-18.3-1.el6.x86_64.rpm 

rpm -ivh rabbitmq-server-3.6.2-1.noarch.rpm

import pika

credentials = pika.PlainCredentials(‘guest‘, ‘guest‘)  # 使用用户名密码进行验证
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host=‘192.168.33.35‘, port=5672, credentials=credentials))
channel = connection.channel()  # 声明一个通道

channel.queue_declare(queue=‘test.queue‘)  # 声明一个queue
channel.basic_publish(exchange=‘‘, routing_key=‘test.queue‘, body=‘Hello World!‘)
print(" [x] Sent ‘Hello World!‘")
connection.close()

import pika

credentials = pika.PlainCredentials(‘guest‘, ‘guest‘)  # 使用用户名密码进行验证
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host=‘192.168.33.35‘, port=5672, credentials=credentials))

channel = connection.channel()

channel.queue_declare(queue=‘test.queue‘)

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

channel.basic_consume(callback, queue=‘test.queue‘, no_ack=True)  # callback如果收到消息就调用callback函数处理消息
#  no_ack=True 指客户端处理完消息后，不跟服务器进行确认，这个参数在生成一定不能是用

channel.basic_qos(prefetch_count=1)  # 设置接收端控制消息处理机制
print(‘ [*] Waiting for messages. To exit press CTRL+C‘)

channel.start_consuming()

import pika

credentials = pika.PlainCredentials(‘guest‘, ‘guest‘)  # 使用用户名密码进行验证
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host=‘192.168.33.35‘, port=5672, credentials=credentials))

channel = connection.channel()

channel.queue_declare(queue=‘test.queue‘, durable=True)


def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
    ch.basic_ack(delivery_tag=method.delivery_tag)  # 代表告诉消息服务器我处理完毕，你可以把消息删除了

channel.basic_consume(callback, queue=‘test.queue‘)  # callback如果收到消息就调用callback函数处理消息

channel.basic_qos(prefetch_count=1)  # 设置接收端控制消息处理机制
print(‘ [*] Waiting for messages. To exit press CTRL+C‘)

channel.start_consuming()

import pika
import sys

credentials = pika.PlainCredentials(‘guest‘, ‘guest‘)  # 使用用户名密码进行验证
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host=‘192.168.33.35‘, port=5672, credentials=credentials))
channel = connection.channel()

channel.exchange_declare(exchange=‘logs‘, type=‘fanout‘, durable=True)

message = ‘ ‘.join(sys.argv[1:]) or "info: Hello Worlcccc!"

channel.basic_publish(exchange=‘logs‘, routing_key=‘‘, body=message)
print(" [x] Sent %r" % message)
connection.close()

import pika

credentials = pika.PlainCredentials(‘guest‘, ‘guest‘)  # 使用用户名密码进行验证
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host=‘192.168.33.35‘, port=5672, credentials=credentials))
channel = connection.channel()

channel.exchange_declare(exchange=‘logs‘, type=‘fanout‘, durable=True)

result = channel.queue_declare(exclusive=True)  # 不指定queue名字,rabbit会随机分配一个名字,exclusive=True会在使用此queue的消费者断开后,自动将queue删除
queue_name = result.method.queue

channel.queue_bind(exchange=‘logs‘, queue=queue_name)

print(‘ [*] Waiting for logs. To exit press CTRL+C‘)

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

channel.basic_consume(callback, queue=queue_name)
channel.start_consuming()

import pika
import sys

credentials = pika.PlainCredentials(‘guest‘, ‘guest‘)
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host=‘192.168.33.35‘, port=5672, credentials=credentials))
channel = connection.channel()

channel.exchange_declare(exchange=‘direct_logs‘, type=‘direct‘)

severity = sys.argv[1] if len(sys.argv) > 1 else ‘info‘

message = ‘ ‘.join(sys.argv[2:]) or ‘Hello World!‘

channel.basic_publish(exchange=‘direct_logs‘, routing_key=severity, body=message)
print(" [x] Sent %r:%r" % (severity, message))
connection.close()

import pika
import sys

credentials = pika.PlainCredentials(‘guest‘, ‘guest‘)
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host=‘192.168.33.35‘, port=5672, credentials=credentials))
channel = connection.channel()

channel.exchange_declare(exchange=‘direct_logs‘, type=‘direct‘)

result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue

severities = sys.argv[1:]
if not severities:
    sys.stderr.write("Usage: %s [info] [warning] [error]\n" % sys.argv[0])
    sys.exit(1)

for severity in severities:
    channel.queue_bind(exchange=‘direct_logs‘, queue=queue_name, routing_key=severity)

print(‘ [*] Waiting for logs. To exit press CTRL+C‘)

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

channel.basic_consume(callback, queue=queue_name)

channel.start_consuming()

import redis

r = redis.Redis(host=‘192.168.33.35‘, port=6379)
r.set(‘foo‘, ‘Bar‘)
print(r.get(‘foo‘))

import redis

pool = redis.ConnectionPool(host=‘192.168.33.35‘, port=6379)

r = redis.Redis(connection_pool=pool)
r.set(‘foo‘, ‘Bar‘)
print(r.get(‘foo‘))