公司最近想做一个这样的需求: 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
