From 3dccd71916cbe842ad49d1fa69f0da4c9766a194 Mon Sep 17 00:00:00 2001 From: quyixiao <2621048238@qq.com> Date: Wed, 12 Mar 2025 01:30:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../heyu/api/data/config/RabbitConfig.java | 3 +- .../heyu/api/controller/TestController.java | 65 +++++++++++++++++++ .../PostCodeQueueSimpleRabbitListener.java | 7 +- .../src/main/resources/bootstrap-dev.yml | 8 +-- 4 files changed, 75 insertions(+), 8 deletions(-) diff --git a/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java b/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java index 2d3e568..58cca71 100644 --- a/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java +++ b/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java @@ -10,13 +10,14 @@ import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; /** * @author wutao * @description mq配置 * @date 2020-12-25 */ -//@Configuration +@Configuration @Slf4j public class RabbitConfig { diff --git a/api-web/api-interface/src/main/java/com/heyu/api/controller/TestController.java b/api-web/api-interface/src/main/java/com/heyu/api/controller/TestController.java index b26b7ac..4b10fca 100644 --- a/api-web/api-interface/src/main/java/com/heyu/api/controller/TestController.java +++ b/api-web/api-interface/src/main/java/com/heyu/api/controller/TestController.java @@ -6,9 +6,11 @@ import com.heyu.api.data.annotation.NotIntercept; import com.heyu.api.data.constants.RedisConstans; import com.heyu.api.data.dao.api.ApiPostCodeDao; import com.heyu.api.data.dao.calca.CalcaAccountDao; +import com.heyu.api.data.entity.api.ApiPostCodeEntity; import com.heyu.api.data.entity.calca.CalcaAccountEntity; import com.heyu.api.data.utils.R; import com.heyu.api.data.utils.RedisUtils; +import com.heyu.api.data.utils.StringUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; @@ -187,6 +189,9 @@ public class TestController{ } + + + } catch (Exception e) { log.error(e.getMessage()); } @@ -207,4 +212,64 @@ public class TestController{ + + + + // http://localhost:8888/app/test/email2?key=AD + @RequestMapping("/email2") + public R email2(String key ) throws Exception { + String fileName = "/Users/quyixiao/Desktop/"+key+"/"+key+".txt"; + + // 读取文件内容到Stream流中，按行读取 + Stream lines = Files.lines(Paths.get(fileName)); + StringBuffer sb = new StringBuffer(); + + + // 随机行顺序进行数据处理 + lines.forEach(ele -> { + + String a[] = ele.split("\t"); + String b[] = new String[12]; + if (a != null && a.length == 11){ + for (int i = 0; i < a.length; i++) { + b[i] = a[i]; + } + b[11] = ""; + a = b ; + } + + + if (a != null && a.length == 12) { + ApiPostCodeEntity apiPostCodeEntity = new ApiPostCodeEntity(); + apiPostCodeEntity.setParam1(getValue(a[0])); + apiPostCodeEntity.setParam2(getValue(a[1])); + apiPostCodeEntity.setParam3(getValue(a[2])); + apiPostCodeEntity.setParam4(getValue(a[3])); + apiPostCodeEntity.setParam5(getValue(a[4])); + apiPostCodeEntity.setParam6(getValue(a[5])); + apiPostCodeEntity.setParam7(getValue(a[6])); + apiPostCodeEntity.setParam8(getValue(a[7])); + apiPostCodeEntity.setParam9(getValue(a[8])); + apiPostCodeEntity.setParam10(getValue(a[9])); + apiPostCodeEntity.setParam11(getValue(a[10])); + apiPostCodeEntity.setParam12(getValue(a[11])); + + rabbitTemplate.convertAndSend(accountLogNameQueue, JSON.toJSONString(apiPostCodeEntity)); + } + }); + + return R.ok(); + } + + + public String getValue(String value ) { + if(StringUtils.isBlank(value)){ + return "null"; + } + return value; + } + } + + + diff --git a/api-web/api-interface/src/main/java/com/heyu/api/listener/PostCodeQueueSimpleRabbitListener.java b/api-web/api-interface/src/main/java/com/heyu/api/listener/PostCodeQueueSimpleRabbitListener.java index ba4f3a4..5817de9 100644 --- a/api-web/api-interface/src/main/java/com/heyu/api/listener/PostCodeQueueSimpleRabbitListener.java +++ b/api-web/api-interface/src/main/java/com/heyu/api/listener/PostCodeQueueSimpleRabbitListener.java @@ -11,9 +11,10 @@ import org.springframework.amqp.support.AmqpHeaders; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.messaging.handler.annotation.Header; import org.springframework.messaging.handler.annotation.Payload; +import org.springframework.stereotype.Component; -//@Component +@Component @Slf4j public class PostCodeQueueSimpleRabbitListener { @@ -22,13 +23,13 @@ public class PostCodeQueueSimpleRabbitListener { private ApiPostCodeDao apiPostCodeDao; @RabbitHandler - @RabbitListener(queues = "#{accountAmountQueue.name}", containerFactory = "accountAmountQueueSimpleRabbitListenerContainerFactory") + @RabbitListener(queues = "#{postCodeDataNameQueue.name}", containerFactory = "accountAmountQueueSimpleRabbitListenerContainerFactory") public void consumeMessage(@Payload String message, @Header(AmqpHeaders.DELIVERY_TAG) long delivertTag, Channel channel) { try { ApiPostCodeEntity apiPostCodeEntity = JSON.parseObject(message, ApiPostCodeEntity.class); apiPostCodeDao.insertApiPostCode(apiPostCodeEntity); } catch (Exception e) { - log.error("exception e", e); + log.error("exception e " + message, e); } } diff --git a/api-web/api-interface/src/main/resources/bootstrap-dev.yml b/api-web/api-interface/src/main/resources/bootstrap-dev.yml index 449f754..78af0d1 100644 --- a/api-web/api-interface/src/main/resources/bootstrap-dev.yml +++ b/api-web/api-interface/src/main/resources/bootstrap-dev.yml @@ -34,10 +34,10 @@ spring: host: 121.40.41.240 timeout: 5000 rabbitmq: - host: 172.16.5.230 - port: 15672 - username: user - password: dk_eP^#fkLf30 + host: rabit.iwulin.tech + port: 32407 + username: admin + password: Ij_klfJ^$^_3IBs listener: simple: # 设置手动ack回复