python3.7在线编程(Python 网络编程基础入门知识篇,欢迎收藏!)python基础 / python网络编程基础...

wufei123 发布于 2024-07-01 阅读(3)

Python的网络编程主要支持两种网络协议:TCP和UDP这两种协议都通过叫Socket的编程抽象进行处理Socket起源于Unix,是类似于文件的存在,可以像文件一样进行I/O、打开、关闭等操作,最主要的是它可以实现网络上不同主机的进程间通信,所以基本上Socket是任何一种网络通讯中最基础的内容。

Python中建立一个套接字很简单:

import sockets = socket.socket(family, type)地址族family为地址族,该族指定要使用的网络协议,主要使用的有:AF_INET:IPv4协议(TCP,UDP)

AF_INET6:IPv6协议(TCP,UDP)AF_UNIX:UNIX域协议,用于同一台机器的进程间通讯套接字类型type为套接字类型,指定给定的协议组中使用的通信类型:SOCK_STREAM:用于TCP

SOCK_DGRAM:用于UDPTCP和UDP都是基于Client/Server的编程模型,所以Socket编程也分为客户端和服务器端,以TCP为例:TCP客户端编程要获取远程主机的ip地址,可以使用socket标准库提供的gethostbyname方法:

socket套接字实例s可用于客户端的方法有以下几个:s.connect(addr):连接服务器端套接字addr格式取决于地址族,对于IPv4来说,是一个包含ip地址与端口的元组,(host, port)。

连接失败会报socket.error错误s.sendall(string):尝试发送所有数据,成功则返回None,失败则报异常s.recv(bufsize):接收数据,bufsize指定接收的最大数据量。

s.close:关闭套接字OK,现在可以用socket向远程主机发送一个HTTP GET请求了:

# -*- coding: utf-8 -*-import sockets = socket.socket(socket.AF_INET, socket.SOCK_STREAM) #建立套接字host = www.baidu.com

port = 80ip = socket.gethostbyname(host) #获取ips.connect((ip, port)) #建立连接message = GET / HTTP/1.1rnrn

s.sendall(message) #发送GET请求r = s.recv(4096) #接收数据print rs.close #关闭套接字返回:

HTTP/1.1 302 Moved TemporarilyDate: Wed, 10 Jan 2018 18:56:45 GMTContent-Type: text/htmlContent-Length: 225

Connection: Keep-AliveLocation: http://www.baidu.com/search/error.htmlServer: BWS/1.1X-UA-Compatible: IE=Edge,chrome=1

BDPAGETYPE: 3Set-Cookie: BDSVRTM=0; path=/

下面我们可以实现自己的服务器TCP服务器端编程Socket实例与服务器端编程有关的方法有以下几个:s.bind(addr):addr也是(host, port)形式的元组,将套接字绑定到特定的地址和端口上。

空字符串表示任意地址,broadcast可以用做发送广播信息s.listen(backlog):开始监听连接,backlog为最大挂起连接次数s.accept:返回元组(conn,addr),conn为新的套接字,可以用来发送和接收数据。

addr是客户端的套接字地址s.recv、s.sendall和s.close与客户端同现在写一个将客户端发送来的信息发送回去的服务器:。

# -*- coding: utf-8 -*-import socketimport sysHOST = PORT = 8088s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

s.bind((HOST, PORT))s.listen(5)print 开始监听conn, addr = s.acceptprint Connected with + addr[0] + : + str(addr[1])

data = conn.recv(1024)conn.sendall(data)conn.closes.close运行:服务器开始监听连接了修改一下刚才写的客户端程序:。

# -*- coding: utf-8 -*-import sockets = socket.socket(socket.AF_INET, socket.SOCK_STREAM)host = localhost

port = 8088s.connect((host, port)) #建立连接message = GET / HTTP/1.1rnrns.sendall(message) #发送GET请求r = s.recv(4096) #接收数据

print rs.close #关闭套接字运行,连接本地的服务器,服务器端输出:连接成功客户端输出:发送的消息被返回了这就是一个最简单的服务器了上述服务器只能处理一次连接,这显然不是我们想看到的,保持一直运行:。

# -*- coding: utf-8 -*-import socketimport sysHOST = PORT = 8088s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

s.bind((HOST, PORT))s.listen(5)print 开始监听while True:conn, addr = s.acceptprint Connected with + addr[0] + : + str(addr[1])

data = conn.recv(1024)conn.sendall(data)conn.closes.close

现在就可以使用客户端无限连接了:服务器端多线程处理连接现在服务器端虽然可以处理无限多个连接,但只能一个一个的处理,后面的客户端连接只能等待前面的连接完成才能发送数据要同时处理多个连接,可以使用多线程服务器端接收到新的连接后,开启一个线程处理新连接,主线程去建立下一个连接。

服务器端:

# -*- coding: utf-8 -*-import socketimport threadingHOST = PORT = 8088s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

s.bind((HOST, PORT))s.listen(5)print 开始监听def runThread(conn):data = conn.recv(1024)print dataconn.sendall(data)

conn.closewhile True:conn, addr = s.acceptprint Connected with + addr[0] + : + str(addr[1])t = threading.Thread(target=runThread, args=(conn,))

t.daemon = Truet.start客户端启动多个连接:

# -*- coding: utf-8 -*-import socketimport timeimport threadingdef run:s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

host = localhostport = 8088s.connect((host, port))message = GET / HTTP/1.1rnrns.sendall(message)print s.recv(4096)

s.closeif __name__ == __main__:for i in xrange(4):t = threading.Thread(target=run)t.start运行:

开始监听Connected with 127.0.0.1:61772GET / HTTP/1.1Connected with 127.0.0.1:61773GET / HTTP/1.1Connected with 127.0.0.1:61774

GET / HTTP/1.1Connected with 127.0.0.1:61775GET / HTTP/1.1UDP编程UDP与TCP的不同之处在于UDP是不用建立连接的在此需要使用s.recvfrom与s.sendto方法,前者与s.recv相同,但返回(data, addr)的元组,addr为数据发送端的套接字地址,后者发送数据时需要加入要发送的远程地址。

服务器:

# -*- coding: utf-8 -*-import sockets = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)s.bind((, 10000))

while True:data, addr = s.recvfrom(1024)print 接收到%s的连接%str(addr)s.sendto(data, addr)客户端:

# -*- coding: utf-8 -*-import sockets = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)s.sendto(Hello World, (localhost, 10000))

r, addr = s.recvfrom(1024)print rs.close

Python学习关注,免费直播最新课程学习群:839383765 分享业内最新python知识!

发表评论:

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。

河南中青旅行社综合资讯 奇遇综合资讯 盛世蓟州综合资讯 综合资讯 游戏百科综合资讯 新闻30606