|
|
web socket 接收器：webSocket.py
相关依赖
# pip install bottle gevent gevent-websocket argparse
from bottle import request, Bottle, abort
from geventwebsocket import WebSocketError
from gevent.pywsgi import WSGIServer
from flask import request
from geventwebsocket.handler import WebSocketHandler
from bottle import get, post, request
app
= Bottle()
users = {}
@app.
get('/websocket/<token>/<senduser>')
def handle_websocket(token,senduser):
wsock
= request.environ.get('wsgi.websocket')
users[token]
= wsock
if not wsock:
abort(
400, 'Expected WebSocket request.')
while True:
try:
message
= wsock.receive()
except WebSocketError:
breakif message:
try:
users[senduser].send(message)
except WebSocketError:
print u
'kill'
server
= WSGIServer(("0.0.0.0", 1019), app,handler_class=WebSocketHandler)
server.serve_forever()
服务端：logs.py
相关依赖：
pip install websocket-client
import subprocess
from websocket import create_connection
ws_server
= "ws://172.18.30.19:1010/websocket/<token>/<senduser>" ws
= create_connection(ws_server) command='sshpass -p 123456 ssh 192.168.20.200 -p 32776 -o StrictHostKeychecking=no "tail -f /root/tomcat-8.0/logs/catalina.out"' popen
=subprocess.Popen(command,stdout=subprocess.PIPE,stderr=subprocess.PIPE,shell=True)while True: line
=popen.stdout.readline().strip() ws.send(line)
应用前端：logs.html
<!DOCTYPE html>
<html>
<head>
<title>LOG+</title>
<style>
html, body {
font: normal 0.9em arial, helvetica;
}
#log {
width: 440px;
height: 200px;
border: 1px solid #7F9DB9;
overflow: auto;
}
#msg {
width: 330px;
}
</style>
<script>
var socket;
function init() {
var host = "ws://172.18.30.19:1010/websocket/<token>/<senduser>";
try {
socket = new WebSocket(host);
socket.onopen = function (msg) {
log('Connected');
};
socket.onmessage = function (msg) {
log(msg.data);
};
socket.onclose = function (msg) {
log("Lose Connection!");
};
socket.onerror = function(msg) {
log("websocket error!");
};
}
catch (ex) {
log(ex);
}
$(
"msg").focus();
}
function send() {
var txt, msg;
txt
= $("msg");
msg
= txt.value;
if (!msg) {
alert(
"Message can not be empty");
return;
}
txt.value
= "";
txt.focus();
try {
socket.send(msg);
}
catch (ex) {
log(ex);
}
}
window.onbeforeunload
= function () {
try {
socket.send(
'quit');
socket.close();
socket
= null;
}
catch (ex) {
log(ex);
}
};
function $(id) {
return document.getElementById(id);
}
function log(msg) {
$(
"log").innerHTML += "<br>" + msg;
}
function onkey(
event) {
if (event.keyCode == 13) {
send();
}
}
</script>
</head>
<body>
<h3>WebSocket</h3>
<br><br>
<div></div>
<input type="textbox" onkeypress="onkey(event)"/>
<button>
</body>
</html>
测试一把：
结束语：
前端 ——》 接收器 《—— 服务端
以需求用例为基，Case&Coding两条线并行，服务（M）&消费（VC）分离，单元、接口、功能、集成四层质量管理，自动化集成、测试、交付全程支持。 3个大阶段（需求分析阶段、研发准备阶段、研发测试阶段）16个小历程（*）确定好边界，明确好对接产物，做好服务管理。
在使用这段python代码之前，先在安装以下模块：
pip install gevent-websocket
pip install gevent
pip install bottle
- from bottle import request, Bottle, abort
- from geventwebsocket import WebSocketError
- from gevent.pywsgi import WSGIServer
- from geventwebsocket.handler import WebSocketHandler
- app = Bottle()
- users = set()
- @app.get('/websocket/')
- def handle_websocket():
- wsock = request.environ.get('wsgi.websocket')
- users.add(wsock)
- if not wsock:
- abort(400, 'Expected WebSocket request.')
- while True:
- try:
- message = wsock.receive()
- except WebSocketError:
- break
- print u"现有连接用户：%s" % (len(users))
- if message:
- for user in users:
- try:
- user.send(message)
- except WebSocketError:
- print u'某用户已断开连接'
- # 如果有客户端断开，则删除这个断开的websocket
- users.remove(wsock)
- server = WSGIServer(("0.0.0.0", 8000), app,handler_class=WebSocketHandler)
- server.serve_forever()
|
|
QQ群⑧：
窥视卡
雷达卡
发表于 2017-12-27 08:34:27
提升卡
置顶卡
沉默卡
喧嚣卡
变色卡
千斤顶
显身卡