Browse Source

🚀 集成SSE,解决乱码异常

master
wangxiang 3 years ago
parent
commit
d48b01d2fd
  1. 4
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapLogisticSseController.java
  2. 4
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IMapLogisticSseService.java
  3. 4
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticSseServiceImpl.java

4
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapLogisticSseController.java

@ -62,7 +62,7 @@ public class MapLogisticSseController {
@GetMapping("/sendTenantMessage") @GetMapping("/sendTenantMessage")
public R sendTenantMessage(String json) { public R sendTenantMessage(String json) {
iMapLogisticSseService.sendTenantMessage(json); iMapLogisticSseService.sendMessage(json);
return R.ok(); return R.ok();
} }
@ -74,7 +74,7 @@ public class MapLogisticSseController {
@GetMapping("/disconnectTenant") @GetMapping("/disconnectTenant")
public R disconnectTenant() { public R disconnectTenant() {
iMapLogisticSseService.disconnectTenant(); iMapLogisticSseService.disconnect();
return R.ok(); return R.ok();
} }

4
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IMapLogisticSseService.java

@ -33,13 +33,13 @@ public interface IMapLogisticSseService {
* @param json 发送数据包 * @param json 发送数据包
* @return void * @return void
*/ */
void sendTenantMessage(String json); void sendMessage(String json);
/** /**
* 断开当前用户租户下所有客户端连接 * 断开当前用户租户下所有客户端连接
* @return void * @return void
*/ */
void disconnectTenant(); void disconnect();
/** /**
* 断开当前用户连接 * 断开当前用户连接

4
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticSseServiceImpl.java

@ -88,7 +88,7 @@ public class MapLogisticSseServiceImpl implements IMapLogisticSseService {
@Override @Override
@SneakyThrows @SneakyThrows
public void sendTenantMessage(String json) { public void sendMessage(String json) {
KiccUser kiccUser = getUser(); KiccUser kiccUser = getUser();
Set<SseSignalContainer> sendSseSignalContainers = sseSignalContainers.stream() Set<SseSignalContainer> sendSseSignalContainers = sseSignalContainers.stream()
.filter(item -> StrUtil.equals(item.getTenantId(), kiccUser.getTenantId())) .filter(item -> StrUtil.equals(item.getTenantId(), kiccUser.getTenantId()))
@ -112,7 +112,7 @@ public class MapLogisticSseServiceImpl implements IMapLogisticSseService {
} }
@Override @Override
public void disconnectTenant() { public void disconnect() {
KiccUser kiccUser = getUser(); KiccUser kiccUser = getUser();
Set<SseSignalContainer> sendSseSignalContainers = sseSignalContainers.stream() Set<SseSignalContainer> sendSseSignalContainers = sseSignalContainers.stream()
.filter(item -> StrUtil.equals(item.getTenantId(), kiccUser.getTenantId())) .filter(item -> StrUtil.equals(item.getTenantId(), kiccUser.getTenantId()))

Loading…
Cancel
Save