python--socket模块_在python3中,使用socket模块进行数据传输时,数据类型应为字符串类型

什么是 Socket?

Socket又称"套接字"，应用程序通常通过"套接字"向网络发出请求或者应答网络请求，使主机间或者一台计算机上的进程间可以通讯。
socket通信逻辑如下图：

socket()函数

用 socket（）函数来创建套接字
语法：socket.socket([family[, type[, proto]]])
参数解释：

• family: 套接字家族可以使 AF_UNIX 或者 AF_INET。
• type: 套接字类型可以根据是面向连接的还是非连接分为SOCK_STREAM 或 SOCK_DGRAM。
• protocol: 一般不填默认为 0。

通过s = socket.socket()方法，我们可以获得一个socket对象s，也就是通常说的获取了一个“套接字”，该对象具有一下方法：

注意：

1. Python3以后，socket传递的都是bytes类型的数据，字符串需要先转换一下，string.encode()即可；另一端接收到的bytes数据想转换成字符串，只要bytes.decode()一下就可以
2. 在正常通信时，accept()和recv()方法都是阻塞的。所谓的阻塞，指的是程序会暂停在那，一直等到有数据过来。

socket编程的思路

Python的socket编程，通常可分为TCP和UDP编程两种

1. TCP是带连接的可靠传输服务，每次通信都要握手，结束传输也要挥手，数据会被检验，是使用最广的通用模式,三次握手和四次挥手
2. UDP是不带连接的传输服务(不需建立连接和断开连接），简单粗暴，不加控制和检查的一股脑将数据发送出去的方式，但是传输速度快，通常用于安全和可靠等级不高的业务场景，比如文件下载。

TCP编程

服务器端

import socket

ip_port = ('127.0.0.1', 9999)

sk = socket.socket()            # 创建套接字
sk.bind(ip_port)                # 绑定服务地址
sk.listen(5)                    # 监听连接请求
print('启动socket服务，等待客户端连接...')
conn, address = sk.accept()     # 等待连接，此处自动阻塞
while True:     # 一个死循环，直到客户端发送‘exit’的信号，才关闭连接
    client_data = conn.recv(1024).decode()      # 接收信息
    if client_data == "exit":       # 判断是否退出连接
        exit("通信结束")
    print("来自%s的客户端向你发来信息：%s" % (address, client_data))
    conn.sendall('服务器已经收到你的信息'.encode())    # 回馈信息给客户端
conn.close()    # 关闭连接
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

客户端

import socket

ip_port = ('127.0.0.1', 9999)

s = socket.socket()     # 创建套接字

s.connect(ip_port)      # 连接服务器

while True:     # 通过一个死循环不断接收用户输入，并发送给服务器
    inp = input("请输入要发送的信息： ").strip()
    if not inp:     # 防止输入空信息，导致异常退出
        continue
    s.sendall(inp.encode())

    if inp == "exit":   # 如果输入的是‘exit’，表示断开连接
        print("结束通信！")
        break

    server_reply = s.recv(1024).decode()
    print(server_reply)

s.close()       # 关闭连接
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

测试图如下：

套接字的创建和关闭，服务器的绑定和监听，客户端的连接，这些都是固定套路，收发是一一对应的，有发就要有收，并且recv()方法默认是阻塞的

UDP编程

由于UDP没有握手和挥手的过程，因此accept()和connect()方法都不需要
服务端

import socket
ip_port = ('127.0.0.1', 9999)
sk = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, 0)
sk.bind(ip_port)

while True:
    data = sk.recv(1024).strip().decode()
    print(data)
    if data == "exit":
        print("客户端主动断开连接！")
        break

sk.close()

1
2
3
4
5
6
7
8
9
10
11
12
13
14

客户端

import socket
ip_port = ('127.0.0.1', 9999)

sk = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, 0)
while True:
    inp = input('发送的消息：').strip()
    sk.sendto(inp.encode(), ip_port)
    if inp == 'exit':
        break

sk.close()
1
2
3
4
5
6
7
8
9
10
11

测试图如下：

实战项目：
编写端口扫描器：https://blog.csdn.net/Kris__zhang/article/details/114888101
编写udp端口扫描工具全：https://blog.csdn.net/Kris__zhang/article/details/114830931?spm=1001.2014.3001.5501