python 进行socket 通信

python 进行socket 通信

socket是应用层于TCP/IP协议族通信的中间软件抽象层,它是一组接口。Socket组织数据,以求符合指定的协议。

基于TCP协议的Socket(基于连接的通信)

server端(服务器端)

import socket
sk = socket.socket()                         # 括号内默认不加参数就是进行TCP连接
sk.bind(('127.0.0.1',8898))               #把地址绑定到套接字
sk.listen()                                        #监听链接
conn,addr = sk.accept()                 #接受客户端链接
ret = conn.recv(1024)                   #接收客户端信息
print(ret)                                       #打印客户端信息
conn.send(ret.upper)                  #向客户端发送信息
conn.close()                               #关闭客户端套接字
sk.close()                                  #关闭服务器套接字(可选)

client端(客户端)

import socket
sk = socket.socket()           # 创建客户套接字
sk.connect(('127.0.0.1',8898))    # 尝试连接服务器
sk.send(b'hello!')
ret = sk.recv(1024)         # 对话(发送/接收)
print(ret)
sk.close()            # 关闭客户套接字

这样子就可以简单地建立通信了,这时候在客户端向服务端发送消息,服务端就会返回客户端消息的大写,返回到客户端,并且进行打印。
虽然这样子是建立了连接,但是这时候存在一个缺点,就是只能够一个服务端对应一个客户端,这样子是非常的不理想。这时候就需要使用到多线程或者多进程来提高效率了。

改进版

服务端

import socket
from threading import Thread


def connect(conn):
    while True:
        ret = conn.recv(1024)  # 接收客户端信息 (二进制数据)
        # print(ret.decode('utf-8').upper()) # 打印客户端信息,并且转换为大写输出(监听客户端的信息)
        conn.send(ret)  # 向客户端发送信息


sk = socket.socket()
sk.bind(('127.0.0.1', 8898))  # 把地址绑定到套接字
sk.listen(2)  # 监听链接
while True:
    conn, addr = sk.accept()  # 接受客户端链接
    t = Thread(target=connect, args=(conn,))
    t.start()
    print("接通连接")

conn.close()  # 关闭客户端套接字
sk.close()  # 关闭服务器套接字(可选)

客户端

import socket

sk = socket.socket()  # 创建客户套接字 括号内不加参数默认就是tcp协议
sk.connect(('127.0.0.1', 8898))  # 尝试连接服务器
while True:
    try:
        sk.send(b'hello!')   # 服务端接收到的只是二进制的数据
        ret = sk.recv(1024)  # 对话(发送/接收)
        print(ret.decode('utf-8'))
    except Exception as e:
        print("fail:",e)
        break

sk.close()  # 关闭客户套接字
print("关闭连接")

这样子就可以实现多个客户端同时连接在一个服务器上了,这样子在应用上提高了很大的效率。

基于UDP协议的Socket(不基于连接的通信)

服务端

import socket
udp_sk = socket.socket(type=socket.SOCK_DGRAM)   #创建一个服务器的套接字(UDP连接)
udp_sk.bind(('127.0.0.1',9000))        #绑定服务器套接字
msg,addr = udp_sk.recvfrom(1024)
print(msg)
udp_sk.sendto(b'hi',addr)                 # 对话(接收与发送)
udp_sk.close()                         # 关闭服务器套接字

客户端

import socket
ip_port=('127.0.0.1',9000)
udp_sk=socket.socket(type=socket.SOCK_DGRAM)
udp_sk.sendto(b'hello',ip_port)
back_msg,addr=udp_sk.recvfrom(1024)
print(back_msg.decode('utf-8'),addr)
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/115137.html原文链接:https://javaforall.net

(0)
上一篇 2021年11月10日 下午11:00
下一篇 2021年11月11日 下午3:00


相关推荐

  • InvalidateRect说明

    InvalidateRect说明nbsp nbsp nbsp nbsp InvalidateRe 是将窗口中的一块矩形区域标注为 无效 系统会不断向窗口发送 WM PAINT 消息令其重绘 在响应 WM PAINT 消息时 需要调用 BeginPaint 获取 DC 来进行重绘 该函数会合并所有 无效 区域 对 DC 进行裁剪 将整个窗口标注为 有效 清除 WM PAINT 消息 DC 经裁剪之后 在进行绘制时 超出 DC 范围的操作将不被处理 所以即使在响应 W

    2026年3月17日
    3
  • Javadeque_deque接口

    Javadeque_deque接口Queue也是Java集合框架中定义的一种接口,直接继承自Collection接口。除了基本的Collection接口规定测操作外,Queue接口还定义一组针对队列的特殊操作。通常来说,Queue是按照先进先出(FIFO)的方式来管理其中的元素的,但是优先队列是一个例外。Deque接口继承自Queue接口,但Deque支持同时从两端添加或移除元素,因此又被成为双端队列。鉴…

    2026年2月1日
    4
  • 2025实战:从零构建企业级本地知识库的避坑指南

    2025实战:从零构建企业级本地知识库的避坑指南

    2026年3月15日
    3
  • JS 字符串转Date类型

    JS 字符串转Date类型字符串转日期时间格式 getDate strDate vardate eval newDate strDate replace d function a returnparseI a 10 1 match d g returndate

    2026年3月19日
    1
  • vscode 简单配置mingw64

    vscode 简单配置mingw64把 mingw64 添加环境变量 mingw 64 x86 64 8 1 0 release posix seh rt v6 rev0 mingw64 binctrl r 打开 cmd 输入 gcc v 回车 C Users chade gt mdcplusplus projectC Users chade gt cdcplusplus projectC Users chade cplusplus project gt code 这时 vscode 应该已经打开 创

    2026年3月17日
    2
  • pycharm中运行lua脚本requier sys报错_pycharm怎么安装jupyter

    pycharm中运行lua脚本requier sys报错_pycharm怎么安装jupyterpycharm中运行jupyternotebook,首先需要安装:pipinstlljupyternotebook安装完成后在pycharm中新建一个ipynb文件如下图: 然后输入代码,但运行出现了一个问题:解决方法如下:在cmd中运行jupyternotebook,可以看到url和token弄完之后确实可以运行了,但是如果把cmd关掉之后又不能运…

    2022年8月26日
    8

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号