我正在构建一个实时 Web 应用程序。我希望能够从我的 python 应用程序的服务器端实现发送广播消息。
这是设置:
- 客户端的socketio.js
- TornadIO2服务器作为 Socket.IO 服务器
- 服务器端的python ( Django框架)
我可以成功地将 socket.io 消息从客户端发送到服务器。服务器处理这些并可以发送响应。在下文中,我将描述我是如何做到的。
当前设置和代码
首先,我们需要定义一个 Connection 来处理 socket.io 事件:
class BaseConnection(tornadio2.SocketConnection):
def on_message(self, message):
pass
# will be run if client uses socket.emit('connect', username)
@event
def connect(self, username):
# send answer to client which will be handled by socket.on('log', function)
self.emit('log', 'hello ' + username)
启动服务器由 Django 管理自定义方法完成:
class Command(BaseCommand):
args = ''
help = 'Starts the TornadIO2 server for handling socket.io connections'
def handle(self, *args, **kwargs):
autoreload.main(self.run, args, kwargs)
def run(self, *args, **kwargs):
port = settings.SOCKETIO_PORT
router = tornadio2.TornadioRouter(BaseConnection)
application = tornado.web.Application(
router.urls,
socket_io_port = port
)
print 'Starting socket.io server on port %s' % port
server = SocketServer(application)
很好,服务器现在运行。让我们添加客户端代码:
<script type="text/javascript">
var sio = io.connect('localhost:9000');
sio.on('connect', function(data) {
console.log('connected');
sio.emit('connect', '{{ user.username }}');
});
sio.on('log', function(data) {
console.log("log: " + data);
});
</script>
显然,{{ user.username }}
将替换为当前登录用户的用户名,在本例中用户名是“alp”。
现在,每次刷新页面时,控制台输出都是:
connected
log: hello alp
因此,调用消息和发送响应是有效的。但现在是棘手的部分。
问题
响应“hello alp”仅发送给 socket.io 消息的调用者。我想向所有连接的客户端广播一条消息,以便在新用户加入聚会时实时通知他们(例如在聊天应用程序中)。
所以,这是我的问题:
如何向所有连接的客户端发送广播消息?
如何向在特定频道上订阅的多个连接的客户端发送广播消息?
如何在我的 python 代码中的任何地方(
BaseConnection
课堂外)发送广播消息?这是否需要某种用于 python 的 Socket.IO 客户端,或者是 TornadIO2 内置的?
所有这些广播都应该以可靠的方式完成,所以我想 websockets 是最好的选择。但我对所有好的解决方案持开放态度。