api 'com.tencent.imsdk:imsdk-plus:6.1.2155'

val config = V2TIMSDKConfig()
V2TIMManager.getInstance()
    .initSDK(this, sdkId, config, object : V2TIMSDKListener() {
        override fun onConnecting() {
            // 正在連接到騰訊云服務(wù)器
            Log.e("im", "正在連接到騰訊云服務(wù)器")
        }

        override fun onConnectSuccess() {
            // 已經(jīng)成功連接到騰訊云服務(wù)器
            Log.e("im", "已經(jīng)成功連接到騰訊云服務(wù)器")
        }

        override fun onConnectFailed(code: Int, error: String) {
            // 連接騰訊云服務(wù)器失敗
            Log.e("im", "連接騰訊云服務(wù)器失敗")
        }
    })

V2TIMManager.getInstance().login(currentUser,sig, object : V2TIMCallback {
    override fun onSuccess() {
        Log.e("im", "${currentUser}登錄成功")
    }
    override fun onError(code: Int, desc: String?) {
        Log.e("im", "${currentUser}登錄失敗，錯(cuò)誤碼為:$[code],具體錯(cuò)誤:${desc}")
    }
})

val group = V2TIMGroupInfo()
group.groupName = "test"
group.groupType = "Meeting"
group.introduction = "more to show"
group.groupID = "test"
val memberInfoList: MutableList<V2TIMCreateGroupMemberInfo> = ArrayList()
val memberA = V2TIMCreateGroupMemberInfo()
memberA.setUserID("master")
memberInfoList.add(memberA)
V2TIMManager.getGroupManager().createGroup(
    group, memberInfoList, object : V2TIMValueCallback<String?> {
        override fun onError(code: Int, desc: String) {
            // 創(chuàng)建失敗
            Log.e("im","創(chuàng)建失敗$[code],詳情:${desc}")
        }

        override fun onSuccess(groupID: String?) {
            // 創(chuàng)建成功
            Log.e("im","創(chuàng)建成功,群號(hào)為${groupID}")
        }
    })

V2TIMManager.getInstance().joinGroup("群聊ID","驗(yàn)證消息",object :V2TIMCallback{
    override fun onSuccess() {
        Log.e("im","加群成功")
    }
    override fun onError(p0: Int, p1: String?) {
        Log.e("im","加群失敗")
    }
})

val myMessage = "一段自定義的json數(shù)據(jù)"

//由于這里自定義消息接收的參數(shù)為byteArray類型的，所以進(jìn)行一個(gè)轉(zhuǎn)換
val messageCus= V2TIMManager.getMessageManager().createCustomMessage(myMessage.toByteArray())

V2TIMManager.getMessageManager().sendMessage(messageCus,toUserId,groupId,weight,onlineUserOnly, offlinePushInfo,object:V2TIMSendCallback<V2TIMMessage>{
    override fun onSuccess(message: V2TIMMessage?) {
       	Log.e("im","發(fā)送成功，內(nèi)容為:${message?.customElem}")
        //這里同時(shí)需要自己進(jìn)行解析消息,需要轉(zhuǎn)換成String類型的數(shù)據(jù)
        val data = String(message?.customElem?.data)
       	...
    }

    override fun onError(p0: Int, p1: String?) {
        Log.e("im","錯(cuò)誤碼為:${p0},具體錯(cuò)誤:${p1}")
    }

    override fun onProgress(p0: Int) {
        Log.e("im","處理進(jìn)度:${p0}")
    }
})

