码迷,mamicode.com
首页 > 编程语言 > 详细

一个hello/hi的简单的网络聊天程序和python Socket API与Linux Socket API之间的关系

时间:2019-12-09 01:02:08      阅读:105      评论:0      收藏:0      [点我收藏+]

标签:直接   strong   说明   alt   mic   传输   网络   接受   ==   

1.Socket概述

  套接字(socket)是一个抽象层,应用程序可以通过它发送或接收数据,可对其进行像对文件一样的打开、读写和关闭等操作。套接字允许应用程序将I/O插入到网络中,并与网络中的其他应用程序进行通信。网络套接字是IP地址与端口的组合

  套接字可以看成是两个网络应用程序进行通信时,各自通信连接中的一个端点。通信时,其中的一个网络应用程序将要传输的一段信息写入它所在主机的Socket中,该Socket通过网络接口卡的传输介质将这段信息发送给另一台主机的Socket中,使这段信息能传送到其他程序中。因此,两个应用程序之间的数据传输要通过套接字来完成。工作流程如下图所示:

技术图片

Socket():创建套接字。

 
Bind():指定本地地址。在某个知名端口(Well-known Port)上操作的服务器进程必须要对系统指定本地端口,所以一旦创建了一个套接字,服务器就必须使用bind()系统调用为套接字建立一个本地地址。
 
Connect():将套接字连接到目的地址。客户机可以调用connect()为套接字绑定一个永久的目的地址,将它置于已连接状态。对数据流方式的套接字,必须在传输数据前,调用connect()构造一个与目的地的TCP连接,并在不能构造连接时返回一个差错代码。
 
Listen():设置等待连接状态。对于一个服务器的程序,当申请到套接字,并调用bind()与本地地址绑定后,就应该等待某个客户机的程序来要求连接。listen()就是把一个套接字设置为这种状态的函数。
 
Accept():接受连接请求。服务器进程使用系统调用socket,bind和listen创建一个套接字,将它绑定到知名的端口,并指定连接请求的队列长度。然后,服务器调用Accept进入等待状态,直到到达一个连接请求。
 
Send()/Receive():发送和接收数据 。在数据流方式中,一个连接建立以后,或者在数据报方式下,调用了Connect()进行了套接字与目的地址的绑定后,就可以调用Send()和Receive()函数进行数据传输。
 
Close():关闭套接字。
 
2.python网络聊天程序

直接上代码:

客户端:

 1 import socket
 2 import sys
 3 
 4 # 创建一个socket
 5 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 6 # 建立连接
 7 s.connect((127.0.0.1, 3000))
 8 while True:
 9     # 发送数据:
10     try:
11         data = input("客户端:")
12         s.send(data.encode())
13         buf = s.recv(1024).decode()
14         if buf != exit:
15             print("服务端: " + buf)
16     except:
17         print("Dialogue Over")
18         s.close()
19         sys.exit(0)

服务端:

 1 import socket
 2 
 3 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 4 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
 5 s.bind((127.0.0.1, 3000))  # 监听端口
 6 s.listen(1)  # 调用listen()方法开始监听端口,传入的参数指定等待连接的最大数量
 7 sock, addr = s.accept()
 8 buf = sock.recv(1024).decode()
 9 while True:
10     if buf != exit:
11         print("客户端: " + buf)
12     data = input("服务端: ")
13     sock.send(data.encode())
14     if data == exit:
15         break
16     buf = sock.recv(1024).decode()

这两个程序有这么几行,对应上面的工作流程说明:

 

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM):

创建socket实现IPV4的通信(socket.AF_INET)并使用流式socket for TCP(socket.SOCK_STREAM)

 

s.bind((‘127.0.0.1‘, 3000)):

将地址(主机名(127.0.0.1)、端口号(3000)对)绑定到套接字上

 

s.connect((‘127.0.0.1‘, 3000))

连接到指定的服务端的socket上

 

s.listen(1):

调用listen()方法开始监听端口,传入的参数指定等待连接的最大数量,此处为1

 

sock, addr = s.accept() :

接受TCP连接并返回(conn,address),其中conn是新的套接字对象,可以用来接收和发送数据。address是连接客户端的地址。

 

sock.send(data.encode()):

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

 

buf = sock.recv(1024).decode():

接受TCP套接字的数据。数据以字符串形式返回,指定要接收的最大数据量为1024。

 

s.close():

关闭套接字。

 

程序运行结果如下:

客户端:

技术图片

 服务端:

技术图片

 注意要先启动Server再启动Client,否则会报错

 

3.python函数和Linux Socket API的对应关系

对应关系如下表:

python函数 Linux Socket API
socket.socket int socket(int domain, int type, int protocol);
bind int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
connect int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
listen int listen(int sockfd, int backlog);
accept int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
send ssize_t send(int sockfd, const void *buf, size_t len, int flags);
recv ssize_t recv(int sockfd, void *buf, size_t len, int flags);
close int close(int socketfd)

 

可以通过strace python3 server.py命令跟踪这个程序所使用的系统调用

在输出的结果中有这么一段:

 技术图片

 这个程序使用的系统调用对应上面的表格中的Linux Socket API

 

一个hello/hi的简单的网络聊天程序和python Socket API与Linux Socket API之间的关系

标签:直接   strong   说明   alt   mic   传输   网络   接受   ==   

原文地址:https://www.cnblogs.com/sdwwwzaoy/p/12008804.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!