socket(简称套接字),是进程间通讯的一个工具,他能实现把数据从一方传输到另一方,完成不同电脑上进程之间的通讯,它好比数据的搬运工。
socket应用:
不夸张来说,只要跟网络相关的应用程序或者软件都使用到了socket, 比如:微信,qq等
使用socket创建udp网络程序的流程:
1,创建客户端套接字
2,发送/接收数据
3,关闭套接字
使用程序展现流程 :(使用的 ide为pycharm):
1,首先创建socket,在 Python 中 使用socket 模块的函数 socket 就可以完成:
import socket
2,创建udp socket套接字
创建套接字格式 :udp_socket = socket(AddressFamily, Type)
其中AddressFamily代表IP地址类型,AF_INET表示ipv4类型、AF_INET6表示ipv6类型; Type:套接字类型,可以是 SOCK_STREAM(流式套接字,主要用于 TCP 协议)或者 SOCK_DGRAM(数据报套接字,主要用于 UDP 协议)
udp_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
3,发送/接收套接字(接上方的步骤)
首先准备对方的 ip地址和 端口号
假设ip地址为:192.168.1.103
端口号为:8080
dest_addr = ('192.168.1.103',8080) #注意 是元组 ip地址为字符串,端口号为数字
从键盘获取数据
send_data = input('请输入要输入的数据 ')
发送数据到指定的电脑上
udp_socket = socket.sendto(send_data.encode('utf-8'),dest_addr)
#sendto是udp用来发送数据的,在发送的过程中我们需要对发送的数据进行转码,转换成utf-8
4,关闭套接字
udp_socket.close()
以上便是udp使用socket传输的一些基本步骤
整个发送/接受数据的小程序完整如下:
import socket
# 1. 创建udp套接字
udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 2. 准备接收方的地址
dest_addr = ('192.168.236.129', 8080)
# 3. 从键盘获取数据
send_data = input("请输入要发送的数据:")
# 4. 发送数据到指定的电脑上
udp_socket.sendto(send_data.encode('utf-8'), dest_addr)
# 5. 等待接收对方发送的数据
recv_data = udp_socket.recvfrom(1024) # 1024表示本次接收的最大字节数
# 6. 显示对方发送的数据
# 接收到的数据recv_data是一个元组
# 第1个元素是对方发送的数据
# 第2个元素是对方的ip和端口
print(recv_data[0].decode('gbk'))
print(recv_data[1])
# 7. 关闭套接字
udp_socket.close()
数据的编码和解码(简单两行):
str->bytes:encode编码
bytes->str:decode解码
udp绑定端口:
用上方的小程序发送信息,我们每次发送的数据,端口好都是会改变的,所以需要我们对端口进行绑定
绑定示例:
from socket import *
# 1. 创建套接字
udp_socket = socket(AF_INET, SOCK_DGRAM)
# 2. 绑定本地的相关信息,如果一个网络程序不绑定,则系统会随机分配
local_addr = ('', 7788) # ip地址和端口号,ip一般不用写,表示本机的任何一个ip
udp_socket.bind(local_addr)
# 3. 等待接收对方发送的数据
recv_data = udp_socket.recvfrom(1024) # 1024表示本次接收的最大字节数
# 4. 显示接收到的数据
print(recv_data[0].decode('gbk'))
# 5. 关闭套接字
udp_socket.close()
udp小程序的实战(面向对象开发):简单的聊天室(一起使用python的基础知识和上访的udp来实战吧^_^)
import socket
#这个是发送信息的函数
def send_msg(udp_socket):
"""获取键盘数据,并将其发送给对方"""
# 1. 从键盘输入数据
msg = input("\n请输入要发送的数据:")
# 2. 输入对方的ip地址
dest_ip = input("\n请输入对方的ip地址:")
# 3. 输入对方的port
dest_port = int(input("\n请输入对方的port:"))
# 4. 发送数据
udp_socket.sendto(msg.encode("utf-8"), (dest_ip, dest_port))
#这个是接受数据的函数
def recv_msg(udp_socket):
"""接收数据并显示"""
# 1. 接收数据
recv_msg = udp_socket.recvfrom(1024)
# 2. 解码
recv_ip = recv_msg[1]
recv_msg = recv_msg[0].decode("utf-8")
# 3. 显示接收到的数据
print(">>>%s:%s" % (str(recv_ip), recv_msg))
#主函数
def main():
# 1. 创建套接字
udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 2. 绑定本地信息
udp_socket.bind(("", 7890))
while True:
# 3. 选择功能
print("="*30)
print("1:发送消息")
print("2:接收消息")
print("="*30)
op_num = input("请输入要操作的功能序号:")
# 4. 根据选择调用相应的函数
if op_num == "1":
send_msg(udp_socket)
elif op_num == "2":
recv_msg(udp_socket)
else:
print("输入有误,请重新输入...")
if __name__ == "__main__":
main()
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。