大橙子网站建设,新征程启航

为企业提供网站建设、域名注册、服务器等服务

Java中间消息件ActiveMQ怎么用

这篇文章将为大家详细讲解有关Java中间消息件ActiveMQ怎么用,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

网站建设哪家好,找创新互联!专注于网页设计、网站建设、微信开发、小程序制作、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了舟山免费建站欢迎大家使用!

什么是中间消息间吧。

采用消息传送机制/消息队列 的中间件技术,进行数据交流,用在分布式系统的集成。Java中对Jms有了定义,这是Java消息的统一接口。什么是ActiveMq呢?这是这个接口的一种实现,相当于数据库连接驱动一样,不同厂商有自己不同的实现,我们尽快看怎么用代码实现吧。

消息一共有两种接收和发送形式:点对点和发布定阅模式,也就是“一对一”和“一对多”。

1.导包(maven):

     org.apache.activemq      activemq-client      5.13.4    

2.开始写类,提供者(发送者)和消费者(接收者)是两个不同的项目,我们先创建普通的maven项目,而不是web项目点对点的方式(消息只能被消费一次,如果同时有多个消费者,谁先抢到就是谁的)

消息提供者

public static void main(String[] args) throws JMSException {    //创建连接工厂,这个参数就是自己的activeMQ的地址    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");    //2.创建连接    Connection connection = connectionFactory.createConnection();    //3.启动连接    connection.start();    //4.获取session(会话对象)    /*    arg0 是否启用事务    arg1 消息的确认方式 自动确认     */    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);    //5.创建一个队列对象,名称    Queue firstQueue = session.createQueue("firstQueue");    //6.创建一个消息的生产者对象//    Destination destination = ;//目标对象    MessageProducer producer = session.createProducer(firstQueue);    //7.创建一个消息    TextMessage textMessage = session.createTextMessage("欢迎来到奇的天喻软件");    //8.发送消息    producer.send(textMessage);    //9.关闭资源    producer.close();    session.close();    connection.close();  }

消息消费者

前几步是一样的,都是创建连接,只有第6步不一样,创建的是一个消费者

public static void main(String[] args) throws JMSException, IOException {    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");    //2.创建连接    Connection connection = connectionFactory.createConnection();    //3.启动连接    connection.start();    //4.获取session(会话对象)    /*    arg0 是否启用事务    arg1 消息的确认方式 自动确认     */    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);    //5.创建一个队列对象,名称    Queue firstQueue = session.createQueue("firstQueue");    //6.创建消息消费者对象    MessageConsumer consumer = session.createConsumer(firstQueue);    //7.设置监听    consumer.setMessageListener(new MessageListener() {      @Override      public void onMessage(Message message) {        TextMessage textMessage = (TextMessage)message;        try {          System.out.println("提取的消息是"+textMessage.getText());        } catch (JMSException e) {          e.printStackTrace();        }      }    });    //8.等待键盘输入    //目的是为了让程序停止来看效果    System.in.read();    //9.关闭资源    consumer.close();    session.close();    connection.close();  }

发布订阅模式(发布消息后,只有在之前运行的消费者才能收到,消息被任何一个消费者消费后,以后启动的消费者不能消费之前的消息)

消息提供者

//创建连接工厂    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");    //2.创建连接    Connection connection = connectionFactory.createConnection();    //3.启动连接    connection.start();    //4.获取session(会话对象)    /*    arg0 是否启用事务    arg1 消息的确认方式 自动确认     */    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);    //5    Topic topic = session.createTopic("first-topic");    //6.创建一个消息的生产者对象//    Destination destination = ;//目标对象    MessageProducer producer = session.createProducer(topic);    //7.创建一个消息    TextMessage textMessage = session.createTextMessage("欢迎来到奇的天喻软件");    //8.发送消息    producer.send(textMessage);    //9.关闭资源    producer.close();    session.close();    connection.close();

消费者

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");    //2.创建连接    Connection connection = connectionFactory.createConnection();    //3.启动连接    connection.start();    //4.获取session(会话对象)    /*    arg0 是否启用事务    arg1 消息的确认方式 自动确认     */    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);    //5    Topic topic = session.createTopic("first-topic");    //6.创建消息消费者对象    MessageConsumer consumer = session.createConsumer(topic);    //7.设置监听    consumer.setMessageListener(new MessageListener() {      @Override      public void onMessage(Message message) {        TextMessage textMessage = (TextMessage)message;        try {          System.out.println("提取的消息是"+textMessage.getText());        } catch (JMSException e) {          e.printStackTrace();        }      }    });    //8.等待键盘输入    //目的是为了让程序停止来看效果    System.in.read();    //9.关闭资源    consumer.close();    session.close();    connection.close();

关于“Java中间消息件ActiveMQ怎么用”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。


文章名称:Java中间消息件ActiveMQ怎么用
文章来源:http://dzwzjz.com/article/jsgiee.html
在线咨询
服务热线
服务热线:028-86922220
TOP