快捷導(dǎo)航

Python制作簡易聊天器，搭建UDP網(wǎng)絡(luò)通信模型

更新時間：2022年01月25日 15:40:23 作者：松鼠愛吃餅干?

這篇文章主要介紹了Python制作簡易聊天器，搭建UDP網(wǎng)絡(luò)通信模型，用UDP建立網(wǎng)絡(luò)模型來完成一個簡單的聊天器，感興趣的小伙伴可以參考一下，希望對你有所幫助

1.導(dǎo)入模塊

import socket

socket是套接字，鏈接電腦并且接收/發(fā)送消息的一個對象

socket有兩種類型：udp和tcp

udp比較簡單不安全丟包的情況速度快
tcp比較復(fù)雜的網(wǎng)絡(luò)模型安全速度慢

2.創(chuàng)建一個套接字對象

def main():
? ? udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

udp需要借助網(wǎng)絡(luò)：IP協(xié)議
IP協(xié)議分為兩種：IPv4和IPv6
PC電腦采取的是IPv4，IPv6一般是移動端使用：手機(jī)

3.發(fā)送數(shù)據(jù)到ubuntu系統(tǒng)中

udp_socket.sendto(b'hello python', ('192.168.3.40', 8080))
udp_socket.close()

4.發(fā)送任意數(shù)據(jù)給網(wǎng)絡(luò)條數(shù)助手

def main():
? ? udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
? ? send_data = input('請輸入任意字符:')
? ? udp_socket.sendto(send_data.encode('utf-8'), ('192.168.3.40', 8080))
? ? udp_socket.close()

5.循環(huán)發(fā)送數(shù)據(jù)

def main():
? ? # 創(chuàng)建套接字
? ? udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
? ? # 循環(huán)發(fā)送
? ? while True:
? ? ? ? send_data = input('請輸入你想要發(fā)送的數(shù)據(jù):')
? ? ? ? udp_socket.sendto(send_data.encode('utf-8'), ('192.168.3.40', 8080))
? ? ? ? if send_data == "exit":
? ? ? ? ? ? break

? ? udp_socket.close()

6.循環(huán)接受數(shù)據(jù)

綁定本機(jī)信息告訴ubuntu我的當(dāng)前地址以及端口

def main():
? ? udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
? ? localhost_addr = ('', 6666)
? ? udp_socket.bind(localhost_addr)

循環(huán)接收

while True:
? ? recv_data = udp_socket.recvfrom(1024)
? ? # 元組解包
? ? recv_msg, recv_addr = recv_data
? ? print(recv_msg.decode('utf-8'), recv_addr)

將相關(guān)的功能抽離出來做成一個函數(shù)

發(fā)送消息：

def send_msg(udp_socket):
? ? msg = input('請輸入你想要發(fā)送的消息:')
? ? udp_socket.sendto(msg.encode('utf-8'), ('192.168.3.40', 8080))

接收消息：

def recv_msg(udp_socket):
? ? # 接收
? ? msg = udp_socket.recvfrom(1024)
? ? # 解碼
? ? recv_msg = msg[0].decode('utf-8')
? ? print(recv_msg)

發(fā)送 / 接收功能：

def main():
? ? udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
? ? udp_socket.bind(('', 6666))

? ? while True:
? ? ? ? op_num = input('請輸入要操作的功能序號 [1.發(fā)送消息 2.接收消息]:' )
? ? ? ? # 根據(jù)用戶輸入的數(shù)字去調(diào)用相關(guān)的功能
? ? ? ? if op_num == "1":
? ? ? ? ? ? send_msg(udp_socket)
? ? ? ? elif op_num == "2":
? ? ? ? ? ? recv_msg(udp_socket)
? ? ? ? else:
? ? ? ? ? ? print('輸入有誤, 請重新輸入...')