【报Bug】uniapp引入@microsoft/signalr 自定义制作基座 编译APP端 报错

解决方案 小程序 -- APP 通用

const protocal = {
protocol: "json",
version: 1
};

const MessageType = {
/ Indicates the message is an Invocation message and implements the {@link InvocationMessage} interface. */
Invocation: 1,
/* Indicates the message is a StreamItem message and implements the {@link StreamItemMessage} interface. /
StreamItem: 2,
/ Indicates the message is a Completion message and implements the {@link CompletionMessage} interface. */
Completion: 3,
/ Indicates the message is a Stream Invocation message and implements the {@link StreamInvocationMessage} interface. */
StreamInvocation: 4,
/* Indicates the message is a Cancel Invocation message and implements the {@link CancelInvocationMessage} interface. /
CancelInvocation: 5,
/ Indicates the message is a Ping message and implements the {@link PingMessage} interface. */
Ping: 6,
/* Indicates the message is a Close message and implements the {@link CloseMessage} interface. /
Close: 7,
}

export class HubConnection {

constructor() {
this.openStatus = false;
this.methods = {};
this.negotiateResponse = {};
this.connection = {};
this.url = "";
this.invocationId = 0;
this.callbacks = {};
}

start(url, queryString) {
var negotiateUrl = url + "/negotiate";
if (queryString) {
for (var query in queryString) {
negotiateUrl += (negotiateUrl.indexOf("?") < 0 ? "?" : "&") + (${query}= + encodeURIComponent(queryString[query]));
}
}
uni.request({
url: negotiateUrl,
method: "post",
async: false,
success: res => {
this.negotiateResponse = res.data;
this.startSocket(negotiateUrl.replace("/negotiate", ""));
},
fail: res => {
console.error(requrst ${url} error : ${res});
return;
}
});

}

startSocket(url) {
url += (url.indexOf("?") < 0 ? "?" : "&") + ("id=" + this.negotiateResponse.connectionId);
url = url.replace(/^http/, "ws");
this.url = url;
if (this.connection != null && this.openStatus) {
return;
}

this.connection = uni.connectSocket({  
  url: url,  
  method: "get",  
  success:()=>{}  
})  

this.connection.onOpen(res => {  
  console.log(`websocket connectioned to ${this.url}`);  
  this.sendData(protocal);  
  this.openStatus = true;  
  this.onOpen(res);  
});  

this.connection.onClose(res => {  
  console.log(`websocket disconnection`);  
  this.connection = null;  
  this.openStatus = false;  
  this.onClose(res);  
});  

this.connection.onError(res => {  
  console.error(`websocket error msg: ${msg}`);  
  this.close({  
    reason: msg  
  });  
  this.onError(res)  
});  

this.connection.onMessage(res => this.receive(res));  

}

on(method, fun) {

let methodName = method.toLowerCase();  
if (this.methods[methodName]) {  
  this.methods[methodName].push(fun);  
} else {  
  this.methods[methodName] = [fun];  

}  

}

onOpen(data) { }

onClose(msg) {

}

onError(msg) {

}

close(data) {
if (data) {
this.connection.close(data);
} else {
this.connection.close();
}

this.openStatus = false;  

}

sendData(data, success, fail, complete) {
this.connection.send({
data: JSON.stringify(data) + "", //
success: success,
fail: fail,
complete: complete
});
}

receive(data) {
if (data.data.length > 3) {
data.data = data.data.replace('{}', "")
}

var messageDataList = data.data.split("");  

//循环处理服务端信息  
for (let serverMsg of messageDataList) {  
  if (serverMsg) {  
    var messageData = serverMsg.replace(new RegExp("", "gm"), "")  
    var message = JSON.parse(messageData);  

    switch (message.type) {  
      case MessageType.Invocation:  
        this.invokeClientMethod(message);  
        break;  
      case MessageType.StreamItem:  
        break;  
      case MessageType.Completion:  
        var callback = this.callbacks[message.invocationId];  
        if (callback != null) {  
          delete this.callbacks[message.invocationId];  
          callback(message);  
        }  
        break;  
      case MessageType.Ping:  
        // Don't care about pings  
        break;  
      case MessageType.Close:  
        console.log("Close message received from server.");  
        this.close({  
          reason: "Server returned an error on close"  
        });  
        break;  
      default:  
        console.warn("Invalid message type: " + message.type);  
    }  
  }  
}  

}

send(functionName) {

var args = [];  
for (var _i = 1; _i < arguments.length; _i++) {  
  args[_i - 1] = arguments[_i];  
}  

this.sendData({  
  target: functionName,  
  arguments: args,  
  type: MessageType.Invocation,  
  invocationId: this.invocationId.toString()  
});  
this.invocationId++;  

}

invoke(functionName) {
var args = [];
for (var _i = 1; _i < arguments.length; _i++) {
args[_i - 1] = arguments[_i];
}

var _this = this;  
var id = this.invocationId;  
var p = new Promise(function (resolve, reject) {  

  _this.callbacks[id] = function (message) {  
    if (message.error) {  
      reject(new Error(message.error));  
    } else {  
      resolve(message.result);  
    }  
  }  

  _this.sendData({  
    target: functionName,  
    arguments: args,  
    type: MessageType.Invocation,  
    invocationId: _this.invocationId.toString()  
  }, null, function (e) {  
    reject(e);  
  });  

});  
this.invocationId++;  
return p;  

}

invokeClientMethod(message) {
var methods = this.methods[message.target.toLowerCase()];
if (methods) {
methods.forEach(m => m.apply(this, message.arguments));
if (message.invocationId) {
// This is not supported in v1. So we return an error to avoid blocking the server waiting for the response.
var errormsg = "Server requested a response, which is not supported in this version of the client.";
console.error(errormsg);
this.close({
reason: errormsg
});
}
} else {
console.warn(No client method with the name '${message.target}' found.);
}
}
}

你这nvue也用signalr，windows啥的元素在APP端没用的

本人已解决 重新signalr js

解释上面 的方案 针对引入js 是@aspnet/signalr 别下载错了