python入门（九）：网络编程和多线程详解编程语言

Socket简介

Socket又称 套接字 ，应用程序通常通过 套接字 向网络发出请求或者应答网络请求，使主机间或者一台计算机上的进程间可以通讯。

socket起源于UNIX，在Unix一切皆文件哲学的思想下，socket是一种 打开—读/写—关闭 模式的实现，服务器和客户端各自维护一个 文件 ，在建立连接打开后，可以向自己文件写入内容供对方读取或者读取对方内容，通讯结束时关闭文件。socket的英文原义是“插槽”或“插座”，就像我们家里座机一样，如果没有网线的那个插口，电话是无法通信的。Socket是实现TCP，UDP协议的接口，便于使用TCP,UDP。

 

Python socket工作流程图：

socket()函数

Python 中，我们用 socket（）函数来创建套接字，语法格式如下：

socket.socket([family[, type[, proto]]])

参数:

family: 套接字家族可以使AF_UNIX或者AF_INET type: 套接字类型可以根据是面向连接的还是非连接分为SOCK_STREAM或SOCK_DGRAM protocol: 一般不填默认为0.

服务器端： 

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

s.listen() 开始TCP监听。backlog指定在拒绝连接之前，操作系统可以挂起的最大连接数量。该值至少为1，大部分应用程序设为5就可以了。 

s.accept() 被动接受TCP客户端连接,(阻塞式)等待连接的到来 

客户端： 

s.connect() 主动初始化TCP服务器连接，。一般address的格式为元组（hostname,port），如果连接出错，返回socket.error错误。 

s.connect_ex() connect()函数的扩展版本,出错时返回出错码,而不是抛出异常 

公共用途的函数： 

s.recv() 接收TCP数据，数据以字符串形式返回，bufsize指定要接收的最大数据量。flag提供有关消息的其他信息，通常可以忽略。 

s.send() 发送TCP数据，将string中的数据发送到连接的套接字。返回值是要发送的字节数量，该数量可能小于string的字节大小。 

s.sendall() 完整发送TCP数据，完整发送TCP数据。将string中的数据发送到连接的套接字，但在返回之前会尝试发送所有数据。成功返回None，失败则抛出异常。 

s.close() 关闭套接字

简单实例

服务端

我们使用 socket 模块的 socket 函数来创建一个 socket 对象。socket 对象可以通过调用其他函数来设置一个 socket 服务。

现在我们可以通过调用 bind(hostname, port) 函数来指定服务的 port(端口)。

接着，我们调用 socket 对象的 accept 方法。该方法等待客户端的连接，并返回 connection 对象，表示已连接到客户端。

完整代码如下：

#!/usr/bin/python3 

# 文件名：server.py 

# 导入 socket、sys 模块 

import socket 

import sys 

# 创建 socket 对象 

serversocket = socket.socket( 

 socket.AF_INET, socket.SOCK_STREAM) 

# 获取本地主机名 

host = socket.gethostname() 

port = 9999 

# 绑定端口 

serversocket.bind((host, port)) 

# 设置最大连接数，超过后排队 

serversocket.listen(5) 

while True: 

 # 建立客户端连接 

 clientsocket,addr = serversocket.accept() 

 print("连接地址: %s" % str(addr)) 

 msg=欢迎访问菜鸟教程！+ "/r/n" 

 clientsocket.send(msg.encode(utf-8)) 

 clientsocket.close()

客户端

接下来我们写一个简单的客户端实例连接到以上创建的服务。端口号为 12345。

socket.connect(hosname, port ) 方法打开一个 TCP 连接到主机为 hostname 端口为 port 的服务商。连接后我们就可以从服务端后期数据，记住，操作完成后需要关闭连接。

完整代码如下：

#!/usr/bin/python3 

# 文件名：client.py 

# 导入 socket、sys 模块 

import socket 

import sys 

# 创建 socket 对象 

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

# 获取本地主机名 

host = socket.gethostname() 

# 设置端口好 

port = 9999 

# 连接服务，指定主机和端口 

s.connect((host, port)) 

# 接收小于 1024 字节的数据 

msg = s.recv(1024) 

s.close() 

print (msg.decode(utf-8)) 

二、多线程

  Python3 通过两个标准库 _thread 和 threading 提供对线程的支持。

  _thread 是对python2的兼容，提供了低级别的、原始的线程以及一个简单的锁，它相比于 threading 模块的功能还是比较有限的。调用 _thread 模块中的start_new_thread()    函数来产生新线程。

  threading 模块除了包含 _thread 模块中的所有方法外，还提供的其他方法：

threading.currentThread(): 返回当前的线程变量。 threading.enumerate(): 返回一个包含正在运行的线程的list。正在运行指线程启动后、结束前，不包括启动前和终止后的线程。 threading.activeCount(): 返回正在运行的线程数量，与len(threading.enumerate())有相同的结果。

  除了使用方法外，线程模块同样提供了Thread类来处理线程，Thread类提供了以下方法:

run(): 用以表示线程活动的方法。 start():启动线程活动。 join([time]): 等待至线程中止。这阻塞调用线程直至线程的join() 方法被调用中止-正常退出或者抛出未处理的异常-或者是可选的超时发生。 isAlive(): 返回线程是否活动的。 getName(): 返回线程名。 setName(): 设置线程名。

 

原创文章，作者：Maggie-Hunter，如若转载，请注明出处：https://blog.ytso.com/11586.html

cjavapython