使用socket实现tcp通信,需导入socket模块
1、服务端
主要步骤:
(1)创建socket:socket.socket(family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None)
family:AF_INET , AF_INET6, AF_UNIX, AF_CAN, AF_PACKET, AF_RDS
type:SOCK_STREAM , SOCK_DGRAM, SOCK_RAW,或者其他SOCK_*
proto:一般使用默认值0
fileno:一般使用默认值
(2)绑定IP和端口号:socket.bind(address)
address:使用(host,port)元组即可
(3)监听:socket.listen([backlog])
backlog:就理解为最大连接数
(4)接受连接:socket.accept()
返回(conn,address)元组,分别是已连接客户端的socket对象和地址
(5)发送/接受数据:socket.recv(bufsize[, flags])/socket.send(bytes[, flags])
bufsize:接收的数据最大字节数
bytes:需要发送的数据字节数
(6)关闭连接:socket.close()
#!/usr/bin/python # -*- coding: UTF-8 -*- # 文件名:tcpserver.py import socket import time MaxBytes=1024*1024 server = socket.socket(socket.AF_INET,socket.SOCK_STREAM) server.settimeout(60) host = '127.0.0.1' #host = socket.gethostname() port = 11223 server.bind((host, port)) # 绑定端口 server.listen(1) # 监听 try: client,addr = server.accept() # 等待客户端连接 print(addr," 连接上了") while True: data = client.recv(MaxBytes) if not data: print('数据为空,我要退出了') break localTime = time.asctime( time.localtime(time.time())) print(localTime,' 接收到数据字节数:',len(data)) print(data.decode()) client.send(data) except BaseException as e: print("出现异常:") print(repr(e)) finally: server.close() # 关闭连接 print("我已经退出了,后会无期")
这个实例没有创建其他线程,也只接收一个客户端的连接;为了能手动结束或自动结束accept和recv的阻塞,设置了超时60秒,并将主体部分放入到try语句中;将socket的关闭放到finally块中,可以防止程序异常退出,而导致没有调用close函数。
2、客户端
主要步骤:
(1)创建socket:socket.socket(family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None)
(2)连接:socket.connect(address)
address:使用(host,port)元组即可
(3)发送/接受数据:socket.recv(bufsize[, flags])/socket.send(bytes[, flags])
(4)关闭连接:socket.close()
#!/usr/bin/python # -*- coding: UTF-8 -*- # 文件名:tcpclient.py import socket import time MaxBytes=1024*1024 host ='127.0.0.1' port = 11223 client = socket.socket(socket.AF_INET,socket.SOCK_STREAM) client.settimeout(30) client.connect((host,port)) while True: inputData=input(); #等待输入数据 if(inputData=="quit"): print("我要退出了,再见") break sendBytes = client.send(inputData.encode()) if sendBytes<=0: break; recvData = client.recv(MaxBytes) if not recvData: print('接收数据为空,我要退出了') break localTime = time.asctime( time.localtime(time.time())) print(localTime, ' 接收到数据字节数:',len(recvData)) print(recvData.decode()) client.close() print("我已经退出了,后会无期")
以上客户端连接成功后等待用户输入,然后将输入信息发送到服务端,服务端将数据原样返回给客户端,如果客户端输入quit就会跳出循环并关闭socket,这时服务端recv会返回空从而跳出循环并关闭socket。希望对大家的学习有所帮助,也希望大家多多支持。
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
- 凤飞飞《我们的主题曲》飞跃制作[正版原抓WAV+CUE]
- 刘嘉亮《亮情歌2》[WAV+CUE][1G]
- 红馆40·谭咏麟《歌者恋歌浓情30年演唱会》3CD[低速原抓WAV+CUE][1.8G]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[320K/MP3][193.25MB]
- 【轻音乐】曼托凡尼乐团《精选辑》2CD.1998[FLAC+CUE整轨]
- 邝美云《心中有爱》1989年香港DMIJP版1MTO东芝首版[WAV+CUE]
- 群星《情叹-发烧女声DSD》天籁女声发烧碟[WAV+CUE]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[FLAC/分轨][748.03MB]
- 理想混蛋《Origin Sessions》[320K/MP3][37.47MB]
- 公馆青少年《我其实一点都不酷》[320K/MP3][78.78MB]
- 群星《情叹-发烧男声DSD》最值得珍藏的完美男声[WAV+CUE]
- 群星《国韵飘香·贵妃醉酒HQCD黑胶王》2CD[WAV]
- 卫兰《DAUGHTER》【低速原抓WAV+CUE】
- 公馆青少年《我其实一点都不酷》[FLAC/分轨][398.22MB]
- ZWEI《迟暮的花 (Explicit)》[320K/MP3][57.16MB]