tcp,udp协议的基础聊天,基于udp协议的时间同步机制,在pycharm上实现着色

今日内容:
  1, tcp协议的聊天

    服务器(server):

1# 服务器:<br>import socket 2 3sk = socket.socket() # 创建 套接字 4sk.bind(('127.0.0.1', 9090)) # 绑定 端口 5sk.listen()# 监听 6flag = True 7while flag: 8 con, addr = sk.accept() 9 while 1: 10 msg = con.recv(1024).decode('utf-8') 11 print(f'客户端:{addr}发送了:{msg}') 12 if msg == 'q': break 13 anime = input('>>>') 14 con.send(anime.encode('utf-8')) 15 if anime.lower() == 'q': 16 flag = False 17 break 18 19 con.close() 20sk.close()

  客户端(client):

1# 客户端 2 3import socket 4 5sk = socket.socket() 6sk.connect(('127.0.0.1', 9090)) 7while 1: 8 user = input('>>>') 9 if user.lower() == 'q': break 10 sk.send(user.encode('utf-8')) 11 msg = sk.recv(1024).decode('utf-8') 12 print(msg) 13 if msg == 'q': break 14sk.close()

阻塞: 让程序停下 堵住.
accept() 等待连接
recv() 等待接收客户端打印的消息
input() 等待用户输入.

socket.socket(family = socket.AF_INET, type = SOCK_STREAM )
参数1: family: 套接字类型
   family = socket.AF_INET 采用网络形式通信的套接字
   family = socket.AF_UNIX 采用文件形式通信的套接字
参数2 type : 通信协议类型 tcp协议, udp 协议
   tcp: SOCK_STREAM
   udp: SOCK_DGRAM

2, udp协议的聊天
  sk = socket.socket(type=socket.SOCK_DGRAM)
  sk.recvfrom

  服务器(server):

1# 服务器 2from socket import socket, SOCK_DGRAM 3 4sk = socket(type=SOCK_DGRAM) 5sk.bind(('127.0.0.1', 9090)) 6while 1: 7 msg_r, addr = sk.recvfrom(1024) 8 msg_r = msg_r.decode('utf-8') 9 print(f'客户端:{addr},发来消息:{msg_r}') 10 if msg_r.lower() == 'q': continue 11 msg_s = input('>>>') 12 sk.sendto(msg_s.encode('utf-8'), addr) 13 if msg_s.lower() == 'q': break 14 15sk.close()

  客户端(client):

1# 客户端 2from socket import socket, SOCK_DGRAM 3 4sk = socket(type=SOCK_DGRAM) 5while 1: 6 msg_s = input('>>>') 7 sk.sendto(msg_s.encode('utf-8'), ('127.0.0.1', 9090)) 8 if msg_s.lower() == 'q': break 9 msg_r, addr = sk.recvfrom(1024) 10 msg_r = msg_r.decode('utf-8') 11 print(f'客户端:{addr},发来消息:{msg_r}') 12 if msg_r.lower() == 'q': break 13 14sk.close()

3, 基于udp协议的时间同步机制.

  服务器(server):

1# 基于 udp协议 的服务器 2import socket 3import time 4sk = socket.socket(type=socket.SOCK_DGRAM) 5 6sk.bind(('127.0.0.1',9090)) 7 8while 1: 9 tm_format,addr = sk.recvfrom(1024) 10 tm_format = tm_format.decode('utf-8')# %Y-%m\%d %H:%M:%S 11 local_tm = time.strftime(tm_format)# 获取到了对应格式的当前时间 12 sk.sendto(local_tm.encode('utf-8'),addr)# 返回给客户端 13 14sk.close()

  客户端(client):

1# 基于 udp 协议 的 客户端 2import socket 3import time 4sk = socket.socket(type=socket.SOCK_DGRAM) 5tm_format = input('>>>') 6while 1: 7 sk.sendto(tm_format.encode('utf-8'),('127.0.0.1',9090)) 8 local_tm,addr = sk.recvfrom(1024) 9 print(local_tm.decode('utf-8')) 10 time.sleep(2)

4, 在pycharm上实现着色

    '\033[0;32;40m欢迎使用学生选课系统\033[0m'  这是一个字符串, 着色其实就是 用 \033[X1;X2;X3m 和 \033[0m 包围起来的字符串 会改变颜色.  X2 是背景色, X3 是字体颜色.

      详情内容请见:https://www.cnblogs.com/Eva-J/p/8330517.html

    服务器代码:

1import socket 2sk = socket.socket(type=socket.SOCK_DGRAM)# udp协议 3sk.bind(('127.0.0.1',9090)) 4dic = {'alex':'\033[0;33;42m','太白':'\033[0;35;40m'} 5while 1: 6 msg_r,addr = sk.recvfrom(1024)# 接收来自哪里的消息 7 msg_r = msg_r.decode('utf-8')# alex : 我要退学 8 # 对于msg_r,通过':'分割,获取下标为0,也就是name,再去掉name的左右两边的空格 9 name = msg_r.split(':')[0].strip() 10 11 color = dic.get(name,'')# 获取字典中 name所对应的 颜色值 12 print('%s%s \033[0m'%(color,msg_r)) 13 if msg_r == 'q':# 如果当前客户端想要断开连接 14 continue # 服务器端不应该继续通话了,应该等待接收另一个客户端的连接,返回到recvfrom 15 msg_s = input('>>>') 16 sk.sendto(msg_s.encode('utf-8'), addr) 17 if msg_s == 'q': 18 break 19sk.close()

  客户端代码:

1import socket 2sk = socket.socket(type=socket.SOCK_DGRAM) 3name = input('请输入您的名字:>>>') 4while 1: 5 msg_s = input('>>>') 6 msg_s = name + " : "+msg_s 7 sk.sendto(msg_s.encode('utf-8'),('127.0.0.1',9090))# 发给谁一条消息 8 if msg_s is 'q': 9 break 10 msg_r,addr = sk.recvfrom(1024) 11 msg_r = msg_r.decode('utf-8') 12 print(msg_r) 13 if msg_r == 'q': 14 break 15 16sk.close()
点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

MySQL部分从库上面因为大量的临时表tmp_table造成慢查询

背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_

皕杰报表之UUID

​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

2020年前端实用代码段,为你的工作保驾护航

有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )