前段和后端怎么用rabbitmq实现消息通信 Python？

Python013

前段和后端怎么用rabbitmq实现消息通信 Python？,第1张

一、通过Python模拟收发消息

1、在各个节点上安装epel源

# yum install epel* -y11

2、安装python库

# yum --enablerepo=epel -y install python2-pika11

3、在rabbitmq-server节点上

1）、创建用户

# rabbitmqctl add_user wuyeliang password 11

2）、创建虚拟主机

# rabbitmqctl add_vhost /my_vhost11

3）、赋予权限

# rabbitmqctl set_permissions -p /my_vhost wuyeliang ".*" ".*" ".*" 11

4、在rabbitmq节点上模拟发消息，代码如下

# vi send_msg.py

#!/usr/bin/env python

import pika

credentials = pika.PlainCredentials('wuyeliang', 'password') #注意用户名及密码

connection = pika.BlockingConnection(pika.ConnectionParameters(

'localhost',

5672,

'/my_vhost',

credentials))

channel = connection.channel()

channel.queue_declare(queue='Hello_World')

channel.basic_publish(exchange='',

routing_key='Hello_World',

body='Hello RabbitMQ World!')

print(" [x] Sent 'Hello_World'")

connection.close()1234567891011121314151612345678910111213141516

4、在client节点上模拟收消息，代码如下

# vi receive_msg.py

#!/usr/bin/env python

import signal

import pika

signal.signal(signal.SIGPIPE, signal.SIG_DFL)

signal.signal(signal.SIGINT, signal.SIG_DFL)

credentials = pika.PlainCredentials('wuyeliang', 'password')

connection = pika.BlockingConnection(pika.ConnectionParameters(

'dlp.srv.world',

5672,

'/my_vhost',

credentials))

channel = connection.channel()

channel.queue_declare(queue='Hello_World')

def callback(ch, method, properties, body):

print(" [x] Received %r" % body)

channel.basic_consume(callback,

queue='Hello_World',

no_ack=True)

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

channel.start_consuming()123456789101112131415161718192021123456789101112131415161718192021

本文实例讲解了python实现两个程序之间通信的方法，具体方法如下：

该实例采用socket实现，与socket网络编程不一样的是socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)的第一个参数是socket.AF_UNIX

而不是 socket.AF_INET

例中两个python程序 s.py/c.py 要先运行s.py

基于fedora13/python2.6测试，成功实现！

s.py代码如下：

#!/usr/bin/env python

import socket

import os

if __name__ == '__main__':

sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)

conn = '/tmp/conn'

if not os.path.exists(conn):

os.mknod(conn)

if os.path.exists(conn):

os.unlink(conn)

sock.bind(conn)

sock.listen(5)

while True:

connection,address = sock.accept()

data = connection.recv(1024)

if data == "hello,server":

print "the client said:%s!\n" % data

connection.send("hello,client")

connection.close()

c.py代码如下：

#!/usr/bin/env python

import socket

import time

if __name__ == '__main__':

sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)

conn = '/tmp/conn'

sock.connect(conn)

time.sleep(1)

sock.send('hello,server')

print sock.recv(1024)

sock.close()

本文介绍了用python与文件进行交互的方法，分享给大家，具体如下：一.文件处理1.介绍 计算机系统：计算机硬件,操作系统,应用程序应用程序无法直接操作硬件，通过操作系统来操作文件，进而读/写硬件中的文件。python打开文件过程：#打开f=open('a.txt','r')#通过句柄对文件进行操作 read()_f=f.read()#关闭文件f.close()with open('a.txt','r') as f: #不需要关闭f.close() #回收操作系统打开的文件del f #回收应用程序级的变量2.打开文件的模式a.打开文本文件#r,只读模式【默认模式，文件必须存在，不存在则抛出异常】f=open('a.txt',encoding='utf-8')data1=f.read()print(f.readline(),end='')print(f.readlines())#w,只写模式【不可读；不存在则创建；存在则清空内容】f=open('a.txt','w',encoding='utf-8')f.write('werf')#a,只追加写模式【不可读；不存在则创建；存在则只追加内容】f=open('a.txt','a',encoding='utf-8')f.write('werf\n')b.对于非文本文件，只能使用b模式，"b"表示以字节的方式操作（而所有文件也都是以字节的形式存储的，使用这种模式无需考虑文本文件的字符编码、图片文件的jgp格式、视频文件的avi格式with open('1.jpg','rb') as f_read:data=f_read.read()print(data)with open('a.txt','rb') as f_read:data=f_read.read().decode('utf-8') #解码print(data)with open('a.txt','wb')as f_write:f_write.write('adsf'.encode('utf-8'))'''练习，利用b模式，编写一个cp工具，要求如下：1. 既可以拷贝文本又可以拷贝视频，图片等文件2. 用户一旦参数错误，打印命令的正确使用方法，如usage: cp source_file target_file'''import sysif len(sys.argv)!=3:print('usage:cp source_file target_file')sys.exit()source_file,target_file=sys.argv[1],sys.argv[2]print()with open(source_file,'rb')as f_read,open(target_file,'wb')as f_write:for line in f_read:f_write.write(line)3.文件内光标的移动#以文本模式读文件，n代表的是字符的个数with open('a.txt','r')as f_read:data=f_read.read(6)print(data)#以b模式读文件，n代表的是字节的个数with open('a.txt','rb')as f_read:data=f_read.read(6)print(data)# tell：告诉当前光标的位置with open('a.txt','r',encoding='utf-8')as f_read:data=f_read.read(4)data1=f_read.tell()print(data,data1)# seek：移动光标（0：文件开头默认；1：文件当前光标；2：文件末尾）with open('a.txt', 'r', encoding='utf-8')as f_read:data = f_read.seek(3)data1 = f_read.read()print(data, data1)# 实现tail功能import timewith open('access.log', 'rb')as f_read:f_read.seek(0,2)while True:line = f_read.readline()if line:print(line.decode('utf-8'),end='')else:time.sleep(1)4.文件的修改import oswith open('a.txt') as read_f,open('.a.txt.swap','w') as write_f:for line in read_f:line=line.replace('alex','SB')write_f.write(line)os.remove('a.txt')os.rename('.a.txt.swap','a.txt')