欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

autobahn的helloworld

程序员文章站 2022-07-14 15:52:44
...
python2.7.8可用,python2.6一样的代码就有问题

https://github.com/tavendo/AutobahnPython/

git clone https://github.com/tavendo/AutobahnPython.git

为了不污染python的系统环境
假设我的当前目录是
/data/mysocket/python/

virtualenv twisted
cd twisted/
source bin/activate
echo $VIRTUAL_ENV
echo $PATH
进入
python setup.py install

pip install zope.interface

yum install libffi-devel
yum install bzip2-devel

安装twisted 这里可能会报错
bz2模块找不到之类的
参考http://*.com/questions/8115280/importerror-no-module-named-bz2-for-python-2-7-2
先 把动态库copy到2.7的
cp /usr/lib64/python2.6/lib-dynload/bz2.so /data/mysocket/python/twisted/lib/python2.7/

pip install twisted

cd AutobahnPython\examples\twisted\websocket\echo>
python server.py


在windows中安装:
先安装virtualenv
http://wangxiaoxu.iteye.com/blog/1896624

https://pypi.python.org/pypi/virtualenv#downloads
下载
virtualenv-1.11.6.tar.gz
python setup.py install
在python/Scripts中多了virtualenv.exe
virtualevn twist
cd twist
Scripts/activate.bat
pip install zope.interface
pip install twisted

(twist) D:\pythonwork\AutobahnPython\examples\twisted\websocket\echo>python serv
er.py
2014-11-08 20:45:22+0800 [-] Log opened.
2014-11-08 20:45:22+0800 [-] WebSocketServerFactory starting on 9000
2014-11-08 20:45:22+0800 [-] Starting factory <autobahn.twisted.websocket.WebSoc
ketServerFactory instance at 0x0000000002BBF288>


然后打开
AutobahnPython/examples/twisted/websocket/echo/client.html
F12 查看helloworld吧


twisted入门
http://outofmemory.cn/code-snippet/4624/python-twisted-example#6762184-tsina-1-61743-3400cac556b7c64aaad138f696c2c997


广播的例子修改如下
(mysite)[root@broadcast broadcast]# cat server.py 
###############################################################################
##
##  Copyright (C) 2011-2013 Tavendo GmbH
##
##  Licensed under the Apache License, Version 2.0 (the "License");
##  you may not use this file except in compliance with the License.
##  You may obtain a copy of the License at
##
##      http://www.apache.org/licenses/LICENSE-2.0
##
##  Unless required by applicable law or agreed to in writing, software
##  distributed under the License is distributed on an "AS IS" BASIS,
##  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
##  See the License for the specific language governing permissions and
##  limitations under the License.
##
###############################################################################

import sys

from twisted.internet import reactor
from twisted.python import log
from twisted.web.server import Site
from twisted.web.static import File
import time
from autobahn.twisted.websocket import WebSocketServerFactory, \
                                       WebSocketServerProtocol, \
                                       listenWS


class BroadcastServerProtocol(WebSocketServerProtocol):

   def onOpen(self):
      self.factory.register(self)
      msg="open "+str(time.time())
      print msg
      self.sendMessage(msg.encode('utf8'))

   def onMessage(self, payload, isBinary):
      if not isBinary:
         #msg = "{} from {}".format(payload.decode('utf8'), self.peer)
         #self.factory.broadcast(msg)
         self.factory.broadcast(payload)

   def connectionLost(self, reason):
      WebSocketServerProtocol.connectionLost(self, reason)
      self.factory.unregister(self)


class BroadcastServerFactory(WebSocketServerFactory):
   """
   Simple broadcast server broadcasting any message it receives to all
   currently connected clients.
   """

   def __init__(self, url, debug = False, debugCodePaths = False):
      WebSocketServerFactory.__init__(self, url, debug = debug, debugCodePaths = debugCodePaths)
      self.clients = []
      #self.tickcount = 0
      #self.tick()

   def tick(self):
      self.tickcount += 1
      self.broadcast("tick %d from server" % self.tickcount)
      reactor.callLater(1, self.tick)

   def register(self, client):
      if not client in self.clients:
         print("registered client {}".format(client.peer))
         self.clients.append(client)

   def unregister(self, client):
      if client in self.clients:
         print("unregistered client {}".format(client.peer))
         self.clients.remove(client)

   def broadcast(self, msg):
      print("broadcasting message '{}' ..".format(msg))
      for c in self.clients:
         c.sendMessage(msg.encode('utf8'))
         print("message sent to {}".format(c.peer))


