socket python json_python实现的基于TCP的JSON数据通信
用Python写的一个多线程TCP通信实例,实现了JSON数据的传输。
闲言少述,直接上代码
一、client
#!/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()
socket python json_python实现的基于TCP的JSON数据通信相关推荐
- python机器学习实现对基于TCP协议的DDOS攻击的流量监测器
文章目录 一.Wireshark抓包工具使用以及数据包分析 1.数据包筛选 2.数据包搜索 3.数据包分析 二.使用python库进行流量特征提取 1.下载scapy库 2.scapy库的使用 3.c ...
- delphi socket 流的使用_基于TCP协议的Socket编程和通信_单向通信
1.TCP:单向通信Socket之服务器端 import java.io.BufferedWriter; import java.io.IOException; import java.io.Outp ...
- java socket 通信协议_java网络通信(基于TCP协议可靠通信的socket编程)
package cn.wang; import java.io.*; import java.net.*; public class Server { static int num = 1;//客户端 ...
- c语言聊天程序socket,今天打的代码。基于TCP的聊天程序。
该楼层疑似违规已被系统折叠 隐藏此楼查看此楼 #include"winsock.h"//# #include"stdio.h"//# #pragma comme ...
- JAVA Socket 底层是怎样基于TCP/IP 实现的???
首先必须明确:TCP/IP模型中有四层结构: 应用层(Application Layer).传输层(Transport Layer).网络层(Internet Layer ).链路层( ...
- android 网络通信方式,Android中基于TCP协议的网络通信
一.Android网络简介 Android与服务器的通信方式主要有两种,一种是Http通信,另一种是Socket通信. HTTP通信:Android中内置HttpClient,这样可以发方便的发送Ht ...
- python 网络编程 套接字的初使用 基于TCP协议的socket
文章目录 基于TCP协议的socket server端 client端 尝试启动 基于TCP协议的socket tcp是基于链接的,必须先启动服务端,然后再启动客户端去链接服务端 server端 # ...
- python实现淘宝客服自动回复语_Python+Socket实现基于TCP协议的客户与服务端中文自动回复聊天功能示例...
本文实例讲述了Python+Socket实现基于TCP协议的客户与服务端中文自动回复聊天功能.分享给大家供大家参考,具体如下: [吐槽] 网上的代码害死人,看着都写的言之凿凿,可运行就是有问题. 有些 ...
- 基于tcp和udp的socket实现
2019独角兽企业重金招聘Python工程师标准>>> 本文介绍如何用Java实现Socket编程.首先介绍Java针对Socket编程提供的类,以及它们之间的关系.然后分别针对TC ...
最新文章
- vant引入组件报错_强烈推荐优秀的Vue UI组件库
- 怎么做一个定时消息提醒_如何用Nodejs编写一个定时消息提醒应用?
- django得到Model的全部字段名(field)
- SQLALchemy (ORM工具)[PostgreSQL为例]
- FOC电机库 定点PID代码分析
- 计算机 画图软件 快捷键大全,教你完整版电脑CAD快捷键大全
- 逆向分析 工具、加壳、安全防护篇
- Dijkstra算法原理
- J2Cache以RabbitMQ作为消息通知配置
- 解决启动CAD时没有响应
- 山东大学计算机转专业2021,2021年山东大学大一新生转专业及入学考试相关规定...
- 为何有好多网站不常用table和iframe这两个元素?
- 赛尔号和赛尔机器人_与赛尔号机器人同乐作文600字
- dcdc模块降额设计_爱默生网络能源PCB设计规范
- 排列组合Cnm的求法
- 2020北京国际茶业展 | 共赴茶香之约,凤牌红茶与您共品好茶
- Android中WebView,打开第三方应用的问题
- Elasticsearch是什么?
- SSL Tomcat 双向认证
- promise的前世来生
热门文章
- IIS作为ASP.NET Core2.1 反向代理服务器未说的秘密
- 带你学习AOP框架之Aspect.Core[1]
- 基于IdentityServer4 实现.NET Core的认证授权
- 使用VS Code 从零开始开发并调试.NET Core 应用程序
- PHP项目中,记录错误日志
- Landsat中国西北地区行列号Shapefile图层对照(附行列号Shapefile下载)
- C和指针之函数递归实现把amount表示的值转换为单词形式written_amount(unsigned int amount,char *buffer)
- linux之man命令用法入门
- 如何解决secureCRT里面的The remote system refused the connection.
- 链表之打印两个有序链表的公共部分