python实现的基于TCP的JSON数据通信
2014-08-27 10:01
1031 查看
用Python写的一个多线程TCP通信实例,实现了JSON数据的传输。
闲言少述,直接上代码
一、客户端
#!/usr/bin/env python
# -*- coding:utf-8 -*-
#
import socket
import threading
import SocketServer
import json
def client(ip, port, message):
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect((ip, port))
try:
print "Send: {}".format(message)
sock.sendall(message)
response = sock.recv(1024)
jresp = json.loads(response)
print "Recv: ",jresp
finally:
sock.close()
if __name__ == "__main__":
# Port 0 means to select an arbitrary unused port
HOST, PORT = "localhost", 50001
msg1 = [{'src':"zj", 'dst':"zjdst"}]
msg2 = [{'src':"ln", 'dst':"lndst"}]
msg3 = [{'src':"xj", 'dst':"xjdst"}]
jmsg1 = json.dumps(msg1)
jmsg2 = json.dumps(msg2)
jmsg3 = json.dumps(msg3)
client(HOST, PORT, jmsg1)
client(HOST, PORT, jmsg2)
client(HOST, PORT, jmsg3)
二、服务端
#!/usr/bin/env python
# -*- coding:utf-8 -*-
#
import socket
import threading
import SocketServer
import json, types,string
import os, time
class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
def handle(self):
data = self.request.recv(1024)
jdata = json.loads(data)
print "Receive data from '%r'"% (data)
print "Receive jdata from '%r'"% (jdata)
rec_src = jdata[0]['src']
rec_dst = jdata[0]['dst']
cur_thread = threading.current_thread()
response = [{'thread':cur_thread.name,'src':rec_src,'dst':rec_dst}]
jresp = json.dumps(response)
self.request.sendall(jresp)
rec_cmd = "proccess "+rec_src+" -o "+rec_dst
print "CMD '%r'" % (rec_cmd)
os.system(rec_cmd)
class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
pass
if __name__ == "__main__":
# Port 0 means to select an arbitrary unused port
HOST, PORT = "localhost", 50001
SocketServer.TCPServer.allow_reuse_address = True
server = ThreadedTCPServer((HOST, PORT), ThreadedTCPRequestHandler)
ip, port = server.server_address
# Start a thread with the server -- that thread will then start one
# more thread for each request
server_thread = threading.Thread(target=server.serve_forever)
# Exit the server thread when the main thread terminates
server_thread.daemon = True
server_thread.start()
print "Server loop running in thread:", server_thread.name
print " .... waiting for connection"
# Activate the server; this will keep running until you
# interrupt the program with Ctrl-C
server.serve_forever()
闲言少述,直接上代码
一、客户端
#!/usr/bin/env python
# -*- coding:utf-8 -*-
#
import socket
import threading
import SocketServer
import json
def client(ip, port, message):
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect((ip, port))
try:
print "Send: {}".format(message)
sock.sendall(message)
response = sock.recv(1024)
jresp = json.loads(response)
print "Recv: ",jresp
finally:
sock.close()
if __name__ == "__main__":
# Port 0 means to select an arbitrary unused port
HOST, PORT = "localhost", 50001
msg1 = [{'src':"zj", 'dst':"zjdst"}]
msg2 = [{'src':"ln", 'dst':"lndst"}]
msg3 = [{'src':"xj", 'dst':"xjdst"}]
jmsg1 = json.dumps(msg1)
jmsg2 = json.dumps(msg2)
jmsg3 = json.dumps(msg3)
client(HOST, PORT, jmsg1)
client(HOST, PORT, jmsg2)
client(HOST, PORT, jmsg3)
二、服务端
#!/usr/bin/env python
# -*- coding:utf-8 -*-
#
import socket
import threading
import SocketServer
import json, types,string
import os, time
class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
def handle(self):
data = self.request.recv(1024)
jdata = json.loads(data)
print "Receive data from '%r'"% (data)
print "Receive jdata from '%r'"% (jdata)
rec_src = jdata[0]['src']
rec_dst = jdata[0]['dst']
cur_thread = threading.current_thread()
response = [{'thread':cur_thread.name,'src':rec_src,'dst':rec_dst}]
jresp = json.dumps(response)
self.request.sendall(jresp)
rec_cmd = "proccess "+rec_src+" -o "+rec_dst
print "CMD '%r'" % (rec_cmd)
os.system(rec_cmd)
class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
pass
if __name__ == "__main__":
# Port 0 means to select an arbitrary unused port
HOST, PORT = "localhost", 50001
SocketServer.TCPServer.allow_reuse_address = True
server = ThreadedTCPServer((HOST, PORT), ThreadedTCPRequestHandler)
ip, port = server.server_address
# Start a thread with the server -- that thread will then start one
# more thread for each request
server_thread = threading.Thread(target=server.serve_forever)
# Exit the server thread when the main thread terminates
server_thread.daemon = True
server_thread.start()
print "Server loop running in thread:", server_thread.name
print " .... waiting for connection"
# Activate the server; this will keep running until you
# interrupt the program with Ctrl-C
server.serve_forever()
相关文章推荐
- python实现的基于TCP的JSON数据通信
- Node.js权威指南 (7) - 实现基于TCP与UDP的数据通信
- Node.js实现基于TCP与UDP的数据通信
- 使用net模块实现基于TCP的数据通信
- 使用基于Android网络通信的OkHttp库实现Get和Post方式简单操作服务器JSON格式数据
- python中json格式数据输出实现方式
- 基于spring实现的restful webservice返回json数据
- 基于jQuery的AJAX和JSON实现纯html数据模板
- 基于jQuery的AJAX和JSON实现纯html数据模板
- java分布式开发TCP/IP NIO无阻塞 Socket((基于消息方式实现系统间的通信) )(转)
- python基于xml parse实现解析cdatasection数据
- 基于jQuery的AJAX和JSON实现纯html数据模板
- json和xml数据格式基于ajax的实现方式
- 基于jQuery的AJAX和JSON实现纯html数据模板
- python基于xml parse实现解析cdatasection数据
- Python实现socket通信 (tcp)
- C#基于TCP&UDP实现服务器与多个客户端之间的通信(客户端之间直接通信,不靠服务器端转发消息)
- 基于JSON实现数据列表翻页显示
- 基于TCP/IP的SOCKET接口实现网络通信
- 基于jQuery的AJAX和JSON实现纯html数据模板