《JavacJavaJar命令》第三篇

Posted 2020-12-03 香农随笔

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了《JavacJavaJar命令》第三篇相关的知识，希望对你有一定的参考价值。

这篇随笔主要写启动 jar 时，如果需要依赖其他的 jar 包该怎么处理，我会以 rabbitMQ 客服端启动为例。

package com.rockcode.www.rabbitmq;

import java.io.IOException;
import java.util.concurrent.TimeoutException;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;

public class Consumer {
    private final static String QUEUE_NAME = "rock";

    public static void main(String[] args) {
        
        ConnectionFactory factory = new ConnectionFactory();
        factory.setUsername("guest");
        factory.setPassword("guest");
        factory.setHost("localhost");
        
        Connection conn;
        try {
            conn = factory.newConnection();
            Channel channel = conn.createChannel();
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
            
            com.rabbitmq.client.Consumer con = new DefaultConsumer(channel) {
                  @Override
                  public void handleDelivery(String consumerTag, Envelope envelope,
                                             AMQP.BasicProperties properties, byte[] body)
                      throws IOException {
                    String message = new String(body, "UTF-8");
                    System.out.println(" [x] Received \'" + message + "\'");
                    
                        try {
                            doWork(message);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                      finally {
                        System.out.println(" [x] Done");
                      }
                    
                  }
                };
            
            channel.basicConsume(QUEUE_NAME, true, con);
            
        } catch (IOException e) {
        } catch (TimeoutException e) {
        }
    
        
    }
    
    private static void doWork(String task) throws InterruptedException {
        for (char ch: task.toCharArray()) {
            if (ch == \'.\') Thread.sleep(1000);
        }
    }

}