全平台 IM 即时通讯
系统完整源码

// 消息发送服务 — MessageService.java
@Service
@Slf4j
public class MessageService {

    @Autowired private WebSocketSessionManager sessionManager;
    @Autowired private MessageRepository      messageRepo;

    public MessageVO sendMessage(SendMessageDTO dto, Long senderId) {
        Message msg = Message.builder()
            .fromUid(senderId)
            .toUid(dto.getToUid())
            .content(dto.getContent())
            .msgType(dto.getMsgType())
            .sendTime(System.currentTimeMillis())
            .build();
        messageRepo.save(msg);
        sessionManager.pushToUser(dto.getToUid(), msg);
        return MessageVO.from(msg);
    }
}

// 聊天组件 — ChatWindow.vue (Vue 3 + UniApp)
<script setup lang="ts">
import { ref, onMounted } from 'vue'
import { useChatStore }  from '@/stores/chat'
import { useWebSocket }  from '@/hooks/useWebSocket'

const chatStore   = useChatStore()
const { sendMsg } = useWebSocket()
const msgContent  = ref('')

const handleSend = async () => {
  if (!msgContent.value.trim()) return
  await chatStore.sendMsg({
    toUid:   chatStore.activeChat.uid,
    content: msgContent.value,
    msgType: 1   // 1=文字 2=图片 3=语音 4=视频 5=文件
  })
  msgContent.value = ''
}
</script>

# REST API 接口文档（Swagger / Apifox 格式）

# 发送消息
POST /api/v1/message/send
Authorization: Bearer {token}
{
  "toUid":   10086,
  "content": "你好",
  "msgType": 1   // 1文字 2图片 3语音 4视频 5文件
}

# 获取历史消息
GET  /api/v1/message/history?uid=10086&page=1&size=20

# WebSocket 长连接
WS   wss://your-domain.com/ws/connect?token={token}

# 创建群组
POST /api/v1/group/create
{
  "name":       "技术交流群",
  "memberUids": [1001, 1002, 1003]
}