rabbitmq-demo学习

rabbitmq学习实例，几种交换类型的demo和与spring结合的demo

package cn.slimsmart.rabbitmq.demo.fanout;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;

public class ReceiveLogsToConsole {
	private final static String EXCHANGE_NAME = “ex_log“;  
	public static void main（String[] args） throws Exception {
		// 创建连接和频道  
        ConnectionFactory factory = new ConnectionFactory（）;  
        factory.setHost（“192.168.101.174“）;
		// 指定用户 密码
		factory.setUsername（“admin“）;
		factory.setPassword（“admin“）;
		// 指定端口
		factory.setPort（AMQP.PROTOCOL.PORT）;
        Connection connection = factory.newConnection（）;  
        Channel channel = connection.createChannel（）;  
  
        channel.exchangeDeclare（EXCHANGE_NAME “fanout“）;  
        // 创建一个非持久的、唯一的且自动删除的队列  
        String queueName = channel.queueDeclare（）.getQueue（）;  
        // 为转发器指定队列，设置binding  
        channel.queueBind（queueName EXCHANGE_NAME ““）;  
  
        System.out.println（“ [*] Waiting for messages. To exit press CTRL+C“）;  
  
        QueueingConsumer consumer = new QueueingConsumer（channel）;  
        // 指定接收者，第二个参数为自动应答，无需手动应答  
        channel.basicConsume（queueName true consumer）;  
  
        while （true）  
        {  
            QueueingConsumer.Delivery delivery = consumer.nextDelivery（）;  
            String message = new String（delivery.getBody（））;  
            System.out.println（“ [x] Received ‘“ + message + “‘“）;  
  
        }  
	}

}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       1716  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\fanout\ReceiveLogsToConsole.java

     文件       3114  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\fanout\ReceiveLogsToFile.java

     文件       2029  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\fanout\SendLog.java

     文件       1813  2014-11-08 19:22  src\main\java\cn\slimsmart\rabbitmq\demo\headers\Consumer.java

     文件       1662  2014-11-08 19:23  src\main\java\cn\slimsmart\rabbitmq\demo\headers\Producer.java

     文件       1732  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\helloword\Receive.java

     文件       1435  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\helloword\Send.java

     文件       2105  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\route\ReceiveLogsDirect.java

     文件       1910  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\route\SendLogDirect.java

     文件       2017  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\rpc\RPCClient.java

     文件        361  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\rpc\RPCMain.java

     文件       2711  2014-11-08 12:11  src\main\java\cn\slimsmart\rabbitmq\demo\rpc\RPCServer.java

     文件        284  2014-11-08 12:39  src\main\java\cn\slimsmart\rabbitmq\demo\spring\async\Consumer.java

     文件       2393  2014-11-08 10:53  src\main\java\cn\slimsmart\rabbitmq\demo\spring\async\ConsumerConfiguration.java

     文件        286  2014-11-08 11:47  src\main\java\cn\slimsmart\rabbitmq\demo\spring\async\Producer.java

     文件       2562  2014-11-08 11:05  src\main\java\cn\slimsmart\rabbitmq\demo\spring\async\ProducerConfiguration.java

     文件        295  2014-11-08 11:12  src\main\java\cn\slimsmart\rabbitmq\demo\spring\async\Receive.java

     文件        182  2014-11-08 11:33  src\main\java\cn\slimsmart\rabbitmq\demo\spring\async\ReceiveMsgHandler.java

     文件        704  2014-11-08 11:25  src\main\java\cn\slimsmart\rabbitmq\demo\spring\async\Send.java

     文件       3013  2014-11-08 11:02  src\main\java\cn\slimsmart\rabbitmq\demo\spring\sync\AnnotationConfiguration.java

     文件        650  2014-11-08 11:22  src\main\java\cn\slimsmart\rabbitmq\demo\spring\sync\BrokerConfigurationApplication.java

     文件        562  2014-11-08 10:38  src\main\java\cn\slimsmart\rabbitmq\demo\spring\sync\Consumer.java

     文件        581  2014-11-08 10:38  src\main\java\cn\slimsmart\rabbitmq\demo\spring\sync\Producer.java

     文件        639  2014-11-08 10:21  src\main\java\cn\slimsmart\rabbitmq\demo\spring\sync\xml\Consumer.java

     文件        615  2014-11-08 10:21  src\main\java\cn\slimsmart\rabbitmq\demo\spring\sync\xml\Producer.java

     文件        266  2014-11-08 17:33  src\main\java\cn\slimsmart\rabbitmq\demo\spring\tag\ConsumerMain.java

     文件       2938  2014-11-08 17:06  src\main\java\cn\slimsmart\rabbitmq\demo\spring\tag\Gson2JsonMessageConverter.java

     文件        654  2014-11-08 18:06  src\main\java\cn\slimsmart\rabbitmq\demo\spring\tag\ProducerMain.java

     文件        341  2014-11-08 17:09  src\main\java\cn\slimsmart\rabbitmq\demo\spring\tag\ReceiveMessageListener.java

     文件        322  2014-11-08 16:35  src\main\java\cn\slimsmart\rabbitmq\demo\spring\tag\User.java

............此处省略40个文件信息