
electron中实现一个websocket服务器接收python端发送的数据
electron中实现一个websocket服务器接收python端发送的数据
首先是electron端
const ws = require("ws");
const fs = require("fs")
const wss = new ws.Server({ port: 1234 });
wss.on('connection', (ws) => {
ws.on('message', (message) => {
console.log(`Received message: ${message}`)
try {
var data = JSON.parse(message);
if (data.type == "status") {
fs.writeFile('resources//status.json', message, (err) => {
if (err) throw err
})
} else if (data.type == "car_view") {
fs.writeFile('resources//car_view.json', message, (err) => {
if (err) throw err
})
} else {
fs.writeFile('resources//test.json', message, (err) => {
if (err) throw err
})
}
} catch (e) {
console.log('Error parsing JSON: ' + e.message);
}
})
})
这是一个使用 Node.js 实现的 WebSocket 服务器,监听端口 1234,并将接收到的消息序列化为 JSON 格式并发送回客户端。服务器使用 WebSocket 服务器模块 “ws” 和文件系统模块 “fs” 来写入接收到的消息到 JSON 文件中。
服务器在监听到新连接时,将新连接赋值给变量 “ws”。当接收到客户端发送的消息时,服务器使用 JSON.parse() 方法解析消息,然后将消息输出到控制台。如果消息类型为 “status”,服务器将消息写入 “resources/status.json” 文件中。如果消息类型为 “car_view”,服务器将消息写入 “resources/car_view.json” 文件中。否则,服务器将消息写入 “resources/test.json” 文件中。
然后使用python端发送数据
import websocket
import threading
import time
import json
# WebSocket服务器地址
websocket_server_url = "ws://127.0.0.1:1234"
# 打开连接
ws = websocket.WebSocket()
ws.connect(websocket_server_url)
# 开启线程定时发送消息
def send_message():
while True:
time.sleep(5) # 每5秒发送一次
data = {
"type": "status",
"carSpeed": 60,
"acceleration": 5,
"location": {
"x": "400px",
"y": "500px"
},
"trafficLight": "green",
"roadCondition": "slippery"
}
ws.send(json.dumps(data))
print(f"发送的消息: {data}")
threading.Thread(target=send_message).start()
# 保持连接
while True:
time.sleep(10)
这段代码是使用 Python 实现的 WebSocket 客户端,使用了 Python 的 socket 模块和 json 模块。
首先,通过 websocket.WebSocket() 方法创建了一个 WebSocket 对象 ws,并使用 ws.connect(websocket_server_url) 方法连接到了 WebSocket 服务器。
接着,通过 send_message() 方法实现了定时发送消息的功能,该方法使用一个无限循环来不断发送消息,每次发送时将消息序列化为 JSON 格式,并使用 ws.send() 方法发送出去。同时,通过打印消息来输出到控制台。
在主循环中,使用 time.sleep(10) 方法实现了长时间连接的效果。当长时间没有收到消息时,主线程将会退出。
更多推荐
所有评论(0)