RabbitMQ生产者和消费者代码参数介绍

	//创建链接工厂
   ConnectionFactory connectionFactory = new ConnectionFactory();
		//设置主机ip地址
		connectionFactory.setHost("192.168.137.25");
		//设置MQ的端口号
		connectionFactory.setPort(5672);
		//设置虚拟主机名
		connectionFactory.setVirtualHost("/ems");
		//虚拟主机设置账号
		connectionFactory.setUsername("ems");
		//虚拟主机设置密码
		connectionFactory.setPassword("123");
		// 创建链接对象
		Connection connection = connectionFactory.newConnection();
		//创建通道
		Channel channel = connection.createChannel();
		
		channel.queueDeclare("/ems",false,false,false,null);
		// 消费信息
		channel.basicConsume("/ems",true,new DefaultConsumer(channel){
			@Override
			public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
				System.out.println(new String(body));
			}
		});

		channel.close();
		connection.close();
	}

ConnectionFactory connectionFactory = new ConnectionFactory();
		connectionFactory.setHost("192.168.137.25");
		connectionFactory.setPort(5672);
		connectionFactory.setUsername("ems");
		connectionFactory.setPassword("123");
		connectionFactory.setVirtualHost("/ems");

		Connection connection = connectionFactory.newConnection();
		Channel channel = connection.createChannel();

		channel.queueDeclare("ems",false,false,false,null);
		// 发布消息
		channel.basicPublish("","ems",null,"hello world".getBytes());
		System.out.println("完成");
		channel.close();
		connection.close();