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)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • dedecms列表页有图调用缩略图无图留空的方法

    dedecms列表页有图调用缩略图无图留空的方法

    2021年9月25日
    42
  • php弱类型花式绕过大全_协同过滤推荐算法代码

    php弱类型花式绕过大全_协同过滤推荐算法代码参考:https://www.leavesongs.com/PENETRATION/webshell-without-alphanum.htmlhttps://www.leavesongs.com/PENETRATION/webshell-without-alphanum-advanced.html字符串异或绕过只适用于PHP5

    2022年10月2日
    3
  • 二阶有源滤波器设计

    二阶有源滤波器设计1引入为什么要用有源二阶滤波器?(1)从有源来说对于无源二阶低通滤波器:其幅頻方程为:我们从中可以看出其通带截止频率为有其品质因子为0.372。我们根据上图得到二阶无源低通滤波器的品质因子只有0.372,如果希望Q大于0.5,就需要在ω=ωo附近增大幅度响应。实现这个目的的一种方法就是增加一个可控的正反馈控制量,这种反馈仅仅在ω=ωo附近奏效,参见下…

    2022年5月4日
    57
  • linux中nmap命令,Linux中nmap命令起什么作用呢?

    linux中nmap命令,Linux中nmap命令起什么作用呢?摘要:下文讲述Linux中nmap的功能说明,如下所示;nmap是一个网络探测和安全审核的工具,它目前是开放源代码模式nmap命令功能:用于网络探测工具和安全和端口扫描器它可以快速扫描大型网络它运用原始的ip报文的方式发现网络上的主机nmap命令的语法格式:nmap[参数]—–常用参数说明——–traceroute:扫描主机端口并跟踪路由-p:扫描指定端口和端口范围-sP:对目标…

    2022年5月28日
    45
  • iOS 签名机制与证书

    iOS 签名机制与证书iOS 签名机制与证书 声明 纯粹就是总结,很多地方跟参考资料一样,就是自己手动打一遍,自己亲自画个图增加理解和加强记忆力,而不只是复制粘贴 iOS 打包流程也不在此叙述,相信很多人已经对照过各种图文

    2022年5月23日
    47
  • 【c#】DataTable分页处理

    【c#】DataTable分页处理【c#】DataTable分页处理

    2022年4月25日
    43

发表回复

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

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