本文介绍了java远程连接调用Rabbitmq,分享给大家,希望此文章对各位有所帮助。
打开IDEA创建一个maven工程(Java就可以了)。
pom.xml文件如下
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://.zhenqi;import java.util.HashMap;/** * Created by wuming on 2017/7/16. */public class TestRabbitmq { public static void main(String[] args){ try{ QueueConsumer consumer = new QueueConsumer("queue"); Thread consumerThread = new Thread(consumer); consumerThread.start(); Producer producer = new Producer("queue"); for (int i = 0; i < 100000; i++){ HashMap message = new HashMap(); message.put("message number", i); producer.sendMessage(message); System.out.println("Message Number "+ i +" sent."); } }catch(Exception e){ e.printStackTrace(); } }}以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。