class BroadcastPreparedServerFactory(BroadcastServerFactory):
   """
   Functionally same as above, but optimized broadcast using
   prepareMessage and sendPreparedMessage.
   """

   def broadcast(self, msg):
      print("broadcasting prepared message '{}' ..".format(msg))
      preparedMsg = self.prepareMessage(msg)
      for c in self.clients:
         c.sendPreparedMessage(preparedMsg)
         print("prepared message sent to {}".format(c.peer))


if __name__ == '__main__':

   if len(sys.argv) > 1 and sys.argv[1] == 'debug':
      log.startLogging(sys.stdout)
      debug = True
   else:
      debug = False

   ServerFactory = BroadcastServerFactory
   #ServerFactory = BroadcastPreparedServerFactory

   factory = ServerFactory("ws://0.0.0.0:9000",
                           debug = debug,
                           debugCodePaths = debug)

   factory.protocol = BroadcastServerProtocol
   factory.setProtocolOptions(allowHixie76 = True)
   listenWS(factory)

   webdir = File(".")
   web = Site(webdir)
   reactor.listenTCP(8080, web)

   reactor.run()
(mysite)[root@broadcast broadcast]# 

客户端html
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<title>Insert title here</title>
</head>
<script type="text/javascript">
	String.prototype.startWith=function(s){
	  if(s==null||s==""||this.length==0||s.length>this.length)
	   return false;
	  if(this.substr(0,s.length)==s)
	     return true;
	  else
	     return false;
	  return true;
	 }
	Date.prototype.format = function(format) {
		var o = {
			"M+" : this.getMonth() + 1, //month
			"d+" : this.getDate(), //day
			"h+" : this.getHours(), //hour
			"m+" : this.getMinutes(), //minute
			"s+" : this.getSeconds(), //second
			"q+" : Math.floor((this.getMonth() + 3) / 3), //quarter
			"S" : this.getMilliseconds()
		}
		if (/(y+)/.test(format))
			format = format.replace(RegExp.$1, (this.getFullYear() + "")
					.substr(4 - RegExp.$1.length));
		for ( var k in o)
			if (new RegExp("(" + k + ")").test(format))
				format = format.replace(RegExp.$1, RegExp.$1.length == 1 ? o[k]
						: ("00" + o[k]).substr(("" + o[k]).length));
		return format;
	}
	var ws = null;
	function log(text) {
		/* document.getElementById("log").innerHTML = (new Date).getTime() + ": "
				+ text + "<br>" + document.getElementById("log").innerHTML; */
		document.getElementById("log").innerHTML = new Date().format('yyyy-MM-dd hh:mm:ss') + ","
		+ text + "<br>" + document.getElementById("log").innerHTML;
	}
	function enterSend(){
		if(event.keyCode == 13){
		    document.getElementById("sendbtn").click();
		}
	}
	function startServer() {
		
		var url = document.getElementById("serverip").value;// "ws://192.168.0.102:8887";  
		if ('WebSocket' in window) {
			ws = new WebSocket(url);
		} else if ('MozWebSocket' in window) {
			ws = new MozWebSocket(url);
		} else {
			log('浏览器不支持');
			return;
		}
		ws.onopen = function() {
			log('唷嘻,连上了');
		};
		// 收到服务器发送的文本消息, event.data表示文本内容  
		ws.onmessage = function(event) {
			var thisdata = event.data;
			if(thisdata.startWith("open")){
				//alert(thisdata);
				document.getElementById("username").value=thisdata.split(" ")[1];
			}else{
				//log(event.data);
				var showData=event.data.split(",");
				log(showData[0]+"说:"+showData[2]);
			}
		};
		ws.onclose = function() {
			log('Closed! 刷新页面尝试连接.');
		}
	}
	function sendMessage() {
		var textMessage = document.getElementById("textMessage").value;
		var username = document.getElementById("username").value;
		var toUser = document.getElementById("toUser").value;;
		if (ws != null && textMessage != "") {
			ws.send(username+","+toUser+","+textMessage);
		}
		document.getElementById("textMessage").value="";
	}
	function stopconn() {
		ws.close();
	}
</script>
<body onload="startServer()">
	 
	 <input id="serverip" type="text" size="20"
		value="ws://182.254.155.153:9000" />
	
	</br>
	您的Id:<input id="username" type="text"  readonly/></br>
	to Id:<input id="toUser" type="text"  /> 如果为空则群发</br> 
	<input id="textMessage" type="text" size="20" onkeydown="enterSend()"  style="border:1;width:400px"  />
	<input id="sendbtn" type="button" onclick="sendMessage()" value="Send">
	<div id="log"></div>
</body>
</html>

相关标签: python websocket