python修炼——UDP、TCP

今日思维导图

每日代码

udp聊天器

import socket

＂＂＂

这段代码可以实现循环进行收发消息，但是同一时间只能进行一个动作

＂＂＂

def send＿msg（udp＿socket）：

＂＂＂发送数据＂＂＂

＃ 发送数据

client＿ip ＝ input（＂请输入对方ip： ＂）

client＿port ＝ int（input（＂请输入对方端口：＂））

send＿data ＝ input（＂请输入要发送的内容：＂）

＃ 发送数据，使用encode进行编码，ip和端口要放在元组中

udp＿socket．sendto（send＿data．encode（＂utf－8＂）， （client＿ip， client＿port））

def recv＿msg（udp＿socket）：

＂＂＂接收数据＂＂＂

＃ 接收数据 ，需要指定要接收的字节，1024就是 1KB

recv＿data ＝ udp＿socket．recvfrom（1024）

＃ recvfrom返回的数据时一个元组，第一个元素是地址，第二个元素是接收到的消息

＃ 使用decode 进行解码

print（＂％s： ％s＂ ％ （str（recv＿data［1］）， recv＿data［0］．decode（＂utf－8＂）））

def main（）：

＃ 创建套接字

udp＿socket ＝ socket．socket（socket．AF＿INET， socket．SOCK＿DGRAM）

＃ 绑定本地信息，可以知道ip和端口

udp＿socket．bind（（＂＂， 6666））

while True：

print（＂－－－udp聊天器－－－＂）

print（＂1． 发送数据＂）

print（＂2． 接收数据＂）

print（＂0． 退出＂）

op ＝ input（＂请输入要进行的操作＂）

if op ＝＝ ＂1＂：

＃ 调用发送数据的函数

send＿msg（udp＿socket）

elif op ＝＝ ＂2＂：

＃ 调用接收数据的函数

recv＿msg（udp＿socket）

elif op ＝＝ ＂0＂：

break

else：

print（＂输入有误，请重新输入＂）

udp＿socket．close（）

if ＿＿name＿＿ ＝＝ ＂＿＿main＿＿＂：

main（）

tcp服务器代码

import socket

＂＂＂tcp服务器＂＂＂

def main（）：

＃ 创建套接字， tcp的参数时SOCK＿STREAM

tcp＿socket ＝ socket．socket（socket．AF＿INET， socket．SOCK＿STREAM）

＃ 绑定本地地址， 本地地址和端口可能需要重新指定

tcp＿socket．bind（（＂＂， 6666））

＃ 由主动变成被动接听， listen方法可以指定同时连接的客户端

tcp＿socket．listen（128）

while True：

＃ 循环接听客户

＃ 等待客户端连接， 当有客户连接，accept方法返回一个元组

＃ 元组第一个元素是一个新的套接字，只针对于当前连接的这个客户端；第二个元素是客户端地址

colient＿socket， colient＿addr ＝ tcp＿socket．accept（）

＃ 接收数据

print（colient＿addr）

while True：

＃ 循环和同一个客户端联系

colient＿data ＝ colient＿socket．recv（1024）

print（colient＿data．decode（＂utf－8＂））

if colient＿data：

＃ 进行判断，只有客户端还在发送数据，就返回一个数据给客户端

＃ 发挥一部分数据给客户端

colient＿socket．send（＂嘿嘿嘿＂．encode（＂utf－8＂））

else：

＃ 没有数据就

break

＃ 关闭套接字

colient＿socket．close（）

tcp＿socket．close（）

if ＿＿name＿＿ ＝＝ ＂＿＿main＿＿＂：

main（）

tcp客户端代码

import socket

＂＂＂tcp客户端＂＂＂

def main（）：

＃ 创建套接字

tcp＿socket ＝ socket．socket（socket．AF＿INET， socket．SOCK＿STREAM）

＃ 链接服务器， tcp客户端需要先链接服务器

tcp＿socket．connect（（＂192．168．xxx．xxx＂， 6666））

while True：

＃ 循环和服务器联系

＃ 发送数据

print（＂输入【exit】退出链接＂）

send＿data ＝ input（＂请输入要发送的数据：＂）

if send＿data ＝＝ ＂exit＂：

break

tcp＿socket．send（send＿data．encode（＂utf－8＂））

＃ 接收服务器返回的数据

server＿data ＝ tcp＿socket．recv（1024）

print（server＿data．decode（＂utf－8＂））

＃ 关闭套接字

tcp＿socket．close（）

if ＿＿name＿＿ ＝＝ ＂＿＿main＿＿＂：

main（）

在 tcp 这里碰见了一个奇怪的BUG

服务器和客户端运行起来后，输入正常数据没有问题，当只输入一个回车时，程序不发送数据也不接受数据只能强行接受，问了下，没有解决，这玩意好像是因为操作系统底层的原因， 后面再研究研究。

今天内容需要记忆和理解都比较多，不过还算可以接受。

最近在试着使用 Typora 练习 Markdown 写作方式，不是很熟练，写出来有点乱，慢慢练习熟练了再使用这种方式吧。

审核编辑：符乾江