通过MQ实现异步调用第三方接口并等待MQ获取接口返回值 代码示例

时间: 2023-12-29 17:03:22 浏览: 54
以下是一个基于Java的MQ异步调用第三方接口示例: ```java // 生产者代码,将请求发送到MQ public class Producer { private final static String QUEUE_NAME = "third-party-api"; public static void main(String[] argv) throws Exception { // 创建连接工厂 ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); // 创建连接 Connection connection = factory.newConnection(); // 创建通道 Channel channel = connection.createChannel(); // 声明队列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 构造请求 String message = "http://third-party-api.com/api?param1=value1&param2=value2"; // 发送请求 channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8")); System.out.println("Sent message: " + message); // 关闭通道和连接 channel.close(); connection.close(); } } // 消费者代码,监听MQ消息并发送请求到第三方接口 public class Consumer { private final static String QUEUE_NAME = "third-party-api"; public static void main(String[] argv) throws Exception { // 创建连接工厂 ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); // 创建连接 Connection connection = factory.newConnection(); // 创建通道 Channel channel = connection.createChannel(); // 声明队列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 创建消费者,并设置回调函数处理消息 Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String message = new String(body, "UTF-8"); System.out.println("Received message: " + message); // 发送请求到第三方接口 String response = sendRequest(message); // 将接口返回值发送到MQ channel.basicPublish("", properties.getReplyTo(), null, response.getBytes("UTF-8")); } }; // 监听队列,自动确认消息 channel.basicConsume(QUEUE_NAME, true, consumer); } // 发送请求到第三方接口,并等待接口返回值 private static String sendRequest(String request) { // TODO: 发送请求到第三方接口,并等待接口返回值 return "response"; } } // 发送请求的代码,监听MQ返回值并返回到主线程 public class RequestSender { private final static String RESPONSE_QUEUE_NAME = "third-party-api-response"; public static void main(String[] argv) throws Exception { // 创建连接工厂 ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); // 创建连接 Connection connection = factory.newConnection(); // 创建通道 Channel channel = connection.createChannel(); // 声明队列 channel.queueDeclare(RESPONSE_QUEUE_NAME, false, false, false, null); // 创建消费者,并设置回调函数处理消息 Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String response = new String(body, "UTF-8"); System.out.println("Received response: " + response); // 将接口返回值返回到主线程 synchronized (this) { this.notify(); } } }; // 监听队列,手动确认消息 channel.basicConsume(RESPONSE_QUEUE_NAME, false, consumer); // 发送请求并等待返回值 String request = "http://third-party-api.com/api?param1=value1&param2=value2"; String correlationId = UUID.randomUUID().toString(); AMQP.BasicProperties props = new AMQP.BasicProperties.Builder() .correlationId(correlationId) .replyTo(RESPONSE_QUEUE_NAME) .build(); channel.basicPublish("", "third-party-api", props, request.getBytes("UTF-8")); synchronized (consumer) { consumer.wait(); } // 关闭通道和连接 channel.close(); connection.close(); } } ``` 说明: 1. 生产者发送请求到MQ,并设置回调队列名。 2. 消费者监听MQ消息,收到消息后发送请求到第三方接口,并将接口返回值发送到回调队列。 3. 发送者发送请求到MQ,并设置回调队列名和Correlation ID。 4. 发送者等待消费者返回接口返回值,并将接口返回值返回到主线程。

相关推荐

最新推荐

recommend-type

vue 调用 RESTful风格接口操作

主要介绍了vue 调用 RESTful风格接口操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
recommend-type

怎样使用MQ-3酒精传感器

怎样使用MQ-3酒精传感器 通过拟合计算Rs/R0比值与浓度的关系进行计算,具有一定的参考和使用价值
recommend-type

java访问IBM MQ SSL加密通道

描述了java程序代码去访问MQ的SSL加密的通道。如何配置JKS,如何配置MQ服务器的SSL秘钥库,如何配置证书制作证书和秘钥库。主要是如何编写java代码去访问SSL通道并取到数据。
recommend-type

WebSphere MQ 多实例部署方案

多实例队列管理器特征是MQV7.0.1版本之后引进的新特征,它是MQ产品的内置功能,丰富了 MQ 高可用性的解决方案。 用户可以在不同机器上定义并启动此队列管理器的多个实例,包括一个活动实例和一个备用实例。 激活的...
recommend-type

spring-cloud-starter-stream-rabbit MQ使用规范

各个微服务统一使用spring-cloud-starter-stream-rabbit 为规范各个微服务之间消息队列的交换机、通道、队列、消息投递更加便于识别、扩展和维护特进行以下要求
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

实现实时数据湖架构:Kafka与Hive集成

![实现实时数据湖架构:Kafka与Hive集成](https://img-blog.csdnimg.cn/img_convert/10eb2e6972b3b6086286fc64c0b3ee41.jpeg) # 1. 实时数据湖架构概述** 实时数据湖是一种现代数据管理架构,它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同,实时数据湖不依赖于预先定义的模式,而是采用灵活的架构,可以处理各种数据类型和格式。这种架构为企业提供了以下优势: - **实时洞察:**实时数据湖允许企业访问最新的数据,从而做出更明智的决策。 - **数据民主化:**实时数据湖使各种利益相关者都可
recommend-type

解释minorization-maximization (MM) algorithm,并给出matlab代码编写的例子

Minorization-maximization (MM) algorithm是一种常用的优化算法,用于求解非凸问题或含有约束的优化问题。该算法的基本思想是通过构造一个凸下界函数来逼近原问题,然后通过求解凸下界函数的最优解来逼近原问题的最优解。具体步骤如下: 1. 初始化参数 $\theta_0$,设 $k=0$; 2. 构造一个凸下界函数 $Q(\theta|\theta_k)$,使其满足 $Q(\theta_k|\theta_k)=f(\theta_k)$; 3. 求解 $Q(\theta|\theta_k)$ 的最优值 $\theta_{k+1}=\arg\min_\theta Q(
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。