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服务端和客户端相关函数

服务端使用的函数

函数

描述

s.bind()

绑定地址(host,port)到套接字, 在 AF_INET下,以元组(host,port)的形式表示地址

s.listen()

开始 TCP 监听。参数backlog是指操作系统可以挂起的最大连接数量。该值至少为 1,一般设置为5

s.accept()

被动接受TCP客户端连接,阻塞式等待连接的到来

客户端使用的函数

函数

描述

s.connect()

TCP服务器连接,参数address的格式为元组(hostname,port),如果连接出错,返回socket.error错误。

s.connect_ex()

connect()函数的扩展版本,出错时返回出错码,而不是抛出异常

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

函数

描述

s.recv()

接收 TCP 数据,数据以字符串形式返回,bufsize 指定要接收的最大数据量

s.send()

发送 TCP 数据,将参数string 中的数据发送到连接的套接字

s.sendall()

完整发送 TCP 数据。将参数 string 中的数据发送到连接的套接字,但在返回之前会尝试发送所有数据。成功返回 None,失败则抛出异常。

s.close()

关闭套接字

s.getpeername()

返回连接套接字的远程地址。返回值通常是元组(ipaddr,port)

s.getsockname()

返回套接字自己的地址。通常是一个元组(ipaddr,port)

s.setsockopt()

设置给定套接字选项的值

s.getsockopt()

返回套接字选项的值

s.settimeout()

设置套接字操作的超时期,参数timeout是一个浮点数,单位是秒。值为None表示没有超时期

s.gettimeout()

返回当前超时期的值,单位是秒,如果没有设置超时期,则返回None

s.setblocking()

如果参数flag为0,则将套接字设为非阻塞模式,否则将套接字设为阻塞模式(默认值)。非阻塞模式下,如果调用recv()没有发现任何数据,或send()调用无法立即发送数据,那么将引起socket.error异常

四、服务器端代码

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

目录
打赏
0
1
1
0
434
分享
相关文章
如何在Python中高效实现CSV到JSON的数据转换
在实际项目中,数据格式转换是常见问题,尤其从CSV到JSON的转换。本文深入探讨了多种转换方法,涵盖Python基础实现、数据预处理、错误处理、性能优化及调试验证技巧。通过分块处理、并行处理等手段提升大文件转换效率,并介绍如何封装为命令行工具或Web API,实现自动化批量处理。关键点包括基础实现、数据清洗、异常捕获、性能优化和单元测试,确保转换流程稳定高效。
102 82
从零开始:用Python爬取网站的汽车品牌和价格数据
在现代化办公室中,工程师小李和产品经理小张讨论如何获取懂车帝网站的汽车品牌和价格数据。小李提出使用Python编写爬虫,并通过亿牛云爬虫代理避免被封禁。代码实现包括设置代理、请求头、解析网页内容、多线程爬取等步骤,确保高效且稳定地抓取数据。小张表示理解并准备按照指导操作。
从零开始:用Python爬取网站的汽车品牌和价格数据
从集思录可转债数据探秘:Python与C++实现的移动平均算法应用
本文探讨了如何利用移动平均算法分析集思录提供的可转债数据,帮助投资者把握价格趋势。通过Python和C++两种编程语言实现简单移动平均(SMA),展示了数据处理的具体方法。Python代码借助`pandas`库轻松计算5日SMA,而C++代码则通过高效的数据处理展示了SMA的计算过程。集思录平台提供了详尽且及时的可转债数据,助力投资者结合算法与社区讨论,做出更明智的投资决策。掌握这些工具和技术,有助于在复杂多变的金融市场中挖掘更多价值。
24 12
Python用代理IP获取抖音电商达人主播数据
在当今数字化时代,电商直播成为重要的销售模式,抖音电商汇聚了众多达人主播。了解这些主播的数据对于品牌和商家至关重要。然而,直接从平台获取数据并非易事。本文介绍如何使用Python和代理IP高效抓取抖音电商达人主播的关键数据,包括主播昵称、ID、直播间链接、观看人数、点赞数和商品列表等。通过环境准备、代码实战及数据处理与可视化,最终实现定时任务自动化抓取,为企业决策提供有力支持。
[oeasy]python061_如何接收输入_input函数_字符串_str_容器_ 输入输出
本文介绍了Python中如何使用`input()`函数接收用户输入。`input()`函数可以从标准输入流获取字符串,并将其赋值给变量。通过键盘输入的值可以实时赋予变量,实现动态输入。为了更好地理解其用法,文中通过实例演示了如何接收用户输入并存储在变量中,还介绍了`input()`函数的参数`prompt`,用于提供输入提示信息。最后总结了`input()`函数的核心功能及其应用场景。更多内容可参考蓝桥、GitHub和Gitee上的相关教程。
16 0
python实战——使用代理IP批量获取手机类电商数据
本文介绍了如何使用代理IP批量获取华为荣耀Magic7 Pro手机在电商网站的商品数据,包括名称、价格、销量和用户评价等。通过Python实现自动化采集,并存储到本地文件中。使用青果网络的代理IP服务,可以提高数据采集的安全性和效率,确保数据的多样性和准确性。文中详细描述了准备工作、API鉴权、代理授权及获取接口的过程,并提供了代码示例,帮助读者快速上手。手机数据来源为京东(item.jd.com),代理IP资源来自青果网络(qg.net)。
深度探索Python Socket编程:从理论到实践,进阶篇带你领略网络编程的魅力!
【7月更文挑战第25天】在网络编程中, Python Socket编程因灵活性强而广受青睐。本文采用问答形式深入探讨其进阶技巧。**问题一**: Socket编程基于TCP/IP,通过创建Socket对象实现通信,支持客户端和服务器间的数据交换。**问题二**: 提升并发处理能力的方法包括多线程(适用于I/O密集型任务)、多进程(绕过GIL限制)和异步IO(asyncio)。**问题三**: 提供了一个使用asyncio库实现的异步Socket服务器示例,展示如何接收及响应客户端消息。通过这些内容,希望能激发读者对网络编程的兴趣并引导进一步探索。
89 4

热门文章

最新文章

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等