Baris gilir mesej dalam seni bina perkhidmatan mikro Java

Dalam seni bina perkhidmatan mikro Java, baris gilir mesej membenarkan komunikasi antara perkhidmatan tak segerak, dengan itu meningkatkan kebolehskalaan, toleransi kesalahan dan prestasi. Aliran Awan Musim Bunga berfungsi sebagai lapisan abstraksi baris gilir mesej dan menyokong hujung belakang seperti Kafka dan RabbitMQ. Artikel ini menunjukkan aplikasi baris gilir mesej melalui pembuatan pesanan dan perkhidmatan pemprosesan. Membuat pesanan akan menerbitkan mesej, dan perkhidmatan pemprosesan pesanan akan menggunakan dan memproses mesej, dengan itu menyahgandingkan interaksi perkhidmatan.

Baris Gilir Mesej dalam Seni Bina Microservice Java

Pengenalan

Baris gilir mesej memainkan peranan penting dalam seni bina perkhidmatan mikro, yang membolehkan komunikasi tak segerak antara perkhidmatan. Dengan memisahkan interaksi antara perkhidmatan, baris gilir mesej boleh meningkatkan kebolehskalaan, toleransi kesalahan dan prestasi.

Pelaksanaan

Terdapat beberapa perpustakaan baris gilir mesej sumber terbuka untuk dipilih di Jawa, seperti Apache Kafka, RabbitMQ dan ActiveMQ.

Untuk tutorial ini, kami akan menggunakan Spring Cloud Stream sebagai lapisan abstraksi baris gilir mesej. Spring Cloud Stream menyediakan sokongan untuk berbilang bahagian belakang pemesejan, termasuk Kafka dan RabbitMQ.

Kes Praktikal: Membuat Pesanan dan Pemprosesan

Untuk menunjukkan aplikasi baris gilir mesej dalam seni bina perkhidmatan mikro, kami mencipta perkhidmatan penciptaan dan pemprosesan pesanan.

Buat perkhidmatan pesanan

// OrderController.java @PostMapping("/") public ResponseEntity createOrder(@RequestBody Order order) { // 创建订单对象 Order savedOrder = orderService.createOrder(order); // 将订单发布到消息队列 orderPublisher.send(savedOrder); return ResponseEntity.ok(savedOrder); }

Proses perkhidmatan pesanan

// OrderProcessor.java @EventListener(topics = "${topic.order.created}") public void processOrder(Order order) { // 处理订单 orderService.processOrder(order); }

Konfigurasikan

# application.yaml spring: cloud: stream: bindings: order-created: destination: orders producer: partitionCount: 1 order-status: destination: orders consumer: partitions: 1

Jalankan

Kesimpulan

Atas ialah kandungan terperinci Baris gilir mesej dalam seni bina perkhidmatan mikro Java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!