Java的常用中间件解析

Java中间件是指在java应用程序和底层操作系统之间提供了一种可以由多种应用程序访问的服务的软件。常用的Java中间件包括RabbitMQ、Kafka、ActiveMQ等。

一、RabbitMQ

1、RabbitMQ是基于AMQP协议的一种开源的、高度可靠的、可扩展的消息队列系统。

2、它支持多种消息协议，可以用于处理异步任务、消息推送等场景，特别适合做复杂的消息系统的构建。

public void rabbitMQSendMessage(String queueName, String message){
    template.convertAndSend(queueName, message);
}

二、Kafka

1、Kafka是一个分布式的、可分区的、多副本的、基于ZooKeeper协调的消息中间件。

2、它支持大数据实时处理的需求，并且提供了高吞吐量、支持分区的特性。

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producer producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord("my-topic", "my-key", "my-value"));
producer.close();

三、ActiveMQ

1、ActiveMQ是一款完全支持JMS1.1和J2EE的开源消息队列产品。

2、它用于在不同应用程序之间，或者同一应用的不同组件之间，传递数据。

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("TEST.Q");
MessageConsumer consumer = session.createConsumer(destination);
Message message = consumer.receive(1000);
connection.close();