当前位置:首页 > 技术 > Python > 正文内容

asyncio --- 异步 I/O http服务代码

Watrt4年前 (2021-10-11)Python18820
import asyncio
async def service(reader,writer):

   data = await reader.read(1024) #同步读取数据
   data =data.decode().replace('\r','<br/>')

   print(writer.get_extra_info('peername'))    #获取连接信息
   writer.write(b'HTTP/1.1 200 OK\r\nContent-Type: text/html; charset=utf-8\r\n\r\n')  #返回HTTP响应头
   #writer.write(b'hi fukun\r\n')
   writer.write(data.encode())     #直接返回响应信息
   writer.close()
   #print(data)


async def server_run():
   server = await asyncio.start_server(service,'127.0.0.1',8888)
   addr = server.sockets[0].getsockname()
   print(f'Serving on {addr}')

   async with server:
       await server.serve_forever()    #开始连接

asyncio.run(server_run())

在linux python3.8测试通过。

import uasyncio
import gc

async def service(reader,writer):
  try:
    data = await reader.read(1024)
    print(data)
    await writer.awrite('HTTP/1.1 200 ok\r\n\r\n hi fukun'.encode())
    await writer.awrite(data)
  except:
    print("传输错误!")
  finally:
    await writer.aclose()
  gc.collect()
def start():
  
  loop = uasyncio.get_event_loop()        //获取协议
  #loop.call_soon(uasyncio.start_server(service, "0.0.0.0", 80))
  loop.create_task(uasyncio.start_server(service, "0.0.0.0"80))
  loop.run_forever()            
  loop.close()

uasyncio.run(start())

通过micropython 实现

打赏 支付宝打赏 微信打赏
分享给朋友:

相关文章

python编写的简单http请求和应答

python编写的简单http请求和应答

响应(服务端)import machine import socket pins = [machine.Pin(i, machine.Pin.IN) for i in (0, 2, 4, 5, 12, 13, 14, 15)] adc = machine.ADC(0) html = &quo...

micropython连接到wifi上面

micropython连接到wifi上面

import network,time,ujson,urequests,ntptime from machine import RTC nic=network.WLAN(network.STA_IF) nic.active(True) #nic.connect('ZCWH','00004157') nic.connect('028sd.com','88884444') nic.co...

micropython 使用ili9163显示IP地址

micropython 使用ili9163显示IP地址

mian.pyexec(open('./wifi.py').read(),globals()) exec(open('./tft.py').read(),globals())wifi.pyimport network import machine import ntptime import time nic = network.WLAN(network.STA_IF) # c...

用mpy-cross保护py文件

用mpy-cross保护py文件

在python中,可以将py文件编译为pyc文件。编译后的pyc文件是二进制格式,一是可以加快加载速度,更重要的是可以保护原始代码。在micropython中同样提供了这个功能,只是它将pyc改名为mpy,编译出的文件扩展名是.mpy。要使用这个功能,首先,我们需要产生mpy-cross工具。在micropython目录下,进入mpy-cross子目录,然后在命令行下输入make编译产生mpy-cross执行文件(需要先安装gcc编译器)。在windows会产生mpy-cross.exe,在li...

Python使用struct处理二进制(pack和unpack用法)

Python使用struct处理二进制(pack和unpack用法)

有的时候需要用python处理二进制数据,比如,存取文件,socket操作时.这时候,可以使用python的struct模块来完成.可以用 struct来处理c语言中的结构体. struct模块中最重要的三个函数是pack(), unpack(), calcsize()pack(fmt, v1, v2, ...)     按照给定的格式(fmt),把数据封装成字符串(实际上是类似于c结构体的字节流) un...

micropython 1.17编译出现FAILED: esp-idf/mbedtls/x509_crt_bundle

micropython 1.17编译出现FAILED: esp-idf/mbedtls/x509_crt_bundle

micropython 1.17编译出现FAILED: esp-idf/mbedtls/x509_crt_bundle 错误解决方法。出现错误的原因是ssl中的证书过期了。解决办法:1:(Top) > Component config > mbedTLS > Certificate Bundle->Enable trusted root certificate bundle   禁用2:修改配置文件 :sdkconfig.base  中添加入...

micropython 清除flash磁盘内容

micropython 清除flash磁盘内容

对于ESP32,一般是在命令行中使用esptool.py清除flash,如果是在程序中想清除flash内容,或者更换文件系统格式,可以用下面方法:import uos uos.VfsFat.mkfs(bdev)如果使用 LFS2 文件系统,命令是import uos uos.VfsLfs2.mkfs(bdev)对于STM32,默认没有bdev设备,需要使用下面方法:import uos flash = pyb.Flash(start=0)u...

发表评论

访客

看不清,换一张

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