python3实现unix域协议(tcp、udp)通信

socket API本来是为网络通信设计的,但后来在socket的框架上发展出一种IPC机制,就是UNIXDomain Socket。虽然网络socket也可用于同一台主机的进程间通信(经过loopback地址127.0.0.1),可是UNIX Domain Socket用于IPC更有效率:不须要通过网络协议栈,不须要打包拆包、计算校验和、维护序号和应答等,只是将应用层数据从一个进程拷贝到另外一个进程。这是由于,IPC机制本质上是可靠的通信,而网络协议是为不可靠的通信设计的。UNIX Domain Socket也提供面向流和面向数据包两种API接口,相似于TCP和UDP,可是面向消息的UNIX Domain Socket也是可靠的,消息既不会丢失也不会顺序错乱。html

【unix域套接口】 或 【本地套接口】,它用于位于同一台机器(操做系统)的进程间通讯。它已经被归入POSIX Operating Systems标准。
它支持如下三种方式数据传输:
(1) 可靠的字节流传输(SOCK_STREAM, 对应TCP);
(2) 无序、不可靠的数据包传输(SOCK_DGRAM,对应UDP)。
(3)有序、可靠的数据包传输(SOCK_SEQPACKET)原始套接字,普通的套接字没法处理ICMP、IGMP等网络报文,而SOCK_RAW能够;其次,SOCK_RAW也能够处理特殊的IPv4报文;此外,利用原始套接字,能够经过IP_HDRINCL套接字选项由用户构造IP头。python

参考:https://blog.csdn.net/sandware/article/details/40923491shell

 

不一样主机直接的网络通讯案例:参考:https://www.cnblogs.com/andy9468/p/9948078.htmlwindows

 

python2实现:服务器

python-Unix套接字

https://www.jianshu.com/p/78103b2a74be网络

 

个人测试:python3实现同一主机不一样进程之间的通讯。框架

一台Linux主机A。只能在Linux主机上运行,windows主机上不能够运行。socket

一、A主机的服务端Stcp

# 服务端
import socket
import os

serverAddr = './uds_socket3.txt'  # 套接字存放路径及名称
while True:
    # 地址复用
    if os.path.exists(serverAddr):
        os.unlink(serverAddr)

    # 建立socket
    # 注意TCP协议对应的为SOCK_STREAM 流式
    server_sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)

    server_sock.bind(serverAddr)

    # 让服务端的socket开启监听,等待客户端的链接请求
    # listen中的参数表示已经创建连接和半连接的总数
    # 若是当前已创建连接数和半连接数已达到设定值,那么新客户端不会当即connect成功,而是等待服务器可以处理时
    server_sock.listen(128)

    # 使用accept方法接收客户端的链接请求
    # 若是有新的客户端来链接服务器,那么就产生一个新的套接字专门为这个客户端服务
    # client_sock用来为这个客户端服务,与客户端造成一对一的链接
    # 而server_sock就能够省下来专门等待其余新客户端的链接请求
    # client_addr是请求链接的客户端的地址信息,为元祖,包含用户的IP和端口
    client_sock, client_addr = server_sock.accept()
    print("客户端%s:%s进行了链接!" % (client_sock, client_addr))

    # recv()方法能够接收客户端发送过来的数据,指明最大收取1024个字节的数据
    recv_data = client_sock.recv(1024)
    # python3中收到的数据为bytes类型
    # recv_data.decode()将bytes类型转为str类型
    print("接收到的数据为:", recv_data.decode())

    # send()方法向客户端发送数据,要求发送bytes类型的数据
    client_sock.send("thank you!\n".encode())

    # 关闭与客户端链接的socket
    # 只要关闭了,就意味着为不能再为这个客户端服务了,若是还须要服务,只能再次从新链接
    # client_sock.close()
    # 关闭服务端的监听socket
    # 要这个套接字关闭了,就意味着整个程序不能再接收任何新的客户端的链接
    # server_sock.close()

  

二、A主机的客户端Coop

# 客户端
import socket

serverAddr = './uds_socket3.txt'  # 注意想要跟谁通讯就绑定谁的套接字文件
while True:
    # 建立客户端socket用以跟服务器链接通讯
    # tcp协议对应为SOCK_STREAM
    client_sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)

    # connect方法用来链接服务器
    client_sock.connect(serverAddr)

    # 提示用户输入要发送的数据
    msg = input("请输入要发送的内容:")
    # send()方法想服务器发送数据
    client_sock.send(msg.encode())

    # recv()接收对方发送过来的数据,最大接收1024个字节
    recv_data = client_sock.recv(1024)
    print("收到了服务器的回应信息:%s" % recv_data.decode())

# 关闭客户端套接字
# client_sock.close()

  

开2个shell窗口运行:

python3 myServer.py

 

 

python3 myClient.py

 

 

在myClient.py的shell窗口输入:

1

 

 

在myServer.py窗口查看:

 

不一样主机直接的网络通讯案例:参考:https://www.cnblogs.com/andy9468/p/9948078.html

相关文章
相关标签/搜索