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;
		}

		// #ifdef MP-WEIXIN
		this.connection = wx.connectSocket({
			url: url,
			method: "get"
		})
		console.log("微信 WEIXIN");
		// #endif

		// #ifdef MP-ALIPAY
		this.connection = my.connectSocket({
			url: url,
			method: "get"
		})
		console.log("支付寶 ALIPAY");
		// #endif


		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("");

		//循環(huán)處理服務(wù)端信息
		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.`);
		}
	}
}

使用方法文章來源地址http://www.zghlxwxcb.cn/news/detail-595425.html

			var Hub = require("@/config/Signalr.js")
			let connection = new Hub.HubConnection();
			//注意：這里的apiHost不是wss或ws，是https或http
			connection.start(`https://15826q7q9.oicp.vip/ws`, {
				access_token: '如果有token則填寫'
			});

			connection.onOpen = res => {
				uni.showToast({
					content: '成功開啟連接'
				});
			}

			connection.on('system', (res) => {
				uni.showToast({
					content: res
				});
				console.log(res);
			});

			connection.on("receive", res => {
				uni.showToast({
					content: '消息' + res.msg
				});

			})

到了這里，關(guān)于uni app Signalr 支持 微信小程序和支付寶小程序的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！