````bash npm install @ym/rpc [--save] ````
npm install ym-rpcbash
npm install @ym/rpc [--save]
``
引入
----
``javascript
import RPC from '@ym/rpc'
/**
* service side
* when a client rpc connect,
* will add a rpc to global.rpcMap, use global.rpcMap
*/
RPC.install(server, {
users: {
name: {
appid: appid,
appsecret: appsecret
}
...
},
port: port // diffrent with process port, default 2001
});
/**
* client side
* when client side success connect to service side,
* will add a clientRpc param to global, use global.clientRpc
*/
RPC.register({
protocol: protocol, // http or https,default http
hostname: hostname, // default 127.0.0.1
port: port, // default 2001
appid: appid,
appsecret: appsecret
});
``
$3
``javascript
let rpc = global.rpcMap.get(username);
``
$3
``javascript
rpc.on(event, callback);
``
$3
``javascript
rpc.emit(event, data);
``
$3
``
rpc.route(event, data, callback);
``
EXAMPLE
``javascript
/ service side /
import express from 'express';
import http from 'http';
import RPC from '@ym/rpc';
const app = express();
const server = http.createServer(app);
RPC.install(server, {
users:{
xuezi: {
appid: 'xuezi',
appsecret: 123456
}
},
port: 2001
});
app.get('/rpc', function(req, res){
let rpc = global.rpcMap.get('xuezi');
rpc.route('pid', {}, function(data){
res.send(data);
});
});
server.listen(3000);
``
``javascript
/ client side /
import express from 'express';
import RPC from '@ym/rpc';
const app = express();
RPC.register( {
protocol: 'http',
hostname: '127.0.0.1',
port: 2001,
appid: 'xuezi',
appsecret: 123456
}).then(function(clientRpc){
clientRpc.on('pid', function(data){
let pid = process.pid;
clientRpc.emit('pid', {pid: pid});
});
app.listen(2000);
}).catch(e=>{
throw e;
});
``
route a stream
`javascript
// receive
rpc.stream(event, function(stream, data){
console.log(data);
stream.pipe(require('fs').createWriteStream(path));
});
// send
rpc.pipe(event, require('fs').createReadStream(path), data, callback);
``