Java Kafka和ActiveMQ是兩種常見的消息隊(duì)列中間件。Kafka是由Apache Software Foundation發(fā)布的高性能分布式消息系統(tǒng)。ActiveMQ是Apache軟件基金會(huì)的項(xiàng)目之一，是一個(gè)基于JMS規(guī)范的消息傳遞中間件。

相較于ActiveMQ，Kafka的一個(gè)重要特點(diǎn)是其高吞吐量和低延遲，這使得它在大數(shù)據(jù)處理和流處理中得到廣泛應(yīng)用。Kafka使用的發(fā)布訂閱模式和ActiveMQ相同，但是在Kafka中，消息會(huì)被持久化到磁盤并且被保留一段時(shí)間，同時(shí)使用分布式方式進(jìn)行高效地讀寫。

public static void main(String[] args) {
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producerproducer = new KafkaProducer<>(props);
for (int i = 0; i< 100; i++)
producer.send(new ProducerRecord<>("my-topic", Integer.toString(i), Integer.toString(i)));
producer.close();
}

ActiveMQ同樣提供高效的消息傳遞和持久化存儲(chǔ)，特別適用于企業(yè)級應(yīng)用和系統(tǒng)集成。它支持多種協(xié)議和數(shù)據(jù)格式，包括OpenWire、STOMP、AMQP、MQTT等。同時(shí)，ActiveMQ還支持集群和分布式索引，提供了高可用性和水平擴(kuò)展性。

Connection connection = getConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("my-queue");
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("Hello world!");
producer.send(message);
producer.close();
session.close();
connection.close();

總的來說，Kafka和ActiveMQ都是非常強(qiáng)大和靈活的消息隊(duì)列中間件，可以根據(jù)需求和場景選擇性地使用。