!125 fix(application): 修复普通用户接收消息数量统计错误
Merge pull request !125 from 木子-李/sse
This commit is contained in:
@@ -221,12 +221,21 @@ import { getBaseURL } from '/@/utils/baseUrl';
|
|||||||
const messageCenter = messageCenterStore();
|
const messageCenter = messageCenterStore();
|
||||||
let eventSource: EventSource | null = null; // 存储 EventSource 实例
|
let eventSource: EventSource | null = null; // 存储 EventSource 实例
|
||||||
const token = Session.get('token');
|
const token = Session.get('token');
|
||||||
|
const isConnected = ref(false); // 标志变量,记录是否已连接过
|
||||||
const getMessageCenterCount = () => {
|
const getMessageCenterCount = () => {
|
||||||
// 创建 EventSource 实例并连接到后端 SSE 端点
|
// 创建 EventSource 实例并连接到后端 SSE 端点
|
||||||
eventSource = new EventSource(`${getBaseURL()}/sse/?token=${token}`); // 替换为你的后端地址
|
eventSource = new EventSource(`${getBaseURL()}sse/?token=${token}`); // 替换为你的后端地址
|
||||||
|
// 首次连接成功时打印一次
|
||||||
|
eventSource.onopen = function () {
|
||||||
|
if (!isConnected.value) {
|
||||||
|
console.log('SSE 首次连接成功');
|
||||||
|
isConnected.value = true; // 设置标志为已连接
|
||||||
|
}
|
||||||
|
};
|
||||||
// 监听消息事件
|
// 监听消息事件
|
||||||
eventSource.onmessage = function (event) {
|
eventSource.onmessage = function (event) {
|
||||||
|
console.log(event.data);
|
||||||
|
|
||||||
messageCenter.setUnread(+event.data); // 更新总记录数
|
messageCenter.setUnread(+event.data); // 更新总记录数
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@@ -48,9 +48,8 @@ const getLastMsg = () => {
|
|||||||
params: {},
|
params: {},
|
||||||
}).then((res: any) => {
|
}).then((res: any) => {
|
||||||
const { data } = res;
|
const { data } = res;
|
||||||
console.log(data);
|
if (data) state.newsList = [data];
|
||||||
|
|
||||||
state.newsList = [data];
|
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
onMounted(() => {
|
onMounted(() => {
|
||||||
|
|||||||
@@ -40,7 +40,7 @@ export default defineComponent({
|
|||||||
// };
|
// };
|
||||||
|
|
||||||
onMounted(() => {
|
onMounted(() => {
|
||||||
getBackends();
|
// getBackends();
|
||||||
});
|
});
|
||||||
return {
|
return {
|
||||||
...toRefs(state),
|
...toRefs(state),
|
||||||
|
|||||||
Reference in New Issue
Block a user