python3 socket demo

server:

import json import socket # 建立一个服务端 server = socket.socket(socket.AF_INET,socket.SOCK_STREAM) server.bind(('10.0.13.134',12360)) #绑定要监听的端口 server.listen(5) #开始监听 表示可以使用五个链接排队 while True:# conn就是客户端链接过来而在服务端为期生成的一个链接实例 conn,addr = server.accept() #等待链接,多个链接的时候就会出现问题,其实返回了两个值 print(conn,addr) while True: try: js_string = conn.recv(512) #接收数据 # print('recive:',json.loads(js_string)) #打印接收到的数据 js_string=js_string.decode('utf-8', 'ignore') print('recive:',js_string) #打印接收到的数据 if not len(js_string) : break # conn.send(data.upper()) #然后再发送数据 except ConnectionResetError as e: print('关闭了正在占线的链接！') break # conn.close()

client:

import time import json import socket# 客户端 发送一个数据，再接收一个数据 client = socket.socket(socket.AF_INET,socket.SOCK_STREAM) #声明socket类型，同时生成链接对象 client.connect(('10.0.13.134', 12360)) # 建立一个链接，连接到本地的6969端口 DATA={ 'Time':None, 'bbox':None, 'confidence':None, 'label':None, 'shape':None, 'auxl':None, } while True: # addr = client.accept() # print '连接地址：', addr # msg = 'do client' #strip默认取出字符串的头尾空格 DATA['Time']=time.time() DATA['bbox']=[[0.1,0.2,0.3,0.9]] DATA['confidence']=[0.9] DATA['label']='smoke' DATA['shape']=(1080,1920) json_string=json.dumps(DATA) client.send(bytes(json_string,encoding='utf-8')) #发送一条信息 python3 只接收btye流 # data = client.recv(1024) #接收一个信息，并指定接收的大小 为1024字节 # print('recv:',data.decode()) #输出我接收的信息 # del DATA client.send(bytes("new_start",encoding='utf-8')) #发送一条信息 python3 只接收btye流 client.close() #关闭这个链接