python Socket无限发送接收数据方式

目录

• 一、关于Socket
• Socket简介
• Socket的主要类型
• 二、Python的socket模块
• 三、Socket服务端和客户端相关函数
• 服务端使用的函数
• 客户端使用的函数
• 服务端和客户端都可以使用的函数
• 四、服务器端代码
• 五、客户端代码
• 总结

一、关于Socket

Socket简介

Socket是指套接字，是对网络中不同主机上的应用进程之间进行双向通信的端点的一种抽象。

一个套接字就是网络上进程通信的一端，提供了应用层进程利用网络协议交换数据的机制。

Socket的主要类型

Socket主要有三种类型：流套接字、数据报套接字、原始套接字。

• 流套接字（SOCK_STREAM)：采用了TCP协议，用于提供面向连接、可靠的数据传输服务。
• 数据报套接字（SOCK_DGRAM）：采用了UDP协议，提供一种无连接的服务。该服务并不能保证数据传输的可靠性，数据有可能在传输过程中丢失或出现数据重复，且无法保证顺序地接收到数据。
• 原始套接字（SOCK_RAW）：与上面两种套接字的区别在于原始套接字可以读写内核没有处理的IP数据包，而流套接字只能读取TCP协议的数据，数据报套接字只能读取UDP协议的数据。

本文中讲的是采用TCP协议，即流套接字。

二、Python的socket模块

Python中进行网络编程的主要是使用socket模块，当然还有高级一点的网络服务模块SocketServer等内容。本文中主要使用的是socket模块。

socket模块中首先需要使用socket()方法创建套接字对象，代码示例如下：

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

其中，

• 第一个参数是代表套接字家族，一般有socket.AF_UNIX、socket.AF_INET、socket.AF_INET6可以选择。AF_UNIX是本机的通信，AF_INET和AF_INET6分别是IPv4和IPv6。
• 第二个参数是套接字类型，有socket.SOCK_STREAM、socket.SOCK_DGRAM、socket.SOCK_RAW，分别代表套接字的三种类型。

三、Socket服务端和客户端相关函数

服务端使用的函数

客户端使用的函数

服务端和客户端都可以使用的函数

四、服务器端代码

import socket

def socket_server():
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    ip = ''   # ip可以是127.0.0.1，也可以为空
    port = 0000   # 端口号
    server_socket.bind((ip, port))
    server_socket.listen(5)
    logger.info('等待连接')
    while True:
        try:
            client_socket, address = server_socket.accept()
            logger.info(address[0] + '已连接')
            while True:
                data = client_socket.recv(1024)   # 接受客户端发来的数据
                if not data:
                    logger.info(address[0] + '断开连接')
                    break
                client_socket.send(data.upper())
                """
                可以使用else与上面的if形成搭配
                自己的任意想要实现的功能
				"""
        except ConnectionResetError:
            logger.error(address[0] + '异常断开连接')
            continue
        except KeyboardInterrupt:
            logger.info('服务器关闭')
            break
    server_socket.close()

if __name__ == '__main__':
    socket_server()

五、客户端代码

import socket

def socket_client():
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    ip = ''   # ip可以为127.0.0.1，也可以为服务器的IP，例：10.0.0.xxx
    port = 0000   # 必须与服务器端口号一致
    client_socket.connect((ip, port))

    while True:
        msg = input('>>').strip()
        if not msg:
            continue
        client_socket.send(msg.encode('utf-8'))   # 客户端发送数据
        data = client_socket.recv(1024)   # 接收服务端返回的数据
        print(data.decode("utf-8"))
        # break   无break可以循环发送

    client_socket.close()

if __name__ == '__main__':
    socket_client()

注：

客户端和服务端再接收发送数据时，都需要注意数据格式，即decode()和encode()。

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持小闻网。