小程序使用websocket远程连接蓝牙设备

公司最近想做一个这样的需求: A手机连接蓝牙设备, 分享给B手机, 让B手机可以间接的去操作A手机的蓝牙设备
实现思路:

image.png

• 在实现思路的基础上, 我们需要获取到用户信息, 如何获取?
  调用接口获取登录凭证（code）。通过凭证进而换取用户登录态信息，包括用户在当前小程序的唯一标识（openid）、微信开放平台帐号下的唯一标识（unionid，若当前小程序已绑定到微信开放平台帐号）及本次登录的会话密钥（session_key）等

uni.login({
  success (res) {
    if (res.code) {
      // 拿到code
    }
  }
})

• 后台调用接口, 登录凭证校验。通过 uni.login 接口获得临时登录凭证 code 后传到开发者服务器调用此接口完成登录流程。

GET https://api.weixin.qq.com/sns/jscode2session?appid=APPID&secret=SECRET&js_code=JSCODE&grant_type=authorization_code

image.png

这时候我们已经拿到用户的信息和id了 , 我们知道普遍的发消息是一个用户与另一个用户发消息, 我们需要id来判断谁与谁发消息
定义发消息人为formId, 被发消息人为 toId, 发消息的内容为message

好了,现在我们来连接websocket, 我写在vuex中, 方便全局

    mutations: {
        // 连接websocket
        WEBSOCKET_INIT(state) {
            let url = state.socketUrl + `/${state.identity.userId}`;
            state.socketTask = uni.connectSocket({
                url: url,
                success(data) {
                    console.log("websocket连接成功", data)
                }
            });
            
            // 消息的发送和接收必须在正常连接, 才能发送或接收
            state.socketTask.onOpen(res => {
                console.log('连接打开');
            })

            // 服务器返回内容的监听
            state.socketTask.onMessage(msg => {
                console.log('收到服务器内容', msg.data);
                state.socketMessage = JSON.parse(msg.data);
                console.log(state.socketMessage)
            })

            // 关闭连接
            state.socketTask.onClose(() => {
                console.log('onClose');
                //一旦关闭连接
                this.commit('WEBSOCKET_INIT')
            })
            state.socketTask.onError(() => {
                console.log('onError')
            })

        },

        // 发送信息
        WEBSOCKET_SEND(state, p) {
            state.socketTask && state.socketTask.send && state.socketTask.send({
                data: JSON.stringify(p),
                success: (res) => {
                    console.log('发送成功', res)
                }
            });
        },
    },

    actions: {
        WEBSOCKET_INIT({
            commit
        }) {
            commit('WEBSOCKET_INIT')
        },

        WEBSOCKET_SEND({
            commit
        }, p) {
            commit('WEBSOCKET_SEND', p)
        }
    }

• B给A发送消息

            // B给A发送指令
            onSendB() {
                let param = {
                    "fromId": this.identity.userId, // 发送人
                    "toId": this.userId, // 接收人
                    'message': `A1 08 01 00 00 00 64 1E 00 32 61 55` // 信息
                }
                this.$store.commit('WEBSOCKET_SEND', param)
            }

• 使用计算属性&监听器监听服务器返回的内容

        computed: {
            ...mapState({
                socketMessage(state) {
                    if(state.socketMessage){
                        console.log(state.socketMessage);
                                                // 内容更新 调用
                        this.onSendCommand(state.socketMessage);
                    }
                        
                    return state.socketMessage
                }
            })
        },

• A接收到B发送的指令, 操作蓝牙设备

            // 发送指令
            onSendCommand(msg) {
                console.log(msg, '获取到的指令');
                var message;
                    message = 'A1 08 01 00 00 00 64 1E 00 32 61 55'
                
                let that = this;
                // 一个马达震动指令
                let data = message.split(' ');
                var buf = new ArrayBuffer(data.length);
                let dataView = new DataView(buf);
                for (let i = 0; i < data.length; i++) {
                    dataView.setUint8(i, '0x' + data[i]);
                }
                // 向低功耗蓝牙设备特征值中写入二进制数据
                uni.writeBLECharacteristicValue({
                    deviceId: that.deviceId, // 设备id
                    serviceId: that.serviceId,
                    characteristicId: that.characteristicId,
                    value: buf,
                    success(res) {
                        console.log(res, '发送指令成功');
                        uni.showToast({
                            title: "发送成功",
                            icon: 'none'
                        })
                    },
                    fail(res) {
                        console.log('发送指令失败', res);
                    }
                })
            },

大概思路就是这样
完整代码加我vx: 19979611308