python网络编程基础--socket的简介,以及使用socket来搭建一个简单的udp小程序

Posted 2020-12-30

socket介绍：

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()