我要评论【注】udp的优缺点：
1：传输效率高
2：易出现数据丢失
3：以数据报的形式传输
client.py
from socket import *
service_addr = ("127.0.0.1", 8888)
udp_socket = socket(af_inet, sock_dgram)
while true:
word = input(">>")
if word == "##":
break
udp_socket.sendto(word.encode(), service_addr)
data, addr = udp_socket.recvfrom(1024)
print(f"{data.decode()}")
udp_socket.close()
server.py
import pymysql
from socket import *
class query:
# 连接数据库
def __init__(self):
# 连接数据库
self.count = 0
self.kwargs = {
"host": "localhost",
"port": 3306,
"user": "root",
"password": "123456",
"database": "dict",
"charset": "utf8"
}
self.db = pymysql.connect(**self.kwargs)
self.cur = self.db.cursor()
# udp套接字对象
self.udp_socket = socket(af_inet, sock_dgram)
self.udp_socket.bind(("0.0.0.0", 8888))
def select_db(self, query_word):
query_sql = "select mean from words where word = %s"
self.cur.execute(query_sql, [query_word])
mean = self.cur.fetchone() # 返回的是元组
if mean == none: # 查不到
return
return mean[0]
def run(self):
while true:
data, addr = self.udp_socket.recvfrom(1024) # 获取请求
self.count += 1
print(f"请求{self.count},查询单词：{data.decode()},用户ip：{addr[0]}")
mean = self.select_db(data.decode())
if mean == none:
self.udp_socket.sendto("无结果!".encode(), addr)
else:
self.udp_socket.sendto(mean.encode(), addr)
if __name__ == '__main__':
query = query()
query.run()
发表评论