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個文件信息