我正在尝试构建一个利用 Phantomjs 1.7（模拟浏览器）的应用程序并创建一个 Python 后端来触发一些事件并收集数据。
问题是 Phantomjs 和我的 Python 程序这两个进程需要双向通信。问题是在里面page.evaluate我不能：
- 传递任何复杂的对象，例如“fs”（从标准输入读取）
- 创建一个 WebSocket 以连接到我的 Python 脚本
- 任何其他形式的进程间通信都受到限制
所以我的解决方案很简单：
- 将 socket.io js 注入我正在查看的页面。
- 连接到我使用 gevent-socketio 实现的 python 服务器
当我尝试从 page.evaluate 内部连接时，我得到：
Unexpected response code: 404
这是 Phantomjs 脚本：
var page = require("webpage").create();
page.onAlert = function(msg) { console.log("alert>>>" + msg); };
page.onConsoleMessage= function(msg) { console.log(msg); };
page.open("http://google.com", function() {
page.injectJs("socket.io.js");
page.evaluate(function() {
var socket = new io.Socket();
socket.connect('localhost:5051/test');
socket.on('connect',function() {
console.log('Client has connected to the server!');
});
// Add a connect listener
socket.on('signal',function(data) {
console.log('Received a signal: ',data);
});
// Add a disconnect listener
socket.on('disconnect',function() {
console.log('The client has disconnected!');
});
// Sends a message to the server via sockets
socket.send("kakalq");
});
//phantom.exit();
});
这是服务器端 Python 脚本：
from socketio import socketio_manage
from socketio.server import SocketIOServer
from socketio.namespace import BaseNamespace
class MyNs(BaseNamespace):
def initialize(self):
print "connected"
self.emit('connect')
def disconnect(self, *args, **kwargs):
print "diconnecting"
super(MyNs, self).disconnect(*args, **kwargs)
def signal(self, message):
print "received signal", message
self.emit("okay", "this will be sent to js")
def start(environ, start_response):
if environ['PATH_INFO'].startswith('/test'):
return socketio_manage(environ, { '/test': MyNs })
if __name__ == "__main__":
server = SocketIOServer( ('', 5051), start,policy_server=False )
server.serve_forever()