基于websocket实现多端即时通讯小示例

基于websocket实现多端即时通讯小示例,可以实现多个客户端的即时通讯.
python 源码需要先安装一下:
pip install SimpleWebSocketServer 第三方库

synchronizer.py 文件源码:

1. import json
   
2. from SimpleWebSocketServer import WebSocket, SimpleWebSocketServer
   
3. wss = []
   
4. class SimpleEcho(WebSocket):
   
5.     # 接收设备发送来的数据
   
6.     def handleMessage(self):
   
7.         if self.data is None:
   
8.             self.data = ''
   
9.         print(self.address,'发送的数据:',self.data)
   
10.         # 接收数据 广播给所以 连接设备
    
11.         for i in wss:
    
12.             i.sendMessage(json.dumps({'code':200,'msg':self.data},ensure_ascii=False))
    
13. 
    
14.     def handleConnected(self):
    
15.         # 客户端连接打印 ip:端口
    
16.         print(self.address, '设备连接成功')
    
17.         if not self in wss:
    
18.             wss.append(self)
    
19. 
    
20.     def handleClose(self):
    
21.         # 客户端关闭后打印
    
22.         print(self.address, '设备已断开')
    
23. 
    
24.     @staticmethod
    
25.     def run():
    
26.         print('websocket 服务器启动中...')
    
27.         server = SimpleWebSocketServer('0.0.0.0', 8000, SimpleEcho)
    
28.         server.serveforever()
    
29. if __name__ == '__main__':
    
30.     SimpleEcho.run()

复制代码

多端同步器.lua 文件源码:

1. --本代码是直接复制 打开一个websocket连接 ,修改IP和端口即可
   
2. local ws = nil
   
3. -- 服务器ip端口
   
4. address = '192.168.0.101:8000'
   
5. 
   
6. nodeTab = {
   
7. 应用市场={bounds={l=786,t=275,r=1032,b=533},class="android.widget.TextView",text="华为应用市场"},
   
8. 搜索={bounds={l=156,t=264,r=1008,b=384},class="android.widget.TextSwitcher",index="1",level="16"},
   
9. 输入框={bounds={l=276,t=96,r=851,b=216},class="android.widget.EditText",index="1",level="13"}
   
10. }
    
11. 
    
12. function findNode(class,click,findName)
    
13.     nodeLib.updateNode()
    
14.     -- 找节点
    
15.     local ret = nodeLib.findOne(class,true)
    
16.     if ret ~= nil then
    
17.         -- 找到点击
    
18.         print('找到节点了')
    
19.         if click then
    
20.             nodeLib.click(ret)
    
21.         end
    
22.         
    
23.     end
    
24.     sleep(2000)
    
25.     -- 找到写入文字
    
26.     if findName then
    
27.         
    
28.          local ret1 = nodeLib.findOne(nodeTab['输入框'],true)
    
29.          nodeLib.setText(ret1,findName)
    
30.         
    
31.     end
    
32.    
    
33. end
    
34. 
    
35. 
    
36. 
    
37. function json(str)
    
38.    
    
39.     return jsonLib.decode(splitStr(str,"消息:")[2])
    
40. end
    
41. 
    
42. function wLog(text)
    
43.     print(text)
    
44.     toast(text,0,0,12)
    
45.    
    
46. end
    
47. 
    
48. function onOpened(handle)
    
49.     ws = handle
    
50.     print("连接上服务器")
    
51.     --sendWebSocket(ws,'服务器1')
    
52.    
    
53. end
    
54. 
    
55. function reConnect()
    
56.     sleep(2000)
    
57.     wLog("断开连接，3秒后重连")
    
58.     setTimer(function()
    
59.         ws = nil
    
60.         startWebSocket(string.format("ws://%s",address),
    
61.         onOpened,onClosed,onError,onRecv)
    
62.     end,3000)
    
63. end
    
64. 
    
65. function onClosed(handle)
    
66.     reConnect()
    
67. end
    
68. 
    
69. function onError(handle)
    
70.     reConnect()
    
71. end
    
72. 
    
73. function onRecv(handle,message)
    
74.     print('服务器返回数据:',message)
    
75.     wLog(message)
    
76.     -- 可在这里实现对应操作
    
77.     local res = jsonLib.decode(message)
    
78.    
    
79.     if res['code']==200 then
    
80.         --print('执行点击懒人精灵')
    
81.         --tap(659,377)
    
82.         toast(res['data'],0,0,30)
    
83.         local count = 1
    
84.         -- 接收websocket 数据后 执行对应操作
    
85.         findNode(nodeTab['应用市场'],true)
    
86.         sleep(3000)
    
87.         findNode(nodeTab['搜索'],true,'抖音')
    
88.         
    
89.         
    
90.         --findNode(nodeTab[],click,findName)
    
91.         
    
92.         
    
93.         
    
94.     end
    
95. end
    
96. 
    
97. local handle = startWebSocket(string.format("ws://%s",address),
    
98. onOpened,onClosed,onError,onRecv)
    
99. 
    
100. 
     
101. 
     
102. 
     
103. 
     
104. 
     
105. if handle ~= nil then
     
106.    
     
107.     while true do
     
108.         --[===[local x=-1 y=-1
     
109.         ret,x,y = findPic(267,283,582,526,"雷电.png","101010",0,0.98)
     
110.         print(ret,x,y)
     
111.         if x >= 1 and y >= 1 and sendData ~= '准备' then
     
112.         sendWebSocket(ws,'服务器1&准备')
     
113.         sendData = '准备'
     
114.         end]===]
     
115.         sleep(1000)
     
116.     end
     
117.    
     
118.    
     
119. end

复制代码

运行结果图片:

感谢分享

66666666666666

谢谢大佬分享 !