RabbitMQ其实就是消息队列。是软件开发中经常用到的通信方法。像IBM WEBSPHERE MQ等等做的都很成熟,今天就说说MQ在java中使用方法。
工具/原料
eclipse
RabbitMQ
java如何使用rabbitmq
1、打开eclipse开发工具,点击导航栏上的【File】菜单,然后在点击New,新建个Maven Project,在新建的项目里演示RabbitMQ在java中的使用。如下图所示。
2、项目新建完成后,会自咿蛙匆盗动生成个pom文件,打开pom文件,添加上RabbitMQ的依赖包,如下图所示。<dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>3.0.4</version> </dependency>
3、RabbitMQ消息队列就是应用在通信里,这里我们就用java模拟生产,消费二者的通信。新建个Consumer类,作为消费类,具体代码,如下图所示。
4、接着在新建个生产者Producer类,代码类似Consumer类,具体请看我的截图,如下图所示。
5、消费和生产类都实现好后,我们先运行消费者类,选中Consumer后,右键鼠标,然后点击【Run As】--->【Run on server】,如下图所示。
6、消费类运行后,在选中生产Producer类,右键鼠标,然后点击【Run As】--->【Run on server】,如下图所示。
7、运行后,可以在eclipse的Console控制台那里看到MQ的通信,我们可以看到先运行的消费类,但是并没有执行而是等待,因为没有生产,是不可能消费的,得到的结果是正确的,如下图所示。