一篇聊聊Go錯誤封裝機制
%w 是用于錯誤包裝（Error Wrapping）的格式化動詞。它是用于 fmt.Errorf 和 fmt.Sprintf 函數中的一個特殊格式化動詞，用于將一個錯誤（或其他可打印的值）包裝在一個新的錯誤中。使
RabbitMQ是一個開源的消息隊列中間件，基于AMQP（Advanced Message Queuing Protocol）協議。它具有高度的可靠性、可擴展性和靈活性，廣泛應用于分布式系統中。
特性：
使用方法：
首先需要安裝RabbitMQ服務器，并啟動它。然后可以使用Java或C#等編程語言通過RabbitMQ的客戶端庫來發送和接收消息。
示例代碼（Java）：
// 發送消息ConnectionFactory factory = new ConnectionFactory();factory.setHost("localhost");try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { String queueName = "hello"; channel.queueDeclare(queueName, false, false, false, null); String message = "Hello, RabbitMQ!"; channel.basicPublish("", queueName, null, message.getBytes()); System.out.println("Sent message: " + message);}// 接收消息try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { String queueName = "hello"; channel.queueDeclare(queueName, 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); } }; channel.basicConsume(queueName, true, consumer);}優缺點：
Kafka是一個分布式的流處理平臺，也是一個高吞吐量的分布式消息隊列系統。它具有持久化、可擴展和高性能的特點，廣泛應用于大數據領域。
特性：
使用方法：
首先需要安裝Kafka服務器，并啟動它。然后可以使用Java或C#等編程語言通過Kafka的客戶端庫來發送和接收消息。
示例代碼（Java）：
// 發送消息Properties props = new Properties();props.put("bootstrap.servers", "localhost:9092");props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");try (Producer<String, String> producer = new KafkaProducer<>(props)) { String topic = "my-topic"; String message = "Hello, Kafka!"; producer.send(new ProducerRecord<>(topic, message)); System.out.println("Sent message: " + message);}// 接收消息Properties props = new Properties();props.put("bootstrap.servers", "localhost:9092");props.put("group.id", "my-group");props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");try (Consumer<String, String> consumer = new KafkaConsumer<>(props)) { String topic = "my-topic"; consumer.subscribe(Collections.singletonList(topic)); while (true) { ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100)); for (ConsumerRecord<String, String> record : records) { String message = record.value(); System.out.println("Received message: " + message); } }}優缺點：
ActiveMQ是一個開源的消息隊列中間件，支持多種消息協議，包括AMQP、STOMP和OpenWire等。它具有可靠性、可擴展性和高性能的特點，廣泛應用于企業級應用。
特性：
使用方法：
首先需要安裝ActiveMQ服務器，并啟動它。然后可以使用Java或C#等編程語言通過ActiveMQ的客戶端庫來發送和接收消息。
示例代碼（Java）：
// 發送消息ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");try (Connection connection = factory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)) { Destination destination = session.createQueue("my-queue"); MessageProducer producer = session.createProducer(destination); TextMessage message = session.createTextMessage("Hello, ActiveMQ!"); producer.send(message); System.out.println("Sent message: " + message.getText());}// 接收消息ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");try (Connection connection = factory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)) { Destination destination = session.createQueue("my-queue"); MessageConsumer consumer = session.createConsumer(destination); connection.start(); Message message = consumer.receive(); if (message instanceof TextMessage) { TextMessage textMessage= (TextMessage) message; System.out.println("Received message: " + textMessage.getText()); }}優缺點：
特性：
使用方法：
首先需要安裝RocketMQ服務器，并啟動它。然后可以使用Java或其他編程語言通過RocketMQ的客戶端庫來發送和接收消息。
示例代碼（Java）：
// 發送消息DefaultMQProducer producer = new DefaultMQProducer("producer-group");producer.setNamesrvAddr("localhost:9876");producer.start();try { Message message = new Message("topic", "Hello, RocketMQ!".getBytes()); SendResult result = producer.send(message); System.out.println("Sent message: " + result.getSendStatus());} finally { producer.shutdown();}// 接收消息DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumer-group");consumer.setNamesrvAddr("localhost:9876");consumer.subscribe("topic", "*");consumer.registerMessageListener(new MessageListenerConcurrently() { @Override public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> messages, ConsumeConcurrentlyContext context) { for (MessageExt message : messages) { System.out.println("Received message: " + new String(message.getBody())); } return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; }});consumer.start();NATS是一個輕量級的、高性能的消息隊列中間件，由Cloud Native Computing Foundation（CNCF）維護。NATS具有簡單易用、快速和可靠的特點，適用于微服務架構和云原生應用。
特性：
使用方法：
首先需要安裝NATS服務器，并啟動它。然后可以使用Java或其他編程語言通過NATS的客戶端庫來發送和接收消息。
示例代碼（Java）：
// 發送消息Connection connection = Nats.connect("nats://localhost:4222");try { connection.publish("subject", "Hello, NATS!".getBytes()); System.out.println("Sent message");} finally { connection.close();}// 接收消息Connection connection = Nats.connect("nats://localhost:4222");try { Dispatcher dispatcher = connection.createDispatcher((msg) -> { System.out.println("Received message: " + new String(msg.getData())); }); dispatcher.subscribe("subject"); connection.flush(Duration.ZERO); System.out.println("Listening for messages..."); Thread.sleep(10000);} finally { connection.close();}本文鏈接：http://www.www897cc.com/showinfo-26-42227-0.html熱門的消息隊列框架比較、使用方法、優缺點，提供示例代碼
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號