feats

config/dev.js

   defineConstants: {
     HOST: '"https://xlk.njyz.tech"',
     // HOST: '"http://127.0.0.1:8081"',
-    WSS_HOST: '"ws://xlk.njyz.tech"',
+    WSS_HOST: '"wss://xlk.njyz.tech"',
     OSS_PATH: '"https://xlk-assets.oss-accelerate.aliyuncs.com/"',
     OSS_FAST_PATH: '"https://xlk-assets.oss-accelerate.aliyuncs.com/"',
     ICON_FONT: '"https://yz-websit.oss-cn-hangzhou.aliyuncs.com/xlk/css/iconfont.ttf"',

src/pages/chat/chatDetail/index.jsx

 import { API_QUERY_USERINFO_BYID } from '@/constants/api'
 import { ROLE_CODE } from '@/constants/user'
 import { uploadFiles, fetch } from '@/utils/request'
-import { queryChatHistory } from '@/services/chat'
+import { queryChatHistory, setMessageReaded } from '@/services/chat'
 import im from '@/utils/im'
 import { getDateForHumans } from '@/utils/chatDate'
 import '@/assets/css/iconfont.css'
         setReceiver(res)
         getChatHistory({ pageNumber: 1 })
       })
-
-      const unsubsribe = im.listen((message) => {
-
-      })
     } else {
       Taro.showToast({
         title: '无聊天对象，请退出重试',
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, [friend])
 
+  useEffect(() => {
+    return im.listen((message) => {
+      const receiveData = JSON.parse(message)
+      setPageList(PageList.concat(receiveData))
+      // 滚动到底部
+      scroll()
+      // 更新记录为已读
+      setMessageReaded(receiveData.chatId)
+    })
+  }, [PageList, scroll])
+
   return (
     <view className='chatDetail flex-v'>
       <view className='flex-item'>

src/utils/im/listeners.js

 
 export default () => {
-  const listeners = []
+  let listeners = []
 
   function getIndex(name) {
     for (let i = 0; i < listeners.length; i += 1) {
     listeners = listeners.filter((f) => f.name !== name)
   }
 
-  function append(name, fun) {
+  function append(fun, name) {
+    if (!name) {
+      name = Math.random().toString(36).substring(2)
+    }
+
     const pos = getIndex(name)
     if (pos === -1) {
       listeners.push({ name, fun })

src/utils/im/sdk.js

       }).then((task) => {
         console.log(`[${now()}]`, '[WS] [connect]', task)
         instanceRef.current = task
-  
+
         task.onOpen(function () {
           console.log(`[${now()}]`, '[WS] [onOpen]', paramsRef.current)
           resolve()
 
         task.onMessage(function (msg) {
           console.info(`[${now()}]`, '[WS] [onMessage]', msg)
-          instanceRef.onMessage().forEach((f) => f(msg))
+          instanceRef.onMessage().forEach((f) => f(msg.data))
         })
 
         task.onError(function (error) {