Python之路PythonNet，第四篇，网络4

from greenlet import greenlet #协程函数
def test1():
print(111111111)
gr2.switch()
print(222222222)
gr2.switch()def test2():
print(333333333)
gr1.switch()
print(444444444)#讲函数变为协程
gr1 = greenlet(test1)
gr2 = greenlet(test2)
gr1.switch() #自动运行gr1
#########
# python3 greenlet_demo.py
1111111111
3333333333
2222222222
4444444444

import gevent
import time #协程函数
def foo(a,b):
print("Running in foo",a,b)
gevent.sleep(3) #模拟遇到ＩＯ阻塞的情况（秒）
print('switch to foo again')def bar():
print("Running in bar")
gevent.sleep(2)
print("switch to bar again")#注册为协程事件
f = gevent.spawn(foo,1,2)
b = gevent.spawn(bar)# gevnet.join(f)
# gevnet.join(b)
gevent.joinall([f,b])
###########
# python3 gevent_demo.py
Running in foo 1 2
Running in bar
switch to bar again
switch to foo again

import gevent
#monkey 脚本插件的使用要在导入socket之前
#它改变了socket模块的阻塞部分
from gevent import monkey
monkey.patch_all()
from socket import * #协程事件
def handler(c,addr):
print("Connect from",addr)
while True:
data = c.recv(1024).decode()
if not data:
break
print("Recv msg:",data)
c.send(b"Receive your message")
c.close()HOST = '172.60.50.218'
PORT = 9999
ADDR = (HOST,PORT)
s = socket()
s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
s.bind(ADDR)
s.listen(20)while True:
c,addr = s.accept()
gevent.spawn(handler,c,addr)s.close()

from socket import *
import timeHOST = '172.60.50.218'
PORT = 8888
ADDR = (HOST,PORT)
BUFFERSIZE = 1024sockfd = socket(AF_INET,SOCK_STREAM)
sockfd.bind(ADDR)
sockfd.listen(5)#将sockfd 变为非阻塞
# sockfd.setblocking(False)#设置sockfd 的超时时间
sockfd.settimeout(5)while True:
print("wait for connect......")
# time.sleep(8)
#套接字等待客户端请求
try:
conn,addr = sockfd.accept()
print("connect from ",addr)
# conn.setblocking(False)
while True:
data = conn.recv(BUFFERSIZE)
if not data:
break
print("接受到：",data.decode())
n = conn.send(b"Recv your message\n")
print("发送了%d 字节的数据"%n)
conn.close()
except Exception as e:
print(e) sockfd.close()

#########recv############from socket import * HOST = ''
PORT = 9999#使用数据报套接字
s = socket(AF_INET,SOCK_DGRAM)#设置套接字为允许广播
s.setsockopt(SOL_SOCKET,SO_BROADCAST,1)s.bind((HOST,PORT))while True:
try:
message,addr = s.recvfrom(1024)
print('get msg from',addr)
print("广播通知:",message.decode())
s.sendto('收到广播了'.encode(),addr)
except Exception as e:
print(e)
s.close()#########sendto#######
from socket import *
from time import sleep#设置发送的广播地址，<broadcast>
dest = ('172.60.50.255',9999) s = socket(AF_INET,SOCK_DGRAM)s.setsockopt(SOL_SOCKET,SO_BROADCAST,1)while True:
sleep(2)
s.sendto("喜迎两会，习大大带你飞".encode(),dest)
data,addr = s.recvfrom(1024)
print(data.decode())s.close()

########unix_recv#######from socket import *
import os #设置通信的套接字文件
address = './sockfile'try:
os.unlink(address) #删除这个目录下的这个文件
except OSError:
if os.path.exists(address): #判断文件是否删除成功
raises = socket(AF_UNIX,SOCK_STREAM)
s.bind(address) #绑定本地套接字的文件
s.listen(5)while True:
conn,addr = s.accept()
print("connect from",addr) #addr是空子串
while True:
data = conn.recv(1024).decode()
if not data:
break
print("receive:",data)
conn.send(b"receive your message")
conn.close()
s.close()#########unix_send#########
from socket import *
from time import sleepaddress = './sockfile's = socket(AF_UNIX,SOCK_STREAM)try:
s.connect(address)
except error as e:
print(e)try:
message = b"This is a unix message"
s.send(message)
# sleep(20)
data = s.recv(1024).decode()
print('recv:',data)
except error as e:
print(e)
finally:
s.close()

#导入HTTPSERVER类兼容python3 and python2
try:
from BaseHTTPServer import \
BaseHTTPRequestHandler,HTTPServer
except ImportError:
from http.server import \
BaseHTTPRequestHandler,HTTPServer#具体的请求处理类
class RequestHandler(BaseHTTPRequestHandler):
def do_GET(self):
print("do method get")
fd = open('index.html','rb')
content = fd.read()
#设置响应码
self.send_response(200)
#设置响应头
self.send_header('Content-type','text/html')
#响应头设置完毕
self.end_headers()
#发送响应体
self.wfile.write(content)
return def do_POST(self):
pass #搭建启动服务器
address = ('127.0.0.1',8000)
server = HTTPServer(address,RequestHandler)
server.serve_forever()