V2TIMManager.getMessageManager().getGroupHistoryMessageList(
    groupId,pullNumber,lastMessage,object:V2TIMValueCallback<List<V2TIMMessage>>{
    override fun onSuccess(p0: List<V2TIMMessage>?) {
       if (p0 != null) {
           if (p0.isEmpty()){
               Log.e("im","沒有更多消息了")
               "沒有更多消息了".showToast()
           }else {
               //記錄最后一條消息
               lastMessage = p0[p0.size - 1]
               for (msgIndex in p0.indices) {
                   //解析各種消息
                   when(p0[msgIndex].elemType){
                       V2TIMMessage.V2TIM_ELEM_TYPE_CUSTOM ->{
                           ...
                       }
                       V2TIMMessage.V2TIM_ELEM_TYPE_TEXT -> {}
                          ...
                       }
                       else -> {
                         ...
                       }
                   }  							
               }
           }
       }
    }
    override fun onError(p0: Int, p1: String?) {
        ....
    }
})

V2TIMManager.getMessageManager().addAdvancedMsgListener(object:V2TIMAdvancedMsgListener(){
    override fun onRecvNewMessage(msg: V2TIMMessage?) {
        Log.e("im","新消息${msg?.customElem}")

        //這里針對(duì)多種消息類型有不同的處理方法
        when(msg?.elemType){
            V2TIMMessage.V2TIM_ELEM_TYPE_CUSTOM ->{
                val message = msg.customElem?.data
                ...
            }
            V2TIMMessage.V2TIM_ELEM_TYPE_TEXT ->{
                val message = msg.textElem.text
                ...
            }
            else -> {
                "暫時(shí)不支持此消息的接收".showToast()
                Log.e("im","${msg?.elemType}")
            }
        }
    }
})

implementation "org.springframework.boot:spring-boot-starter-websocket"

@Configuration
class WebSocketConfig {
    @Bean
    fun serverEndpointExporter(): ServerEndpointExporter {
        return ServerEndpointExporter()
    }
}

@ServerEndpoint("/imserver/{userId}")
@Component
class WebSocketServer {
    @OnOpen
    fun onOpen(session: Session?, @PathParam("userId") userId: String) {
        ...
    }

    @OnClose
    fun onClose() {
        ...
    }

    @OnMessage
    fun onMessage(message: String, session: Session?) {
      ...
    }
    
    @OnError
    fun onError(session: Session?, error: Throwable) {
       ...
    }

    //主要解決@Component和@Resource沖突導(dǎo)致未能自動(dòng)初始化的問題
    @Resource
    fun setMapper(chatMapper: chatMapper){
        WebSocketServer.chatMapper = chatMapper
    }
    
    //這是發(fā)送消息用到的函數(shù)
    @Throws(IOException::class)
    fun sendMessage(message: String?) {
        session!!.basicRemote.sendText(message)
    }

    //靜態(tài)變量和方法
    companion object {
		...
    }
}

companion object {
    //統(tǒng)計(jì)在線人數(shù)
    private var onlineCount: Int = 0
    
    //用于存放每個(gè)用戶對(duì)應(yīng)的webSocket對(duì)象
    val webSocketMap = ConcurrentHashMap<String, WebSocketServer>()

    //操作數(shù)據(jù)庫的mapper對(duì)象的延遲初始化
    lateinit var chatMapper:chatMapper
    
    //服務(wù)端主動(dòng)推送消息的對(duì)外開放的方法
    @Throws(IOException::class)
    fun sendInfo(message: String, @PathParam("userId") userId: String) {
        if (userId.isNotBlank() && webSocketMap.containsKey(userId)) {
            webSocketMap[userId]?.sendMessage(message)
        } else {
            println("用戶$userId,不在線！")
        }
    }

    //在線統(tǒng)計(jì)
    @Synchronized
    fun addOnlineCount() {
        onlineCount++
    }

    //離線統(tǒng)計(jì)
    @Synchronized
    fun subOnlineCount() {
        onlineCount--
    }
}

@OnOpen
fun onOpen(session: Session?, @PathParam("userId") userId: String) {
    this.session = session
    this.userId = userId
    if (webSocketMap.containsKey(userId)) {
        //包含此id說明此時(shí)其他地方開啟了一個(gè)webSocket通道，直接kick下線重新連接
        webSocketMap.remove(userId)
        webSocketMap[userId] = this
    } else {
        webSocketMap[userId] = this
        addOnlineCount()
    }
    println("用戶連接:$userId,當(dāng)前在線人數(shù)為:$onlineCount")
}

