From 8c9dcae89e73fef3f22df129f88880dd90b9fe30 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E7=A6=8F=E8=B4=A2?= <1471584931@qq.com> Date: Tue, 9 Dec 2025 18:04:59 +0800 Subject: [PATCH] =?UTF-8?q?-----=E6=B7=BB=E5=8A=A0=E4=BA=8B=E4=BB=B6?= =?UTF-8?q?=E7=9B=91=E5=90=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/pictc/config/PEventListenerConfig.java | 1 - .../main/java/com/pictc/listener/PEventListenerPublisher.java | 4 ++-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java b/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java index 4785cbc..98ba15a 100644 --- a/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java +++ b/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java @@ -1,6 +1,5 @@ package com.pictc.config; -import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.client.RestTemplate; diff --git a/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java b/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java index d104b38..76a3c3f 100644 --- a/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java +++ b/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java @@ -38,12 +38,12 @@ public class PEventListenerPublisher { Set services = TNacosManager.getNotSelfServices(); boolean flag = single?false:true; if(CollectionUtils.isNotEmpty(services)) { + HttpHeaders headers = TNacosManager.createNewHeaders(); + byte[] bytes = ObjectUtils.toBytes(conetext); for (String serviceId : services) { try { URI uri = TNacosManager.getServiceURI(serviceId); if(uri!=null) { - HttpHeaders headers = TNacosManager.createNewHeaders(); - byte[] bytes = ObjectUtils.toBytes(conetext); RequestEntity request = new RequestEntity(bytes,headers,HttpMethod.POST,uri); ResponseEntity responseEntity = rest.exchange(request,boolean.class); if(single && responseEntity.hasBody() && responseEntity.getBody()) {