ASP.NET Core在支付宝小程序中使用signalR

迷南。 2021-10-23 18:52 364阅读 0赞

Github有一个经过重写的微信小程序SignalR的js类库

[https://github.com/liangshiw/SignalRMiniProgram-Client][https_github.com_liangshiw_SignalRMiniProgram-Client]

于是我把他改成支付宝小程序的版本，上面这个项目的核心代码基本没有变，只是小程序开放接口改了一下，在支付宝小程序就能跑起来了

把下面的js代码复制到你的支付宝小程序即可（**使用方法在下面**）：

【代码】

1 const protocal = {
      2   protocol: "json",
      3   version: 1
      4 };
      5 
      6 const MessageType = {
      7   /** Indicates the message is an Invocation message and implements the {@link InvocationMessage} interface. */
      8   Invocation: 1,
      9   /** Indicates the message is a StreamItem message and implements the {@link StreamItemMessage} interface. */
     10   StreamItem: 2,
     11   /** Indicates the message is a Completion message and implements the {@link CompletionMessage} interface. */
     12   Completion: 3,
     13   /** Indicates the message is a Stream Invocation message and implements the {@link StreamInvocationMessage} interface. */
     14   StreamInvocation: 4,
     15   /** Indicates the message is a Cancel Invocation message and implements the {@link CancelInvocationMessage} interface. */
     16   CancelInvocation: 5,
     17   /** Indicates the message is a Ping message and implements the {@link PingMessage} interface. */
     18   Ping: 6,
     19   /** Indicates the message is a Close message and implements the {@link CloseMessage} interface. */
     20   Close: 7,
     21 }
     22 
     23 
     24 export class HubConnection {
     25 
     26   constructor() {
     27     this.openStatus = false;
     28     this.methods = {};
     29     this.negotiateResponse = {};
     30     this.url = "";
     31     this.invocationId = 0;
     32     this.callbacks = {};
     33   }
     34 
     35   start(url, queryString) {
     36     var negotiateUrl = url + "/negotiate";
     37     if (queryString) {
     38       for (var query in queryString) {
     39         negotiateUrl += (negotiateUrl.indexOf("?") < 0 ? "?" : "&") + (`${query}=` + encodeURIComponent(queryString[query]));
     40       }
     41     }
     42     my.request({
     43       url: negotiateUrl,
     44       method: "POST",
     45       success: (res) => {
     46         this.negotiateResponse = res.data;
     47         this.startSocket(negotiateUrl.replace("/negotiate", ""));
     48       },
     49       fail: (res) => {
     50         console.error(`requrst ${url} error : ${res}`);
     51       }
     52     });
     53   }
     54 
     55   startSocket(url) {
     56     url += (url.indexOf("?") < 0 ? "?" : "&") + ("id=" + this.negotiateResponse.connectionId);
     57     url = url.replace(/^http/, "ws");
     58     this.url = url;
     59     if (this.openStatus) {
     60       return;
     61     }
     62 
     63     console.log(url);
     64 
     65     my.connectSocket({
     66       url: url
     67     })
     68 
     69     my.onSocketOpen(res => {
     70       console.log(`websocket connectioned to ${
        this.url}`);
     71       this.sendData(protocal);
     72       this.openStatus = true;
     73       this.onOpen(res);
     74     });
     75 
     76     my.onSocketClose(res => {
     77       console.log(`websocket disconnection`);
     78       this.openStatus = false;
     79       this.onClose(res);
     80     });
     81 
     82     my.onSocketError(res => {
     83       console.error(`websocket error msg: ${res}`);
     84       this.close({
     85         reason: res
     86       });
     87       this.onError(res)
     88     });
     89 
     90     my.onSocketMessage(res => this.receive(res));
     91   }
     92 
     93   on(method, fun) {
     94 
     95     let methodName = method.toLowerCase();
     96     if (this.methods[methodName]) {
     97       this.methods[methodName].push(fun);
     98     } else {
     99       this.methods[methodName] = [fun];
    100     }
    101   }
    102 
    103   onOpen(data) { }
    104 
    105   onClose(msg) { }
    106 
    107   onError(msg) { }
    108 
    109   close(data) {
    110     if (data) {
    111       console.error('closed socket: ' + data.reason);
    112     }
    113 
    114     my.closeSocket();
    115 
    116     this.openStatus = false;
    117   }
    118 
    119   sendData(data, success, fail, complete) {
    120     my.sendSocketMessage({
    121       data: JSON.stringify(data) + "", //
    122       success: success,
    123       fail: fail,
    124       complete: complete
    125     });
    126   }
    127 
    128 
    129   receive(data) {
    130     if (data.data.length > 3) {
    131       data.data = data.data.replace('{}', "")
    132     }
    133 
    134     var messageDataList = data.data.split("");
    135 
    136     //循环处理服务端信息
    137     for (let serverMsg of messageDataList) {
    138       if (serverMsg) {
    139         var messageData = serverMsg.replace(new RegExp("", "gm"), "")
    140         var message = JSON.parse(messageData);
    141 
    142         switch (message.type) {
    143           case MessageType.Invocation:
    144             this.invokeClientMethod(message);
    145             break;
    146           case MessageType.StreamItem:
    147             break;
    148           case MessageType.Completion:
    149             var callback = this.callbacks[message.invocationId];
    150             if (callback != null) {
    151               delete this.callbacks[message.invocationId];
    152               callback(message);
    153             }
    154             break;
    155           case MessageType.Ping:
    156             // Don't care about pings
    157             break;
    158           case MessageType.Close:
    159             console.log("Close message received from server.");
    160             this.close({
    161               reason: "Server returned an error on close"
    162             });
    163             break;
    164           default:
    165             console.warn("Invalid message type: " + message.type);
    166         }
    167       }
    168     }
    169   }
    170 
    171   send(functionName) {
    172     var args = [];
    173     for (var _i = 1; _i < arguments.length; _i++) {
    174       args[_i - 1] = arguments[_i];
    175     }
    176 
    177     this.sendData({
    178       target: functionName,
    179       arguments: args,
    180       type: MessageType.Invocation,
    181       invocationId: this.invocationId.toString()
    182     });
    183     this.invocationId++;
    184   }
    185 
    186   invoke(functionName) {
    187     var args = [];
    188     for (var _i = 1; _i < arguments.length; _i++) {
    189       args[_i - 1] = arguments[_i];
    190     }
    191 
    192     var _this = this;
    193     var id = this.invocationId;
    194     var p = new Promise(function(resolve, reject) {
    195 
    196       _this.callbacks[id] = function(message) {
    197         if (message.error) {
    198           reject(new Error(message.error));
    199         } else {
    200           resolve(message.result);
    201         }
    202       }
    203 
    204       _this.sendData({
    205         target: functionName,
    206         arguments: args,
    207         type: MessageType.Invocation,
    208         invocationId: _this.invocationId.toString()
    209       }, null, function(e) {
    210         reject(e);
    211       });
    212 
    213     });
    214     this.invocationId++;
    215     return p;
    216   }
    217 
    218   invokeClientMethod(message) {
    219     var methods = this.methods[message.target.toLowerCase()];
    220     if (methods) {
    221       methods.forEach(m => m.apply(this, message.arguments));
    222       if (message.invocationId) {
    223         // This is not supported in v1. So we return an error to avoid blocking the server waiting for the response.
    224         var errormsg = "Server requested a response, which is not supported in this version of the client.";
    225         console.error(errormsg);
    226         this.close({
    227           reason: errormsg
    228         });
    229       }
    230     } else {
    231       console.warn(`No client method with the name '${message.target}' found.`);
    232     }
    233   }
    234 }

【使用方法】

转载于:https://www.cnblogs.com/myhalo/p/11191988.html

[https_github.com_liangshiw_SignalRMiniProgram-Client]: https://github.com/liangshiw/SignalRMiniProgram-Client