Java之常用的消息中间件简介说明

Java中间件简介

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

下文笔者将依次讲述各中简介的简介说明,如下所示

RabbitMQ

RabbitMQ 
    是基于AMQP协议的一种开源的、高度可靠的、可扩展的消息队列系统。
    它支持多种消息协议
      可以用于处理异步任务、消息推送等场景
       特别适合做复杂的消息系统的构建

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

Kafka

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

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

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

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

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

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();