serset
/
Sers


			
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226
							<!DOCTYPE html>

<html lang="zh-cn" xmlns="http://www.w3.org/1999/xhtml">
<head>
    <meta charset="utf-8" />
    <title>Sers-JsStation</title>

</head>
<body>
    <h2>Sers-JsStation</h2>
    <div>

        <textarea type="text" id="txt_log" rows="13" cols="200">
说明:
请在ServiceCenter配置文件中开启websocket通信，并修改对应的端口号和secretKey

</textarea><br />
        <input type="button" onclick="startService()" value="启动服务" />
        <input type="button" onclick="stopService()" value="关闭服务" />
        <input type="button" onclick="txt_log.value = ''" value="清空" /> <br />

        <table>
            <tr><td>appsettings：</td><td>api：</td><td>调用接口：<input type="button" onclick="callApi()" value="执行" /> </td></tr>
            <tr>
                <td>
<textarea type="text" id="txt_appsettings" rows="30" cols="40"></textarea>
                </td>
                <td>
                    <textarea type="text" id="txt_apiNodes" rows="30" cols="80">
[
    {
        route: '/JsStation/api', httpMethod: 'GET', name: 'call api in js server', description: 'js作为服务站点',
        onInvoke: function (requestData_bytes, rpcData_object, replyRpcData_object) {
            var request_string = vit.bytesToString(requestData_bytes);
            vit.logger.info('[api调用] request:' + request_string);

            var replyData = {
                success: true,
                data:
                {
                    request_string: request_string,
                    _: Math.random()
                }
            };
            return vit.objectSerializeToBytes(replyData);
        }
    }
]
</textarea>
                </td>
                <td>
                    <textarea type="text" id="txt_callApi" rows="30" cols="80">
serviceStation.apiClient.callApiAsync("/JsStation/api1", { name: 'sers' }, 'GET',
    function ({success,replyData_bytes,replyRpcData_object}) {
        if (!success) {
            vit.logger.info("接口调用失败！");
            return;
        }
        //var str = vit.bytesToString(replyData_bytes);
        //var apiRet = vit.bytesToObject(replyData_bytes);
        vit.logger.info("接口调用成功。 reply:" + vit.bytesToString(replyData_bytes));
    });


</textarea>
                </td>
            </tr>
        </table>


    </div>

    <script src="sers.ServiceStation.min.js"></script>
    <script>
        var serviceStation = new sers.ServiceStation();

        //------------------------------------------------------------------------
        //(x.1)appsettings.json
        var appsettings =
        {
            CL: {
                host: 'ws://' + (location.hostname || '127.0.0.1') + ':4503',
                secretKey: 'SersCL'
            },
            serviceStationInfo: {
                serviceStationName: 'JsStation',
                serviceStationKey: '',
                stationVersion: '',
                info: {}
            }
        };


        //------------------------------------------------------------------------
        //(x.2)event

        //(x.x.1)register logger.onmessage
        //type: info/error
        //e: pass error when type is error
        //function(message,type,e){ }
        vit.logger.onmessage = function (message, type, e) {
            if (e) message = message + '\n' + e.stack;

            console.log(message);
            txt_log.value = txt_log.value + '\n' + message;
            txt_log.scrollTop = txt_log.scrollHeight;
        };

        //(x.x.2)register localApiService.onError
        //(Error e,requestData_bytes,rpcData_object,replyRpcData_object)
        //localApiService.onError = (e,requestData_bytes,rpcData_object,replyRpcData_object)=>{ return {success:false}; }
        serviceStation.localApiService.onError = function (e, requestData_bytes, rpcData_object, replyRpcData_object) {
            vit.logger.error(e);
            var reply = {
                success: false,
                error: {
                    errorMessage: e.message,
                    errorDetail: { name: e.name, stack: e.stack }
                }
            };
            return reply;
        };

        //(x.x.3)register onDisconnected from serviceCenter
        serviceStation.org.event_onDisconnected = function () {
            vit.logger.info('[sers.CL]org.event_onDisconnected');
        };

        //------------------------------------------------------------------------
        //(x.3)api controller

        /*
            // apiInvoke  {route: '/JsStation/api', httpMethod: 'GET', name: 'call api in js server', description: 'js作为服务站点', onInvoke,onInvokeAsync}
            // onInvoke:   (requestData_bytes,rpcData_object,replyRpcData_object)=>{ return replyData_bytes; }	 //onInvoke 和 onInvokeAsync 指定其一即可
            // onInvokeAsync:   (requestData_bytes,rpcData_object,replyRpcData_object,onInvokeFinish)=>{ }
            //					onInvokeFinish :(replyData_bytes)=>{ }

            //demo:
            {
                route: '/JsStation/api', httpMethod: 'GET', name: 'call api in js server', description: 'js作为服务站点',
                    onInvoke: function (requestData_bytes, rpcData_object, replyRpcData_object) {
                        var request_string = vit.bytesToString(requestData_bytes);
                        vit.logger.info('[api调用] request:' + request_string);

                        var replyData = {
                            success: true,
                            data: {
                                request_string: request_string,
                                _: Math.random()
                            }
                        };
                        return vit.objectSerializeToBytes(replyData);
                    }
            }
        //*/

        //------------------------------------------------------------------------
        //(x.4)startService
        function startService() {
            try {
                appsettings = eval('(' + txt_appsettings.value + ')');
                var apiInvokeArray = eval('(' + txt_apiNodes.value + ')');


                vit.logger.info('');
                vit.logger.info('--------------------------------------------');

                //(x.1)load localApi
                vit.logger.info('[ApiLoader] load localApi...');
                serviceStation.localApiService.clearApiNodes();
                serviceStation.localApiService.addApiInvokeArray(apiInvokeArray);
                vit.logger.info('loaded localApi，count：' + apiInvokeArray.length);


                //(x.2)load configuration
                vit.logger.info('load configuration...');

                //设置websocket host 地址
                serviceStation.org.setHost(appsettings.CL.host);

                //连接秘钥，用以验证连接安全性。服务端和客户端必须一致
                serviceStation.org.secretKey = appsettings.CL.secretKey;

                serviceStation.serviceStationInfo = appsettings.serviceStationInfo;


                //(x.3)connect
                serviceStation.start();
            } catch (e) {
                vit.logger.error(e);
            }
        }

        function stopService() {
            try {
                vit.logger.info('');
                vit.logger.info('--------------------------------------------');
                vit.logger.info('断开连接...');
                serviceStation.stop();
                vit.logger.info('连接已断开');
            } catch (e) {
                vit.logger.error(e);
            }
        }

        function callApi() {
            try {
                vit.logger.info('');
                vit.logger.info('--------------------------------------------');
                vit.logger.info('调用接口...');

                eval(txt_callApi.value);
            } catch (e) {
                vit.logger.error(e);
            }
        }


        txt_appsettings.value = JSON.stringify(appsettings, null, 2);
    </script>
</body>
</html>