python实现简易的websocket功能

教主

服务端采用websocket实现

性能会不怎么好

后期将采用高性能框架进行开发

python服务端：

1. # 打开终端输入：pip install websockets 下载模块即可
   
2. 
   
3. import asyncio
   
4. import websockets
   
5. 
   
6. 
   
7. # 接收客户端消息并处理，这里只是简单把客户端发来的返回回去
   
8. async def check_permit(websocket):
   
9.     while True:
   
10.         name = await websocket.recv()
    
11.         print("服务端收到的信息：" + name)
    
12.         greeting = "服务端处理完毕了"
    
13.         await websocket.send(greeting)
    
14. 
    
15. 
    
16. # 服务器端主逻辑,可多加函数也可设置权限访问
    
17. # websocket和path是该函数被回调时自动传过来的，不需要自己传
    
18. async def main_socket(websocket, path):
    
19.     await check_permit(websocket)
    
20. 
    
21. 
    
22. start_server = websockets.serve(main_socket, '0.0.0.0', 5000)
    
23. asyncio.get_event_loop().run_until_complete(start_server)
    
24. asyncio.get_event_loop().run_forever()
    

复制代码

懒人客户端：

1. --本代码是直接复制 打开一个websocket连接 ,修改IP和端口即可
   
2. local ws = nil
   
3. 
   
4. function wLog(text)
   
5.         print(text)
   
6.         toast(text,0,0,20)
   
7. end
   
8. 
   
9. function onOpened(handle)
   
10.         ws = handle
    
11.         print("连接上服务器")
    
12. end
    
13. 
    
14. function reConnect()
    
15.         sleep(2000)
    
16.         wLog("断开连接，3秒后重连")
    
17.         setTimer(function()
    
18.                 ws = nil
    
19.                 startWebSocket("ws://192.168.200.108:5000",
    
20.                 onOpened,onClosed,onError,onRecv)
    
21.         end,3000)
    
22. end
    
23. 
    
24. function onClosed(handle)
    
25.         reConnect()
    
26. end
    
27. 
    
28. function onError(handle)
    
29.         reConnect()
    
30. end
    
31. 
    
32. function onRecv(handle,message)
    
33.         local text = "消息:"..message
    
34.         wLog(text)
    
35. end
    
36. 
    
37. local handle = startWebSocket("ws://192.168.200.108:5000",
    
38. onOpened,onClosed,onError,onRecv)
    
39. 
    
40. 
    
41. if handle ~= nil then
    
42.         local tick = 1
    
43.         while true do
    
44.                 if ws ~= nil then
    
45.                         sendWebSocket(ws,string.format("hello:%d",tick))
    
46.                         tick = tick + 1
    
47.                 end
    
48.                 sleep(100)
    
49.         end
    
50. end
    

复制代码

教主

打错了字,是采用了websockets模块开发

squallx

websocket能运行脚本中的自定义函数吗

152324093

152324093

项目也就  几百台 设备  要撒性能  都不是考虑范围内的事情
再大的工作室  也就  几百台    有多少人 几千台的