1 public class EmitLog
 2 {
 3     private final static String EXCHANGE_NAME = "ex_log";
 4
 5     public static void main(String[] args) throws IOException
 6     {
 7         // 创建连接和频道
 8         ConnectionFactory factory = new ConnectionFactory();
 9         factory.setHost("localhost");
10         Connection connection = factory.newConnection();
11         Channel channel = connection.createChannel();
12         // 声明转发器和类型
13         channel.exchangeDeclare(EXCHANGE_NAME, "fanout" );
14
15         String message = new Date().toLocaleString()+" : log something";
16         // 往转发器上发送消息
17         channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes());
18
19         System.out.println(" [x] Sent '" + message + "'");
20
21         channel.close();
22         connection.close();
23
24     }
25
26 }  

 1 public class ReceiveLogsToSave
 2 {
 3     private final static String EXCHANGE_NAME = "ex_log";
 4
 5     public static void main(String[] argv) throws java.io.IOException,
 6             java.lang.InterruptedException
 7     {
 8         // 创建连接和频道
 9         ConnectionFactory factory = new ConnectionFactory();
10         factory.setHost("localhost");
11         Connection connection = factory.newConnection();
12         Channel channel = connection.createChannel();
13
14         channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
15         // 创建一个非持久的、唯一的且自动删除的队列
16         String queueName = channel.queueDeclare().getQueue();
17         // 为转发器指定队列，设置binding
18         channel.queueBind(queueName, EXCHANGE_NAME, "");
19
20         System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
21
22         QueueingConsumer consumer = new QueueingConsumer(channel);
23         // 指定接收者，第二个参数为自动应答，无需手动应答
24         channel.basicConsume(queueName, true, consumer);
25
26         while (true)
27         {
28             QueueingConsumer.Delivery delivery = consumer.nextDelivery();
29             String message = new String(delivery.getBody());
30
31             print2File(message);
32         }
33
34     }
35
36     private static void print2File(String msg)
37     {
38         try
39         {
40             String dir = ReceiveLogsToSave.class.getClassLoader().getResource("").getPath();
41             String logFileName = new SimpleDateFormat("yyyy-MM-dd")
42                     .format(new Date());
43             File file = new File(dir, logFileName+".txt");
44             FileOutputStream fos = new FileOutputStream(file, true);
45             fos.write((msg + "\r\n").getBytes());
46             fos.flush();
47             fos.close();
48         } catch (FileNotFoundException e)
49         {
50             e.printStackTrace();
51         } catch (IOException e)
52         {
53             e.printStackTrace();
54         }
55     }
56 }  

 1 public class ReceiveLogsToConsole
 2 {
 3     private final static String EXCHANGE_NAME = "ex_log";
 4
 5     public static void main(String[] argv) throws java.io.IOException,
 6             java.lang.InterruptedException
 7     {
 8         // 创建连接和频道
 9         ConnectionFactory factory = new ConnectionFactory();
10         factory.setHost("localhost");
11         Connection connection = factory.newConnection();
12         Channel channel = connection.createChannel();
13
14         channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
15         // 创建一个非持久的、唯一的且自动删除的队列
16         String queueName = channel.queueDeclare().getQueue();
17         // 为转发器指定队列，设置binding
18         channel.queueBind(queueName, EXCHANGE_NAME, "");
19
20         System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
21
22         QueueingConsumer consumer = new QueueingConsumer(channel);
23         // 指定接收者，第二个参数为自动应答，无需手动应答
24         channel.basicConsume(queueName, true, consumer);
25
26         while (true)
27         {
28             QueueingConsumer.Delivery delivery = consumer.nextDelivery();
29             String message = new String(delivery.getBody());
30             System.out.println(" [x] Received '" + message + "'");
31
32         }
33
34     }
35
36 }