导入包：
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId> </dependency>
application.yml
springrabbitmq:host: localhostport: 5672username: guestpassword: guestvirtual-host: / # 默认虚拟主机listener:simple:acknowledge-mode: manual # 可根据需要设置为autopublisher-confirm-type: correlated
RabbitMQConfig.java
package com.example.dyreportapi.config;import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
@Configuration
public class RabbitMQConfig {public static final String DECLARE_QUEUE = "*****替换正式队列名***"; // 申报队列public static final String RESPONSE_QUEUE = "***替换正式队列名**"; // 回执队列public static final String RK_QUEUE = "***替换正式队列名**"; // 出入库队列@Beanpublic Queue declareQueue() {return new Queue(DECLARE_QUEUE, true); // durable}@Beanpublic Queue responseQueue() {return new Queue(RESPONSE_QUEUE, true);}public Queue rkQUEUE() {return new Queue(RK_QUEUE, true);}@Beanpublic RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {RabbitTemplate template = new RabbitTemplate(connectionFactory);template.setConfirmCallback((correlationData, ack, cause) -> {if (ack) {System.out.println("消息成功投递至 RabbitMQ Broker");} else {System.out.println("消息未投递成功：" + cause);}});return template;}}
ResponseMessageListener.java
import com.example.dyreportapi.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import javax.xml.parsers.ParserConfigurationException;
import org.xml.sax.SAXException;@Component
public class ResponseMessageListener {@RabbitListener(queues = RabbitMQConfig.RESPONSE_QUEUE)public void receiveMessage(String message, Channel channel, Message amqpMessage) throws IOException {System.out.println("接收到回执消息: " + message);long deliveryTag = amqpMessage.getMessageProperties().getDeliveryTag();try {// 解析XML消息if (isXmlMessage(message)) {parseXmlMessage(message);}// 判断是否是某个业务消息的回执if (message.contains("03355813-a4c0-49b8-955b-edd0e2934275") || message.contains("LT072303")) {System.out.println("✅ 匹配到本次发送的车辆备案回执！");// 正常确认消息channel.basicAck(deliveryTag, false);} else {// 不匹配的消息，拒绝并重新入队给其他消费者处理channel.basicNack(deliveryTag, false, true); // requeue=true}} catch (Exception e) {System.err.println("处理消息时发生错误: " + e.getMessage());// 处理异常时，可以选择重新入队或不重新入队channel.basicNack(deliveryTag, false, true);}}/*** 判断消息是否为XML格式*/private boolean isXmlMessage(String message) {return message.trim().startsWith("<") && message.trim().endsWith(">");}/*** 解析XML消息并提取关键标签*/private void parseXmlMessage(String xmlMessage) {try {DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();DocumentBuilder builder = factory.newDocumentBuilder();Document document = builder.parse(new ByteArrayInputStream(xmlMessage.getBytes("UTF-8")));// 获取根元素Element root = document.getDocumentElement();System.out.println("根元素: " + root.getNodeName());// 解析常见的回执标签示例parseCommonResponseTags(document);} catch (ParserConfigurationException | SAXException | IOException e) {System.err.println("XML解析失败: " + e.getMessage());}}/*** 解析常见的回执标签*/private void parseCommonResponseTags(Document document) {// 解析PRE_NO标签NodeList preNoNodes = document.getElementsByTagName("PRE_NO");if (preNoNodes.getLength() > 0) {String preNo = preNoNodes.item(0).getTextContent();System.out.println("PRE_NO: " + preNo);}// 解析MESSAGE_ID标签NodeList messageIdNodes = document.getElementsByTagName("MESSAGE_ID");if (messageIdNodes.getLength() > 0) {String messageId = messageIdNodes.item(0).getTextContent();System.out.println("MESSAGE_ID: " + messageId);}// 解析RESPONSE_CODE标签NodeList responseCodeNodes = document.getElementsByTagName("RESPONSE_CODE");if (responseCodeNodes.getLength() > 0) {String responseCode = responseCodeNodes.item(0).getTextContent();System.out.println("RESPONSE_CODE: " + responseCode);}// 解析RESPONSE_MESSAGE标签NodeList responseMessageNodes = document.getElementsByTagName("RESPONSE_MESSAGE");if (responseMessageNodes.getLength() > 0) {String responseMessage = responseMessageNodes.item(0).getTextContent();System.out.println("RESPONSE_MESSAGE: " + responseMessage);}// 解析NK_STATUS标签NodeList nkStatusNodes = document.getElementsByTagName("NK_STATUS");if (nkStatusNodes.getLength() > 0) {String nkStatus = nkStatusNodes.item(0).getTextContent();System.out.println("NK_STATUS: " + nkStatus);}}
}
package com.example.dyreportapi.controller;import com.example.dyreportapi.service.VehicleDeclareSender;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class VehicleDeclareController {@Autowiredprivate VehicleDeclareSender sender;@GetMapping("/sendVehicle")public String sendVehicleDeclare() {sender.sendVehicleDeclareMessage();return "车辆备案报文已发送";}@GetMapping("/sendVehicleOut")public String sendVehicleOut() {sender.sendVehicleHfdMessage();return "车辆出厂报文已发送";}
}
package com.example.dyreportapi.service;import com.example.dyreportapi.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.UUID;@Service
public class VehicleDeclareSender {@Autowiredprivate RabbitTemplate rabbitTemplate;/*** 车辆备案报文*/public void sendVehicleDeclareMessage() {String messageId = UUID.randomUUID().toString();String messageDate = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));System.out.println(messageId);System.out.println(messageDate);String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +"<DECLARE_DATA>\n" +" <MESSAGE_HEAD>\n" +" <MESSAGE_TYPE>VEH101</MESSAGE_TYPE>\n" +// 报文类型" <MESSAGE_ID>" + messageId + "</MESSAGE_ID>\n" +// 报文ID" <MESSAGE_TYPE>VEH101</MESSAGE_TYPE>\n" +// 报文类型" <PRE_NO>LT072303</PRE_NO>\n" +// 预录入编号" <B2B_NO>LT072303</B2B_NO>\n" +// 预录入编号" <MESSAGE_DATE>" + messageDate + "</MESSAGE_DATE>\n" +// 报文时间" <SENDER_ID>3408660A06</SENDER_ID>\n" +// 发送方ID
// " <SEND_ADDRESS>安庆</SEND_ADDRESS>\n" +// 发送方地址" <RECEIVER_ID>3329</RECEIVER_ID>\n" +// 接收方ID" </MESSAGE_HEAD>\n" +" <VEH101>\n" +" <VEH_BSC>\n" +" <VEHICLE_NO>皖A12345</VEHICLE_NO>\n" +// 车牌号" <B2B_NO>皖A12345</B2B_NO>\n" +// 车牌号" <VEHICLE_TYPE>3</VEHICLE_TYPE>\n" +// 车辆类型" <VEHICLE_WT>12345.67</VEHICLE_WT>\n" +// 车辆重量" <CUSTOMS_CODE>3329</CUSTOMS_CODE>\n" +// 关区代码 备注：3329安庆综保
// " <NOTE>测试车辆备案</NOTE>\n" +// 备注" <DCL_TYPECD>1</DCL_TYPECD>\n" +// 申报类型 1：备案；2：变更；
// " <STEP_ID></STEP_ID>\n" +// 当前环节" <DECLARE_CODE>3408660A06</DECLARE_CODE>\n" + // 申报公司编号" <DECLARE_NAME>安庆振新汽车有限公司</DECLARE_NAME>\n" +// 申报公司名称" <CREATE_BY>admin</CREATE_BY>\n" +// 创建人" <CREATE_TIME>" + messageDate + "</CREATE_TIME>\n" +// 创建时间" <DECLARE_BY>admin</DECLARE_BY>\n" +// 申报人" <DECLARE_TIME>" + messageDate + "</DECLARE_TIME>\n" +// 申报时间
// " <APPROVE_TIME></APPROVE_TIME>\n" +// 审核时间" </VEH_BSC>\n" +" </VEH101>\n" +"</DECLARE_DATA>";System.out.println("已发送车辆备案报文：" + xml);rabbitTemplate.convertAndSend(RabbitMQConfig.DECLARE_QUEUE, xml);System.out.println("已发送车辆备案报文至队列：" + RabbitMQConfig.DECLARE_QUEUE);}/*** 整车出厂报文*/public void sendVehicleHfdMessage() {String messageId = UUID.randomUUID().toString();String messageDate = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));System.out.println(messageId);System.out.println(messageDate);/*** <?xml version="1.0" encoding="UTF-8" standalone="yes"?>* <JEERP_BZ>* <MESSAGE_HEAD>* <MESSAGE_TYPE>HFDB2B</MESSAGE_TYPE>* <MESSAGE_ID>232ab09e-75d0-4fbe-a94e-c02f752c6cf6-20250729101240</MESSAGE_ID>* <MESSAGE_TIME>2025-07-29T10:12:40</MESSAGE_TIME>* <SENDER_ADDRESS></SENDER_ADDRESS>* <RECEIVER_ID>JGEQ</RECEIVER_ID>* <RECEIVER_ADDRESS></RECEIVER_ADDRESS>* <CUSTOM_CODE>3329</CUSTOM_CODE>* <SEQNO>HFD202507297719</SEQNO>* <NOTE></NOTE>* <POCKET_ID>null232ab09e-75d0-4fbe-a94e-c02f752c6cf6-20250729101240</POCKET_ID>* <TOTAL_POCKET_QTY>1</TOTAL_POCKET_QTY>* <CUR_POCKET_NO>1</CUR_POCKET_NO>* <ROUTE_CODE></ROUTE_CODE>* </MESSAGE_HEAD>* <MESSAGE_BODY>* <JG_HFD_HEAD_B2B>* <ERP_NO>HFD202507297719</ERP_NO>* <DCL_TYPECD>1</DCL_TYPECD>* <PASSPORT_TYPECD>5</PASSPORT_TYPECD>* <IO_TYPECD>I</IO_TYPECD>* <MASTER_CUSCD>3329</MASTER_CUSCD>* <AREAIN_ETPSNO>3408660A06</AREAIN_ETPSNO>* <DCL_ETPSNO>3408660A06</DCL_ETPSNO>* <INPUT_CODE>3408660A06</INPUT_CODE>* <CREATE_USER>hxy0154</CREATE_USER>* <VEHICLE_NO>LT072302</VEHICLE_NO>* <VEHICLE_WT>10000</VEHICLE_WT>* <TOTAL_GROSS_WT>560</TOTAL_GROSS_WT>* <TOTAL_NET_WT>510</TOTAL_NET_WT>* <CREATE_DATE>2025-07-29T10:12:40</CREATE_DATE>* <TRAILER_NO>LT072302</TRAILER_NO>* <PLAT_TYPECD>0</PLAT_TYPECD>* <COL1>0</COL1>* <IS_PP>0</IS_PP>* <ETPS_PREENT_NO>HFD202507297719</ETPS_PREENT_NO>* </JG_HFD_HEAD_B2B>* <JG_HFD_LIST_B2B>* <GUID_L>HFD202507297719_1</GUID_L>* <PASSPORT_SEQNO>1</PASSPORT_SEQNO>* <GDECD>LLDB1</GDECD>* <GDS_NM>领料调拨</GDS_NM>* <DCL_UNITCD>007</DCL_UNITCD>* <DCL_QTY>30</DCL_QTY>* <GROSS_WT>560</GROSS_WT>* <NET_WT>510</NET_WT>* <IS_GOODS>0</IS_GOODS>* </JG_HFD_LIST_B2B>* </MESSAGE_BODY>* </JEERP_BZ>*/// 构建基础的XML头部和尾部StringBuilder xmlBuilder = new StringBuilder();xmlBuilder.append("<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\" ?>\n").append("<JEERP_BZ>\n").append(" <MESSAGE_HEAD>\n")//报文类型.append(" <MESSAGE_TYPE>HFDB2B</MESSAGE_TYPE>\n")//报文ID.append(" <MESSAGE_ID>").append(messageId).append("</MESSAGE_ID>\n")//报文发送时间.append(" <MESSAGE_TIME>").append(messageDate).append("</MESSAGE_TIME>\n")//发送方地址.append(" <SENDER_ADDRESS></SENDER_ADDRESS>\n")//申报公司编号.append(" <RECEIVER_ID>JGEQ</RECEIVER_ID>\n")//接收方地址.append(" <RECEIVER_ADDRESS></RECEIVER_ADDRESS>\n")//使用您提供的安庆关区代码.append(" <CUSTOM_CODE>3329</CUSTOM_CODE>\n")//业务单号，唯一.append(" <SEQNO>HFD202507245559</SEQNO>\n")//备注.append(" <NOTE></NOTE>\n").append(" <POCKET_ID>").append(messageId).append("</POCKET_ID>\n").append(" <TOTAL_POCKET_QTY>1</TOTAL_POCKET_QTY>\n").append(" <CUR_POCKET_NO>1</CUR_POCKET_NO>\n").append(" <ROUTE_CODE></ROUTE_CODE>\n").append(" </MESSAGE_HEAD>\n").append(" <MESSAGE_BODY>\n").append(" <JG_HFD_HEAD_B2B>\n")//业务单号，唯一.append(" <ERP_NO>HFD202507245559</ERP_NO>\n")//申报类型 1备案 3作废.append(" <DCL_TYPECD>1</DCL_TYPECD>\n")//核放单类型 5-卡口登记货物 6-空车进出区.append(" <PASSPORT_TYPECD>5</PASSPORT_TYPECD>\n")//进出标志 I-进区，E-出区.append(" <IO_TYPECD>E</IO_TYPECD>\n")//主管海关.append(" <MASTER_CUSCD>3329</MASTER_CUSCD>\n")//国内企业编码.append(" <AREAIN_ETPSNO>3408660A06</AREAIN_ETPSNO>\n")//申报单位代码.append(" <DCL_ETPSNO>3408660A06</DCL_ETPSNO>\n")//录入单位代码.append(" <INPUT_CODE>3408660A06</INPUT_CODE>\n")//创建.append(" <CREATE_USER>hxy0154</CREATE_USER>\n")//车牌号.append(" <VEHICLE_NO>YQY99999</VEHICLE_NO>\n")//车自重.append(" <VEHICLE_WT>1000.19</VEHICLE_WT>\n")//货物总毛重.append(" <TOTAL_GROSS_WT>560</TOTAL_GROSS_WT>\n")//货物总净重.append(" <TOTAL_NET_WT>510</TOTAL_NET_WT>\n")//创建时间.append(" <CREATE_DATE>").append(messageDate).append("</CREATE_DATE>\n")//挂车车牌号.append(" <TRAILER_NO>YQY99999</TRAILER_NO>\n")//是否无车辆运输货物 0 否 1是.append(" <PLAT_TYPECD>0</PLAT_TYPECD>\n")//到货确认标记.append(" <COL1>0</COL1>\n")//是否拼票业务.append(" <IS_PP>0</IS_PP>\n")//企业内部编号.append(" <ETPS_PREENT_NO>HFD202507245559</ETPS_PREENT_NO>\n").append(" </JG_HFD_HEAD_B2B>\n");// 使用for循环生成多个JG_HFD_LIST_B2B项for (int i = 1; i <= 1; i++) {xmlBuilder.append(" <JG_HFD_LIST_B2B>\n")// 报文ID.append(" <GUID_L>HFD202507245559_").append(i).append("</GUID_L>\n")// 序号 从1开始递增的正整数.append(" <PASSPORT_SEQNO>1</PASSPORT_SEQNO>\n")// 商品编码.append(" <GDECD>LLDB1</GDECD>\n")// 商品名称.append(" <GDS_NM>车辆1</GDS_NM>\n")// 申报计量单位.append(" <DCL_UNITCD>007</DCL_UNITCD>\n")// 申报数量.append(" <DCL_QTY>3</DCL_QTY>\n")// 申报毛重.append(" <GROSS_WT>560</GROSS_WT>\n")// 申报净重.append(" <NET_WT>510</NET_WT>\n")// 是否商品.append(" <IS_GOODS>0</IS_GOODS>\n").append(" </JG_HFD_LIST_B2B>\n");}// 添加XML尾部xmlBuilder.append(" </MESSAGE_BODY>\n").append("</JEERP_BZ>");String xml = xmlBuilder.toString();System.out.println("已生成金关核放单报文：" + xml);rabbitTemplate.convertAndSend(RabbitMQConfig.RK_QUEUE, xml);System.out.println("已发送车辆出入库消息：" + RabbitMQConfig.RK_QUEUE);}
}
![[2025CVPR-图象分类方向]SPARC:用于视觉语言模型中零样本多标签识别的分数提示和自适应融合](http://pic.xiahunao.cn/[2025CVPR-图象分类方向]SPARC:用于视觉语言模型中零样本多标签识别的分数提示和自适应融合)
)
