https://tomono.tokyo/2021/03/26/9556/ :: websocket server のテスト
ここにあるとおりにしてインスト成功! 以下のコードをうごかして
android app :: websocket testerでやりとりできた
from websocket_server import WebsocketServer
import time
def start():
# クライアントが接続してきた時のイベント
def new_client(client, server):
print('New client {}:{} has joined.'.format(client['address'][0], client['address'][1]))
# クライアントへメッセージ送信
server.send_message(client, '接続成功!')
time.sleep(1)
# クライアントへメッセージ送信
server.send_message(client, '接続成功して1秒経ちました!')
time.sleep(1)
# クライアントへメッセージ送信
server.send_message(client, '接続成功して2秒経ちました!')
# クライアントが切断した時のイベント
def client_left(client, server):
print('Client {}:{} has left.'.format(client['address'][0], client['address'][1]))
# クライアントからのメッセージを受信した時のイベント
def message_received(client, server, message):
print(message)
# クライアントへメッセージ送信
server.send_message(client, message)
# 8000番ポートでサーバーを立ち上げる
server = WebsocketServer(port=8000, host='192.168.11.8')
# イベントで使うメソッドの設定
server.set_fn_new_client(new_client)
server.set_fn_client_left(client_left)
server.set_fn_message_received(message_received)
# 実行
server.run_forever()
if __name__ == "__main__":
start()
---------------------------------------------------------------
https://qiita.com/youtoy/items/9e1eeae728dc98f15679
(SERVER.MJS)
import { WebSocketServer } from 'ws';
const wss = new WebSocketServer({ port: 8080 });
wss.on('connection', function connection(ws) {
ws.on('error', console.error);
ws.on('message', function message(data) {
console.log('received: %s', data);
});
ws.send('something');
});
(APP.JS AS CLIENT)
const WebSocket = require('ws');
const socket = new WebSocket("ws://localhost:8080");
socket.addEventListener("open", (event) => {
socket.send("Hello Server!");
});
socket.addEventListener("message", (event) => {
console.log("Message from server ", event.data);
});
0 件のコメント:
コメントを投稿