fashilong.js 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264
  1. var server = require("http").createServer();
  2. const TLSSigAPIv2 = require('tls-sig-api-v2')
  3. const appids = require('./../config/appid')
  4. const api = new TLSSigAPIv2.Api(appids.fashilong.appid, appids.fashilong.key)
  5. const PORT = 3031
  6. const LEADER = 'leader'
  7. function getSig(userId) {
  8. return api.genSig(userId, 86400)
  9. }
  10. const EVENT = {
  11. someOneInRoom: 'someOneInRoom', // 有人进入房间
  12. someOneLeaveRoom: 'someOneLeaveRoom', // 有人离开房间
  13. startCall: 'startCall', // 开始通话
  14. stopCall: 'stopCall', // 结束通话
  15. webSyncAction: 'webSyncAction', // 通知h5的事件
  16. clientSyncAction: 'clientSyncAction', // 通知非H5的事件
  17. action: 'action', // 通知所有连接设备的事件
  18. roomClose: 'roomClose', // 房间已结束/房主已离开
  19. roomIn: 'roomIn', // 通知设备成功进入房间
  20. changeVoiceStatus: 'changeVoiceStatus', // 通知某设备语音状态
  21. changeOnlineStatus: 'changeOnlineStatus', // 通知某设备的在线状态
  22. roomPersonChange: 'roomPersonChange', // 房间人数变化事件
  23. changeRoomEnableTalk: 'changeRoomEnableTalk' // 改变房间是否可通话的配置
  24. }
  25. const CODEMAP = {
  26. 3001: '房间已被解散',
  27. 3002: '房主主动解散'
  28. }
  29. module.exports = class WebSocketServer {
  30. constructor() {
  31. this._pageMap = new Map();
  32. this._roomIDS = new Map();
  33. this._roomPerson = new Map()
  34. this._roomsConfig = {}
  35. }
  36. create() {
  37. this.io = require("socket.io")(server, {
  38. path: "/fsl-node",
  39. serveClient: false,
  40. // below are engine.IO options
  41. pingInterval: 10000,
  42. pingTimeout: 5000,
  43. cookie: false,
  44. });
  45. server.listen(PORT, { origins: "*" });
  46. this.io.on("connection", (socket) => {
  47. let user = socket.handshake.query
  48. const { roomId, userId, sceneNum, isClient, role, userLimitNum, roomType } = user
  49. const webRoomId = `${roomId}_${sceneNum}_web`
  50. const clientRoom = `${userId}${roomId}`
  51. // 加入客户端与H5单独的通讯房间
  52. socket.join(clientRoom, () => {})
  53. socket.on(EVENT.clientSyncAction, (data) => {
  54. console.log(data, 'clientSyncAction')
  55. socket.broadcast.to(clientRoom).emit(EVENT.clientSyncAction, data)
  56. })
  57. socket.on(EVENT.changeVoiceStatus, data => {
  58. let _roomPerson = this._roomPerson.get(roomId) || []
  59. user.voiceStatus = data.status
  60. _roomPerson.forEach(item => {
  61. if (item.userId === user.userId) {
  62. item.voiceStatus = user.voiceStatus
  63. }
  64. })
  65. this._roomPerson.set(roomId, _roomPerson)
  66. socket.broadcast.to(roomId).emit(EVENT.changeVoiceStatus, { roomsPerson: sortRoomUser(_roomPerson) })
  67. })
  68. // 房主,保存房间配置
  69. if (isClient && role === LEADER && !this._roomsConfig[roomId]) {
  70. console.log('in', user)
  71. this._roomsConfig[roomId] = {
  72. userLimitNum,
  73. enableTalk: user.enableTalk
  74. }
  75. }
  76. // 1v1保存房主
  77. if (roomType === '1v1' && !this._roomsConfig[roomId]) {
  78. console.log(roomType, roomId, user)
  79. this._roomsConfig[roomId] = {
  80. leaderId: userId
  81. }
  82. }
  83. socket.on(EVENT.changeRoomEnableTalk, data => {
  84. this._roomsConfig[roomId].enableTalk = data
  85. socket.broadcast.to(roomId).emit(EVENT.changeRoomEnableTalk, this._roomsConfig[roomId])
  86. })
  87. // 若有房间人数限制
  88. if (userLimitNum && this._roomPerson.get(roomId) && sortRoomUser(this._roomPerson.get(roomId)).length >= userLimitNum) {
  89. setTimeout(() => {
  90. socket.emit('roomInFail', { type: 'full', msg: '房间人数已满' })
  91. }, 1000)
  92. return this
  93. }
  94. let is1v1 = false
  95. if (this._roomsConfig[roomId]) {
  96. is1v1 = this._roomsConfig[roomId].leaderId === userId
  97. }
  98. console.log(this._roomsConfig[roomId], userId, !is1v1, user.role !== LEADER, (this._roomPerson.get(roomId) && !this._roomPerson.get(roomId).find(item => item.role === LEADER)))
  99. // 非房主进来房间,判断房间是否存在,以及房间内是否有房主,若无则通知房间已关闭
  100. if (!is1v1 && user.role !== LEADER && ((this._roomPerson.get(roomId) && !this._roomPerson.get(roomId).find(item => item.role === LEADER)) || (!this._roomPerson.get(roomId)))) {
  101. setTimeout(() => {
  102. socket.emit(EVENT.roomClose, { code: 3001, msg: CODEMAP[3001] })
  103. }, 1000)
  104. return this
  105. }
  106. // 加入所有连接数的通讯房间
  107. socket.join(roomId, () => {
  108. // 只有h5才能加入H5端的房间
  109. if (!isClient) {
  110. let roomsPerson = this._roomPerson.get(roomId) || []
  111. if (userId) {
  112. user.sig = getSig(userId)
  113. }
  114. let clientPerson = this._roomPerson.get(clientRoom) || []
  115. clientPerson.forEach(item => {
  116. if (item.userId === user.userId && item.avatar) {
  117. user.avatar = item.avatar
  118. user.voiceStatus = item.voiceStatus
  119. user.onlineStatus = item.onlineStatus
  120. user.nickname = decodeURIComponent(item.nickname)
  121. }
  122. })
  123. roomsPerson.push(user)
  124. this._roomPerson.set(roomId, roomsPerson)
  125. } else {
  126. // 通知客户端的房间配置
  127. let roomsPerson = this._roomPerson.get(roomId) || []
  128. socket.emit(EVENT.roomIn, { user, roomsPerson: sortRoomUser(roomsPerson), roomsConfig: this._roomsConfig[roomId] })
  129. }
  130. })
  131. let clientPerson = this._roomPerson.get(clientRoom) || []
  132. if (isClient) {
  133. clientPerson.push(user)
  134. this._roomPerson.set(clientRoom, clientPerson)
  135. }
  136. if (!isClient) {
  137. socket.join(webRoomId, () => {
  138. // let roomsPerson = this._roomPerson.get(roomId) || []
  139. // socket.broadcast.to(roomId).emit(EVENT.someOneInRoom, { user, roomsPerson: sortRoomUser(roomsPerson) })
  140. })
  141. }
  142. // 开始通话
  143. socket.on(EVENT.startCall, () => {
  144. if (!isClient) {
  145. let roomsPerson = this._roomPerson.get(roomId) || []
  146. // 返回h5房间内的信息
  147. socket.emit(EVENT.roomIn, { user, roomsPerson: sortRoomUser(roomsPerson), roomsConfig: this._roomsConfig[roomId] })
  148. // 判断是否某些情况断线重连
  149. if (!user.isInRoom) {
  150. socket.broadcast.to(roomId).emit(EVENT.someOneInRoom, { user, roomsPerson: sortRoomUser(roomsPerson) })
  151. }
  152. user.isInRoom = true
  153. updateRoomUser(roomsPerson, user)
  154. }
  155. })
  156. socket.on(EVENT.changeOnlineStatus, data => {
  157. user.onlineStatus = data.status
  158. let roomPerson = this._roomPerson.get(roomId)
  159. let __roomPerson = updateRoomUser(roomPerson, user)
  160. let actionName = user.onlineStatus ? 'inRoom' : 'leaveRoom'
  161. socket.broadcast.to(roomId).emit(EVENT.roomPersonChange, { roomsPerson: sortRoomUser(__roomPerson), actionName, user })
  162. })
  163. socket.on(EVENT.stopCall, () => {
  164. socket.leave(roomId)
  165. console.log(role, user, 'stopCall')
  166. if (role === LEADER) {
  167. socket.broadcast.to(roomId).emit(EVENT.roomClose, { code: 3002, msg: CODEMAP[3002] })
  168. delete this._roomsConfig[roomId]
  169. }
  170. let roomsPerson = this._roomPerson.get(roomId) || []
  171. roomsPerson = removeRoomUser(roomsPerson, user)
  172. this._roomPerson.set(roomId, roomsPerson)
  173. socket.broadcast.to(roomId).emit(EVENT.someOneLeaveRoom, { user, roomsPerson: sortRoomUser(roomsPerson) })
  174. user.isInRoom = false
  175. updateRoomUser(roomsPerson, user)
  176. })
  177. socket.on(EVENT.webSyncAction, (data) => {
  178. socket.broadcast.to(webRoomId).emit(EVENT.webSyncAction, data)
  179. })
  180. socket.on(EVENT.action, (data) => {
  181. socket.broadcast.to(roomId).emit(EVENT.action, data)
  182. })
  183. socket.on("disconnect", (reason) => {
  184. socket.leave(roomId)
  185. if (!isClient) {
  186. let roomsPerson = this._roomPerson.get(roomId) || []
  187. roomsPerson = removeRoomUser(roomsPerson, user)
  188. this._roomPerson.set(roomId, roomsPerson)
  189. // socket.broadcast.to(roomId).emit(EVENT.someOneLeaveRoom, { user, roomsPerson })
  190. socket.leave(webRoomId)
  191. socket.leave(roomId)
  192. }
  193. })
  194. socket.on('reconnect', () => {
  195. socket.join(roomId)
  196. if (!isClient) {
  197. let roomsPerson = this._roomPerson.get(roomId) || []
  198. roomsPerson.push(user)
  199. this._roomPerson.set(roomId, roomsPerson)
  200. socket.join(webRoomId)
  201. socket.join(roomId)
  202. }
  203. })
  204. socket.on("error", function(reason) {
  205. console.log("异常关闭", reason)
  206. })
  207. return this;
  208. })
  209. }
  210. close() {
  211. this.server.disconnect(true);
  212. }
  213. };
  214. function removeRoomUser(roomsPerson, user) {
  215. for (let i = 0; i < roomsPerson.length; i++) {
  216. if (roomsPerson[i].userId === user.userId) {
  217. roomsPerson.splice(i, 1)
  218. }
  219. }
  220. return roomsPerson
  221. }
  222. // 过滤房间内相同的人
  223. function sortRoomUser(roomsPerson) {
  224. if (!roomsPerson) return []
  225. const res = new Map()
  226. return roomsPerson.filter((a) => !res.has(a.userId) && res.set(a.userId, 1))
  227. }
  228. function updateRoomUser(roomsPerson, user) {
  229. if (!roomsPerson) return []
  230. roomsPerson.forEach(item => {
  231. if (item.userId === user.userId) {
  232. item = Object.assign(item, user)
  233. }
  234. })
  235. return roomsPerson
  236. }