Spring通过REST API和WebSocket作为中间层，实现JavaScript与RabbitMQ的消息交互：1. Spring集成RabbitMQ并提供POST接口接收前端请求；2. JavaScript调用该接口发送消息，Spring将其转发至队列；3. 消费者处理后通过WebSocket将结果推送给前端，完成双向通信。
JavaScript本身运行在浏览器或Node.js环境中，无法直接与Spring框架的消息队列（如RabbitMQ、Kafka）进行通信。但可以通过中间层实现前后端协同处理消息。常见的做法是：Spring作为后端服务使用消息队列进行异步通信，前端JavaScript通过HTTP或WebSocket与Spring后端交互，间接完成消息的发送与接收。
1. Spring集成消息队列（以RabbitMQ为例）
在Spring Boot项目中集成RabbitMQ，用于接收和发送消息：
添加依赖（Maven）：
org.springframework.boot
spring-boot-starter-amqp
配置application.yml：
spring:
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
创建消息生产者：
@Service
public class MessageProducer {
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend(“myQueue”, message);
}
}
创建消息消费者：
@Service
public class MessageConsumer {
@RabbitListener(queues = “myQueue”)
public void receive(String message) {
System.out.println(“Received: ” + message);
}
}
2. 提供REST API供JavaScript调用
Spring提供一个REST接口，供前端JavaScript发送消息请求：
@RestController
public class MessageController {
@Autowired
private MessageProducer messageProducer;
@PostMapping(“/send”)
public ResponseEntity sendMessage(@RequestBody Map payload) {
messageProducer.sendMessage(payload.get(“msg”));
return ResponseEntity.ok(“Message sent!”);
}
}
3. JavaScript通过HTTP发送消息
前端JavaScript通过fetch调用Spring的REST接口：
立即学习“Java免费学习笔记（深入）”；
async function sendMsg() {
const res = await fetch(‘http://localhost:8080/send’, {
method: ‘POST’,
headers: { ‘Content-Type’: ‘application/json’ },
body: JSON.stringify({ msg: ‘Hello from JS!’ })
});
const data = await res.json();
console.log(data);
}
4. 使用WebSocket实现实时消息推送
若需从Spring向JavaScript实时推送消息（例如消费队列后的结果），可使用WebSocket：
Spring配置WebSocket：
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint(“/ws”).withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker(“/topic”);
registry.setApplicationDestinationPrefixes(“/app”);
}
}
控制器推送消息：
@Controller
public class WsController {
@Autowired
private SimpMessagingTemplate messagingTemplate;
public void sendMessageToClient(String message) {
messagingTemplate.convertAndSend(“/topic/messages”, message);
}
}
JavaScript订阅消息：
const socket = new SockJS(‘/ws’);
const stompClient = Stomp.over(socket);
stompClient.connect({}, function(frame) {
stompClient.subscribe(‘/topic/messages’, function(message) {
console.log(‘Received: ‘ + message.body);
});
});
当Spring从RabbitMQ接收到消息后，可在MessageConsumer中调用WsController的sendMessageToClient方法，将消息推送给前端。
基本上就这些。通过HTTP实现JS发送消息到Spring，再由Spring转发至消息队列；通过WebSocket实现Spring将队列消息实时推送到前端JavaScript。这种方式解耦清晰，适用于大多数Web应用。
以上就是JS如何与Spring消息队列集成_JavaScript与Spring消息队列集成的实现方法的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1535025.html
微信扫一扫 
支付宝扫一扫 
