python学习笔记（十一）——网络编程

python 可以使用 socket 模块进行网络通信。

在python开发文档中可以查询到有关该模块的参考 https://docs.python.org/zh-cn/3/library/socket.html?highlight=socket#module-socket

一、使用 socket.socket()函数创建套接字

socket(socket_family, socket_type, protocol=0)
‘’‘
socket_family 可选 AF_UNIX 或 AF_INET
# AF_UNIX用于同一台机器上的进程间通信
# AF_INET对于IPV4协议的TCP和UDP
socket_type 可选 SOCK_STREAM 或 SOCK_DGRAM
# SOCK_STREAM 流式套接字，即TCP
# SOCK_DGRAM 数据报套接字，即UDP
protocol 通常省略，默认为 0
‘’’

• 创建TCP/IP套接字

tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

• 创建 UDP/IP 套接字

udpSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

socket对象内置方法

网络编程示例

1. TCP程序

1.1. 简单的服务器应答程序

功能：客户端连接服务端后，服务端发送“你好”到客户端，客户端接收数据并打印到屏幕上。

# server.py
from socket import socket

ss = socket() # 创建服务器套接字
ss.bind(("127.0.0.1",6000))    # 套接字与地址绑定
ss.listen(5)                    # 监听连接
while True:   # 服务器无限循环
    cs,c_addr = ss.accept() # 接受客户端连接
    data = cs.send("你好..".encode("utf-8"))  # 使用字节流传输数据
    cs.close() # 关闭客户端套接字
ss.close() # 关闭服务器套接字 

from socket import socket

s = socket() # 默认参数socket.AF_INET, socket.SOCK_STREAM
s.connect(("127.0.0.1",6000))
data = s.recv(1024)		# 最大接收长度
print(data.decode("utf-8"))	
s.close()

1.2. 服务器返回当前时间程序

import socket, time

serversocket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
serversocket.bind(('',8888))    # localhost/127.0.0.1
serversocket.listen(5)

while True:
    (clientsocket, address) = serversocket.accept() #等待客户端连接
    data = clientsocket.recv(4096)          #接收姓名
    print("打印: ", data.decode())         # 将字节流(bitys)转换为str
    datetime = time.asctime()+'\n'
    replay = 'Hello'.encode() + data;   #回复：问候消息
    replay += 'My time is '.encode() + datetime.encode()#回复：当前服务器时间
    clientsocket.send(replay)           # 发送消息
    clientsocket.close()#关闭连接

import os
import sys
import socket

sock = socket.socket(socket.AF_INET,socket . SOCK_STREAM)
sock.connect((sys.argv[1],8888))             #服务器地址由命令行指定
sock.send( (os.getlogin() + '\n').encode()) #发送姓名
message = sock.recv(4096)       #接收响应
print(message.decode())         #打印结果
sock.close()#关闭连接

# 编译命令 python client.py localhost

2.UDP程序

echo程序，客户端向服务器端发送数据，服务器将该数据再次发送会=回给客户端。

# ser.py
import socket

ss = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)   # udp
ss.bind(("127.0.0.1", 6001))     # 绑定本地地址
while True:
    data,addr = ss.recvfrom(1024)
    print("from",addr,"recv:", data.decode("utf-8"))
    ss.sendto(data, addr)

# cli.py
import socket
                                    # udp
ss = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
ser_addr = ("127.0.0.1",6001)     # 服务器地址
while True:
    sendbuf = input("输入：")
    if sendbuf == "exit":
        break;
    ss.sendto(sendbuf.encode("utf-8"), ser_addr)
    data,_ = ss.recvfrom(1024)
    print("recv:", data.decode("utf-8"))

转载：https://blog.csdn.net/weixin_43919932/article/details/116796772