Browse Source

🚀 集成SSE,解决乱码异常

master
wangxiang 3 years ago
parent
commit
b6fdb41ab8
  1. 9
      src/components/AMap/src/AMapDesigner/index.vue
  2. 3
      src/settings/componentSetting.ts

9
src/components/AMap/src/AMapDesigner/index.vue

@ -122,7 +122,7 @@
import { isArray, isString } from '/@/utils/is'; import { isArray, isString } from '/@/utils/is';
import { useI18n } from '/@/hooks/web/useI18n'; import { useI18n } from '/@/hooks/web/useI18n';
import { useDebounceFn } from '@vueuse/core'; import { useDebounceFn } from '@vueuse/core';
import { EventSourcePolyfill } from 'event-source-polyfill/src/eventsource'; import { NativeEventSource, EventSourcePolyfill } from 'event-source-polyfill/src/eventsource';
import { getAccessToken } from '/@/utils/auth'; import { getAccessToken } from '/@/utils/auth';
/** 类型规范统一声明定义区域 */ /** 类型规范统一声明定义区域 */
@ -466,11 +466,12 @@
orgMarkerCluster?.setData(orgPoints); orgMarkerCluster?.setData(orgPoints);
// ssegps // ssegps
eventSource = new EventSourcePolyfill(mapDesigner.sseUrl, { const EventSource = EventSourcePolyfill;
eventSource = new EventSource(mapDesigner.sseUrl, {
headers: { Authorization: `Bearer ${getAccessToken()}` } headers: { Authorization: `Bearer ${getAccessToken()}` }
}); });
eventSource.onopen =function (ev) { eventSource.onopen = function (ev) {
console.info(ev,'建立连接。。。'); console.info(ev,'建立连接。。。');
}; };
@ -491,6 +492,7 @@
}); });
onUnmounted(() => { onUnmounted(() => {
console.log('结束');
eventSource.close(); eventSource.close();
if (map) { if (map) {
// //
@ -500,6 +502,7 @@
/** 地图创建完成(动画关闭) */ /** 地图创建完成(动画关闭) */
function complete () { function complete () {
eventSource.close();
if (map) { if (map) {
map.on('complete', () => { map.on('complete', () => {
setMapDataJson(mapProps.options); setMapDataJson(mapProps.options);

3
src/settings/componentSetting.ts

@ -5,7 +5,6 @@
* @create: 2022/4/7 * @create: 2022/4/7
*/ */
import type { SorterResult } from '../components/Table'; import type { SorterResult } from '../components/Table';
import { getAccessToken } from '/@/utils/auth';
import { buildUUID } from '/@/utils/uuid'; import { buildUUID } from '/@/utils/uuid';
import { useGlobSetting } from '/@/hooks/setting'; import { useGlobSetting } from '/@/hooks/setting';
const { apiUrl } = useGlobSetting(); const { apiUrl } = useGlobSetting();
@ -56,6 +55,6 @@ export default {
// 默认缩放 // 默认缩放
defaultZoom: 17, defaultZoom: 17,
// sse后端地址 // sse后端地址
sseUrl: `${apiUrl}/common_proxy/common/mapLogisticSse/subscribe?clientId=${buildUUID()}&accessToken=${getAccessToken()}` sseUrl: `${apiUrl}/common_proxy/common/mapLogisticSse/subscribe?clientId=${buildUUID()}}`
} }
}; };

Loading…
Cancel
Save