マルチクラウドとエッジのデータ同期をマスターする: KubeMQ の Java SDK を使用した小売ユースケース

import io.kubemq.sdk.queues.QueueMessage;
import io.kubemq.sdk.queues.QueueSendResult;
import io.kubemq.sdk.queues.QueuesClient;

import java.util.UUID;

public class StoreInventoryManager {
    private final QueuesClient client1;
    private final QueuesClient client2;
    private final String queueName = "store-1";

    public StoreInventoryManager() {
        this.client1 = QueuesClient.builder()
                .address("cloudinventory1:50000")
                .clientId("store-1")
                .build();

        this.client2 = QueuesClient.builder()
                .address("cloudinventory2:50000")
                .clientId("store-1")
                .build();
    }

    public void sendInventoryData(String inventoryData) {
        QueueMessage message = QueueMessage.builder()
                .channel(queueName)
                .body(inventoryData.getBytes())
                .metadata("Inventory Update")
                .id(UUID.randomUUID().toString())
                .build();

        try {
            // Send to cloudinventory1
            QueueSendResult result1 = client1.sendQueuesMessage(message);
            System.out.println("Sent to cloudinventory1: " + result1.isError());

            // Send to cloudinventory2
            QueueSendResult result2 = client2.sendQueuesMessage(message);
            System.out.println("Sent to cloudinventory2: " + result2.isError());

        } catch (RuntimeException e) {
            System.err.println("Failed to send inventory data: " + e.getMessage());
        }
    }

    public static void main(String[] args) {
        StoreInventoryManager manager = new StoreInventoryManager();
        manager.sendInventoryData("{'item': 'Laptop', 'quantity': 50}");
    }
}

import io.kubemq.sdk.queues.QueueMessage;
import io.kubemq.sdk.queues.QueuesPollRequest;
import io.kubemq.sdk.queues.QueuesPollResponse;
import io.kubemq.sdk.queues.QueuesClient;

public class CloudInventoryManager {
    private final QueuesClient client;
    private final String queueName = "store-1";

    public CloudInventoryManager() {
        this.client = QueuesClient.builder()
                .address("cloudinventory1:50000")
                .clientId("cloudinventory1")
                .build();
    }

    public void receiveInventoryData() {
        QueuesPollRequest pollRequest = QueuesPollRequest.builder()
                .channel(queueName)
                .pollMaxMessages(1)
                .pollWaitTimeoutInSeconds(10)
                .build();

        try {
            while (true) {
                QueuesPollResponse response = client.receiveQueuesMessages(pollRequest);

                if (!response.isError()) {
                    for (QueueMessage msg : response.getMessages()) {
                        String inventoryData = new String(msg.getBody());
                        System.out.println("Received inventory data: " + inventoryData);

                        // Process the data here

                        // Acknowledge the message
                        msg.ack();
                    }
                } else {
                    System.out.println("Error receiving messages: " + response.getError());
                }

                // Wait for a bit before polling again
                Thread.sleep(1000);
            }
        } catch (RuntimeException | InterruptedException e) {
            System.err.println("Failed to receive inventory data: " + e.getMessage());
        }
    }

    public static void main(String[] args) {
        CloudInventoryManager manager = new CloudInventoryManager();
        manager.receiveInventoryData();
    }
}