高速公路 JS,如果 RPC 的被调用方是异步的怎么办?
autobahn JS, what if RPC's callee is async?
在 autobahnJS 的文档中提供了以下示例来说明如何设置远程过程调用 (RPC):
...
// 3) register a procedure for remoting
function add2(args) {
return args[0] + args[1];
}
session.register('com.myapp.add2', add2);
// 4) call a remote procedure
session.call('com.myapp.add2', [2, 3]).then(
function (res) {
console.log("Result:", res);
}
);
...
如果add2需要做一些异步操作怎么办?我的想法是,也许可以回调在客户端中注册的另一个远程函数,该函数触发了对 backend.add2 的初始调用。像这样:
...
//backend code
function add2(args) {
setTimeout(function() {
console.log("We are done here");
session.call('client.added', [123])
}, 1000);
return null; // useless, this value is never used
}
session.register('backend.add2', add2);
// client code
session.call('backend.add2', [2, 3]).then(
function (res) {
console.log("Result:", res);
}
);
...
你看到更好的选择了吗?这对我来说似乎有点麻烦。理想情况下,add2 会 return 一个承诺。但是我不确定这是否可以通过 RPC 实现?
您可以 return 一个承诺,然后在异步函数 returns 后解决。
来自 AutobahnJS API reference page:
function myAsyncFunction(args, kwargs, details) {
var d = new autobahn.when.defer();
setTimeout(function() {
d.resolve("async finished");
}, 1000);
return d.promise;
}
我注册异步函数的例子
session.register('com.forlunch.list_chats', function (args, kwargs, details) {
return functions.list_chats(args);
})
查询 mysql 数据库
async function list_chats(params){
var query = "SELECT * WHERE ... ;"
let res = await mysql_query(query)
return res
}
function mysql_query (query){
return new Promise(function(resolve, reject) {
const con = mysql.createConnection(mysql_options);
con.query(query,[], function (err, rows, fields) {
if (err) return reject(err);
resolve(rows);
});
})
}
在 autobahnJS 的文档中提供了以下示例来说明如何设置远程过程调用 (RPC):
...
// 3) register a procedure for remoting
function add2(args) {
return args[0] + args[1];
}
session.register('com.myapp.add2', add2);
// 4) call a remote procedure
session.call('com.myapp.add2', [2, 3]).then(
function (res) {
console.log("Result:", res);
}
);
...
如果add2需要做一些异步操作怎么办?我的想法是,也许可以回调在客户端中注册的另一个远程函数,该函数触发了对 backend.add2 的初始调用。像这样:
...
//backend code
function add2(args) {
setTimeout(function() {
console.log("We are done here");
session.call('client.added', [123])
}, 1000);
return null; // useless, this value is never used
}
session.register('backend.add2', add2);
// client code
session.call('backend.add2', [2, 3]).then(
function (res) {
console.log("Result:", res);
}
);
...
你看到更好的选择了吗?这对我来说似乎有点麻烦。理想情况下,add2 会 return 一个承诺。但是我不确定这是否可以通过 RPC 实现?
您可以 return 一个承诺,然后在异步函数 returns 后解决。
来自 AutobahnJS API reference page:
function myAsyncFunction(args, kwargs, details) {
var d = new autobahn.when.defer();
setTimeout(function() {
d.resolve("async finished");
}, 1000);
return d.promise;
}
我注册异步函数的例子
session.register('com.forlunch.list_chats', function (args, kwargs, details) {
return functions.list_chats(args);
})
查询 mysql 数据库
async function list_chats(params){
var query = "SELECT * WHERE ... ;"
let res = await mysql_query(query)
return res
}
function mysql_query (query){
return new Promise(function(resolve, reject) {
const con = mysql.createConnection(mysql_options);
con.query(query,[], function (err, rows, fields) {
if (err) return reject(err);
resolve(rows);
});
})
}