大家好，又见面了，我是你们的朋友全栈君。

点对点通信实验

语言：python

1.socket基础

参考：百度百科，socket，CSDN上也有很多讲解socket的。

2.python中使用的相关函数

官方文档

1)socket.socket(family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None)

AF_INET:ipv4协议

SOCK_STREAM:面向连接的稳定数据传输，即TCP

2)socket.bind(address)

s.bind(address)将套接字绑定到地址。address地址的格式取决于地址族。在AF_INET下，以元组（host,port）的形式表示地址。

3)socket.listen(backlog)

开始监听传入连接。backlog指定在拒绝连接之前，可以挂起的最大连接数量。backlog等于5，表示内核已经接到了连接请求，但服务器还没有调用accept进行处理的连接个数最大为5,这个值不能无限大，因为要在内核中维护连接队列

4)socket.setblocking(bool)

是否阻塞（默认True），如果设置False，那么accept和recv时一旦无数据，则报错。

5)socket.accept()

接受连接并返回（conn,address）,其中conn是新的套接字对象，可以用来接收和发送数据。address是连接客户端的地址。接收TCP 客户的连接（阻塞式）等待连接的到来

6)socket.connect(address)

连接到address处的套接字。一般，address的格式为元组（hostname,port）,如果连接出错，返回socket.error错误。

7)socket.close()

关闭套接字

8)socket.recv(bufsize[,flag])

接受套接字的数据。数据以字符串形式返回，bufsize指定最多可以接收的数量。flag提供有关消息的其他信息，通常可以忽略。

9)socket.send(string[,flag])

将string中的数据发送到连接的套接字。返回值是要发送的字节数量，该数量可能小于string的字节大小。即：可能未将指定内容全部发送。

3.实验

在同一台虚拟机上运行两个docker容器。ip分别为172.17.0.2和172.17.0.3

一个做服务端，一个做客户端

在服务端运行server.py,客户端运行client.py，如下;

注意，在终止程序时使用Ctrl+C不要用Ctrl+Z，否则程序没有完全关掉，下次运行这个程序时会报错。若用Ctrl+Z关闭程序时，这时可以使用ps aus查看进程，使用kill命令杀死进程再运行。

程序如下：

服务端:

import socket

HOST='172.17.0.2'
PORT=5678

def main():
    service=socket.socket()
    service.bind((HOST,PORT))
    service.listen(5)
    print("server is listening...")

    while True:
        connection,addr=service.accept()
        print(addr[0]+" is connected.")
        while True:
            message=connection.recv(1024).decode('utf-8')
            print(message)
            if message=="#exit#":
                print(addr[0]+" exit.")
                break;
        connection.close()

if __name__ == '__main__':
    main()

客户端：

import socket

HOST='172.17.0.2'
PORT=5678

def main():
    client=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    if client.connect((HOST,PORT))!=socket.error:
        print("connect successfully!")
        try:
            while 1:
                message=input("please input the message you want to send:")
                infor=message.encode('utf-8')
                client.send(infor)
        except KeyboardInterrupt:
            message='#exit#'
            infor=message.encode('utf-8')
            client.send(infor)
            print("exit.")
    client.close()

if __name__ == '__main__':
    main()

注：以上所有操作均在作者在网上搜集资料后，在个人电脑上实验成功，若读者实验时失败，可能由一些未知因素导致，可与作者联系。编写的教程可能由于疏忽出错，请与作者联系。

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/159982.html原文链接：https://javaforall.cn