python socket

1、TCP链接

TCP是一种面向连接的、可靠的、基于字节流的传输层通信协议。所以在进行TCP链接时首先要开启服务器端口。

TCP服务端一般有几个步骤：

①  sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  创建套接字，第一个参数为套接字家族AF_INET：基于网络的套接字家族；第二个参数SOCK_STREAM：基于TCP协议的通信类型。创建时不带参数默认创建基于TCP协议的网络链接。

②  sk.bind(address)   绑定本机地址与端口号，address：元组，第一个元素为本机ip地址，第二个元素为端口号。

③  sk.listen()   开始监听TCP传入链接。

④  sock, addr = sk.accept()  接收成功链接的TCP并返回元组(sock, addr)，元组第一个元素为新的套接字，负责与链接成功的客户端通信，元组第二个元素为地址，包含IP，与端口号，即 addr = (ip, port)

⑤  sock.recv(bufsize)   bufsize 指定最大接收字节数，返回一个bytes对象，即字节数组。没有数据接收时线程在此堵塞

⑥  sock.send(bytes)     将bytes发送到tcp客户端，返回发送的字节数，接收和发送可以并发执行

⑦  sock.close()   将与客户端通信的套接字关闭，关闭后不能与该客户端进行通信

⑧  sk.close()  将服务端监听套接字关闭，关闭后将不能接收新的链接

 TCP客户端一般有几个步骤：

①  sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  创建套接字

②  sk.connect(("127.0.0.1", 8899))   链接客户端

③  sk.send(bytes)  将bytes发送到服务器，返回发送的字节数

④  msg = sk.recv(bufsize)     接收数据，接收和发送可以并发执行

⑤  sk.close()  关闭套接字

import socket


def fn(conn):
    msg = conn.recv(1024).decode("utf-8")
    print("服务端收到>>>", msg)
    conn.send(msg.encode("utf-8"))
    print("服务端发送消息到客户端>>>", msg)


if __name__ == "__main__":
    sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sk.bind(("127.0.0.1", 8899))
    sk.listen()
    while True:
        conn, addr = sk.accept()
        print("已连接服务器-->", addr)
        fn(conn)
    sk.close()


# 输出结果
已连接服务器--> ('127.0.0.1', 55921)
服务端收到>>> hhh
服务端发送消息到客户端>>> hhh

import socket

sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sk.connect(("127.0.0.1", 8899))
msg = input()
sk.send(msg.encode("utf-8"))
print("客户端发送的内容>>>", msg)
msg = sk.recv(1024).decode("utf-8")
print("客户端收到>>>", msg)
sk.close()


# 输出结果
hhh
客户端发送的内容>>> hhh
客户端收到>>> hhh

import socket
from threading import Thread


def fn(conn):
    msg = conn.recv(1024).decode("utf-8")
    print("服务端收到>>>", msg)
    conn.send(msg.encode("utf-8"))
    print("服务端发送消息到客户端>>>", msg)


if __name__ == "__main__":
    sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sk.bind(("127.0.0.1", 8899))
    sk.listen()
    while True:
        conn, addr = sk.accept()
        print("已连接服务器-->", addr)
        t = Thread(target=fn, args=(conn,))
        t.start()
    sk.close()


# 输出结果已连接服务器--> ('127.0.0.1', 55938)
已连接服务器--> ('127.0.0.1', 55939)
已连接服务器--> ('127.0.0.1', 55940)
服务端收到>>> 111
服务端发送消息到客户端>>> 111
服务端收到>>> 222
服务端发送消息到客户端>>> 222
服务端收到>>> 333
服务端发送消息到客户端>>> 333

 2、UDP连接

udp服务端连接步骤：

①  sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  创建套接字

②  sk.bind(addr)  绑定指定端口和地址，服务端必须绑定，不然客户端无法知道服务端的端口号。客户端可不进行绑定程序运行时随机绑定一个端口号

③  recv_msg, recv_addr = sk.recvfrom(bufsize)   接收数据，没有数据接收时线程在此堵塞

④  sk.sendto(bytes, recv_addr)   发送数据，udp每一次发送数据都需要指定地址，发送与接收可以并发执行

⑤  sk.close()  关闭socket

udp客户端连接步骤：

①  sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  创建套接字

②  sk.sendto(bytes, recv_addr)   发送数据，返回发送的字节数，udp每一次发送数据都需要指定地址，发送与接收可以并发执行

③  recv_msg, recv_addr = sk.recvfrom(bufsize)   接收数据，没有数据接收时线程在此堵塞

④  sk.close()  关闭socket

import socket

print("-----server------")

addr = ("127.0.0.1", 8899)
sk = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sk.bind(addr)

recv_msg, recv_addr = sk.recvfrom(1024)
print("服务端收到>>>", recv_msg.decode("utf-8"), recv_addr)
msg = "AAA"
sk.sendto(msg.encode("utf-8"), recv_addr)
print("服务端发送>>>", msg)

sk.close()


# 输出结果
-----server------
服务端收到>>> BBB ('127.0.0.1', 55802)
服务端发送>>> AAA

import socket

print("-----client------")

server_addr = ("127.0.0.1", 8899)
sk = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

msg = "BBB"
sk.sendto(msg.encode("utf-8"), server_addr)
print("客户端发送>>>", msg)
recv_msg, recv_addr = sk.recvfrom(1024)

print("客户端发送>>>", recv_msg.decode("utf-8"), recv_addr)

sk.close()


# 输出结果
-----client------
客户端发送>>> BBB
客户端发送>>> AAA ('127.0.0.1', 8899)