Merge branch 'jdk17-dev' of 202310181001/pigx into jdk17-dev

pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java

@@ -39,12 +39,7 @@ public class SseEmitterMessageSender {
 			return false;
 		}
 
-		Object sendFailed = ReflectUtil.getFieldValue(sseEmitter, "sendFailed");
-		if ((boolean) sendFailed) {
-			log.error("[send] sseEmitter 已经关闭");
-			SseEmitterHolder.removeSseEmitter(sseEmitter);
-			return false;
-		}
+
 		try {
 			sseEmitter.send(message);
 		}

pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java

@@ -24,10 +24,7 @@ public class RedisMessageDistributor implements MessageDistributor {
 	 */
 	@Override
 	public void distribute(MessageDO messageDO) {
-		// 包装 sessionKey 适配分布式多环境
-		List<Object> sessionKeyList = new ArrayList<>(messageDO.getSessionKeys());
-		messageDO.setSessionKeys(sessionKeyList);
-
+		
 		String str = JSONUtil.toJsonStr(messageDO);
 		stringRedisTemplate.convertAndSend(RedisSseEmitterMessageListener.CHANNEL, str);
 	}