@OnClose
fun onClose() {
    if (webSocketMap.containsKey(userId)) {
        webSocketMap.remove(userId)
        subOnlineCount()
    }
    println("用戶退出:$userId,當(dāng)前在線人數(shù)為:$onlineCount")
}

@OnMessage
fun onMessage(message: String, session: Session?) {
    if (message.isNotBlank()) {
        //解析發(fā)送的報(bào)文
        val newMessage = ...
        
        //這里需要進(jìn)行插入一條數(shù)據(jù)，做持久化處理，即未在線的用戶也同樣可以看到這條消息
        chatMapper.insert(newMessage)
        
        //遍歷所有的消息
        webSocketMap.forEach { 
            it.value.sendMessage(sendMessage.toMyJson())
        }
    }
}

@OnError
fun onError(session: Session?, error: Throwable) {
    println("用戶錯(cuò)誤:$userId 原因: ${error.message}")
    error.printStackTrace()
}

fun sendMessage(message: String?) {
    session!!.basicRemote.sendText(message)
}

@PostMapping("/sendAll/{message}")
fun sendAll(@PathVariable message: String):String{
    //消息的處理
    val newMessage = ... 
    
    //需不要存儲(chǔ)系統(tǒng)消息就看具體需求了
    WebSocketServer.webSocketMap.forEach { 
        WebSocketServer.sendInfo(sendMessage.toMyJson(), it.key)
    }
    
    return "ok"
}

@PostMapping("/sendC2C/{userId}/{message}")
fun sendC2C(@PathVariable userId:String,@PathVariable message:String):String{
    //消息的處理
    val newMessage = ... 
    
    WebSocketServer.sendInfo(newMessage, userId)
    return  "ok"
}

implementation 'org.java-websocket:Java-WebSocket:1.5.2'

val userSocket = object :WebSocketClient(URI("wss://服務(wù)端地址:端口號(hào)/imserver/${userId}")){
    override fun onOpen(handshakedata: ServerHandshake?) {
        //打開進(jìn)行初始化的操作
    }

    override fun onMessage(message: String?) {
       ...
        //這里做recyclerView的更新
    }

    override fun onClose(code: Int, reason: String?, remote: Boolean) {
       //這里執(zhí)行一個(gè)通知操作即可
        ...
    }

    override fun onError(ex: Exception?) {
       ...
    }

}
userSocket.connect()

//斷開連接的話使用自帶的reconnect重新連接即可
//需要注意的一點(diǎn)就是不能在重寫方法里面執(zhí)行這個(gè)操作
userSocket.reconnect()

private val up = 1
private val down = 2
private val fail = 0
private val handler = object : Handler(Looper.getMainLooper()) {
    override fun handleMessage(msg: android.os.Message) {
        when (msg.what) {
            up -> {
                viewBinding.chatRecyclerview.scrollToPosition(0)
                viewBinding.swipeRefresh.isRefreshing = false
            }
            down ->{
                viewBinding.chatRecyclerview.scrollToPosition(viewModel.chatList.size-1)
            }
            fail -> {
                "刷新失敗請(qǐng)檢查網(wǎng)絡(luò)".showToast()
                viewBinding.swipeRefresh.isRefreshing = false
            }
        }
    }
}

viewModel.chatList.add(0,msg)
adapter.notifyItemInserted(0)

//獲取聊天記錄
@GET("chat/refreshes/{time}/{number}")
fun getChat(@Path("time")time:String, @Path("number")count:Int): Call<MessageResponse>

//生成應(yīng)用憑據(jù)
@GET("imSig/{userId}/{expire}")
fun getSig(@Path("userId")userId:String,@Path("expire")expire:Long):Call<String>