django and comet

shengyan@shengyan-desktop:~$ cat /etc/orbited.cfg
# Example Orbited Configuration file

[global]
reactor=select
# reactor=kqueue
# reactor=epoll
#session.ping_interval = 40
session.ping_interval = 300     # 服务器ping客户端时间间隔, 300秒
session.ping_timeout = 30
# once the sockets are open, orbited will drop its privileges to this user.
user=orbited

[listen]
#http://:8000
http://:9000           # 监听http协议的9000端口
stomp://:61613         # 监听stomp协议的61613端口
# uncomment to enable SSL on port 8043 using given .key and .crt files
#https://:8043
#
#[ssl]
#key=orbited.key
#crt=orbited.crt

[static]
prdt=product.htm     # 相当于别名. 无关痛痒的个设置

[access]
#localhost:8000 -> irc.freenode.net:6667
#* -> localhost:4747
* -> localhost:61613    # 访问设置.

[logging]
debug=STDERR,debug.log
info=STDERR,info.log
access=STDERR,info.log
warn=STDERR,error.log
error=STDERR,error.log

#Don't enable debug by default
enabled.default=info,access,warn,error

# Turn debug on for the "Proxy" logger
[loggers]
#Proxy=debug,info,access,warn,error

#!/usr/bin/python
# relay.py
# http://cometdaily.com/2008/10/10/scalable-real-time-web-architecture-part-2-a-live-graph-with-orbited-morbidq-and-jsio/ & http://anirudhsanjeev.org/tutorialhow-to-django-comet-orbited-stomp-morbidq-jsio/

from stompservice import StompClientFactory
from twisted.internet import reactor
from twisted.internet.task import LoopingCall
from random import random
from orbited import json
from SimpleXMLRPCServer import *

from threading import Thread
import stompservice
from settings import RPC_HOSTNAME as HOSTNAME, RPC_PORT as PORT, STOMP_PORT  # 主机名和端口号需要一致

INTERVAL = 1000# in ms

class DataProducer(StompClientFactory):
    def recv_connected(self, msg):

        print 'Connected; producing data'
        self.timer = LoopingCall(self.test_data)
        self.timer.start(INTERVAL/1000.0)

    def send_data(self, channel, data):
        print "Transmitting: %s bytes" % len(data)
        #self.send(channel, data.encode("utf8"))
        self.send(channel, json.encode(data))

    def test_data(self):
        pass

orbited_proxy = DataProducer()

class RPCServer(Thread):
    def __init__(self, orbited):
        self.orbited = orbited
        Thread.__init__(self)
    def run(self):
        class RequestHandler(SimpleXMLRPCRequestHandler):
            rpc_paths = ('/RPC2',)
        #create a server
        server = SimpleXMLRPCServer((HOSTNAME,PORT),
                                    requestHandler = RequestHandler)

        server.register_introspection_functions()
        def transmit_orbited(channel, message):
            """
            @param channel: The stomp channel to send to
            @param message: The message that needs to be transmitted
            """
            self.orbited.send_data(channel, message)
            return ""

        server.register_function(transmit_orbited, 'transmit')
        server.serve_forever()

if __name__ == "__main__":
        rpcthread = RPCServer(orbited_proxy)
        rpcthread.start()

        reactor.connectTCP(HOSTNAME, STOMP_PORT, orbited_proxy)
        reactor.run()


#python relay.py 启动它.

def _prdt(dnid='--',):
    """
    handle an XMLHttpRequest
    """
    import xmlrpclib
    proxy = xmlrpclib.ServerProxy("http://%s:%s" % (settings.RPC_HOSTNAME, settings.RPC_PORT))
    msg = {}
    msg['dnid'] = dnid
    #...
    proxy.transmit("/topic/prdt", msg)  # 这个路径和js中订阅的路径一致

<script src="/site_media/js/jquery-1.2.6.js" type="text/javascript"></script>
<script src="/static/Orbited.js" type="text/javascript"></script>
<script src="/static/protocols/stomp/stomp.js" type="text/javascript"></script>
<script type="text/javascript">
    document.domain = document.domain;
    OrbitedHost = "localhost";  // 主机名
    Orbited.settings.port = 9000;  // Orbited端口
    Orbited.settings.hostname = OrbitedHost;
    TCPSocket = Orbited.TCPSocket;
    StompPort = 61613;    // STOMP端口, 这两个端口设置是和orbited配置中一致
</script>