我刚接触autobahn的概念,我想学习如何将实时数据流从push api推送到网页中。
下面的代码给出了控制台中的实时输出流。我想把它显示在网页上。
var autobahn = require('autobahn');
var wsuri = "wss://api.poloniex.com";
var connection = new autobahn.Connection({
url: wsuri,
realm: "realm1"
});
connection.onopen = function (session) {
function marketEvent (args,kwargs) {
console.log(args);
}
session.subscribe('BTC_XMR', marketEvent);
function tickerEvent (args,kwargs) {
console.log(args);
}
function trollboxEvent (args,kwargs) {
console.log(args);
}
session.subscribe('ticker', tickerEvent);
session.subscribe('trollbox', trollboxEvent);
}
connection.onclose = function () {
console.log("Websocket connection closed");
}
connection.open();发布于 2017-05-28 17:13:17
也许node.js在这里不是最简单的解决方案。您可以通过Autobahn|JS http://crossbar.io/autobahn/的GitHub链接从git存储库下载autobahn.min.js。只需将该文件放入您的网站目录中,并按如下方式使用它
<!DOCTYPE html>
<html>
<head>
<script src="autobahn.min.js" ></script>
</head>
<div id="output"></div>
<script>
var connection = new autobahn.Connection({
url: 'wss://api.poloniex.com',
realm: 'realm1'
});
connection.onopen = function (session) {
function marketEvent (args,kwargs) {
console.log(args);
}
function tickerEvent (args,kwargs) {
console.log(args);
document.getElementById("output").innerHTML=args;
}
function trollboxEvent (args,kwargs) {
console.log(args);
}
session.subscribe('BTC_XMR', marketEvent);
session.subscribe('ticker', tickerEvent);
session.subscribe('trollbox', trollboxEvent);
}
connection.onclose = function () {
console.log("Websocket connection closed");
}
connection.open();
</script>
</html>https://stackoverflow.com/questions/44194031
复制相似问题