rabbitMQ 常用api翻译

Posted 2020-10-19 longtengdama

1.首先是发布消息者的代码

 

public class MQPublisher {
    public static void main(String[] args) {
        try{
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("123.199.200.54");//129.199.200.54
            factory.setUsername("omsuser");
            factory.setPassword("9aVXR2LLk2xskcDq7ziccWKP");
            factory.setPort(5672);
            Connection connection = factory.newConnection();

            Channel channel = connection.createChannel();
            channel.queueDeclare("ManufactureBill", true, false, false, null);
            String bill = getManufactureBill();
            MQMessage mqmsg=new MQMessage();
            JSONObject jso=JSON.parseObject(bill);//json字符串转换成jsonobject对象
            mqmsg.setObject(jso);
            mqmsg.setType(0);
            String MQjson = JSON.toJSONString(mqmsg,SerializerFeature.WriteMapNullValue);
            //channel.basicPublish("", "ManufactureBill", null, bill.getBytes());
           // channel.queueDelete("ManufactureBill");
            channel.basicPublish("", "ManufactureBill", null, MQjson.getBytes());
           
            channel.close();
            connection.close();
        }catch(Exception e){
            e.printStackTrace();
        }
    }

 定义通道

AMQP.Queue.DeclareOk queueDeclare(String queue,
                                  boolean durable,
                                  boolean exclusive,
                                  boolean autoDelete,
                                  Map<String,Object> arguments)
                           throws IOException

Declare a queue

Parameters:

queue - the name of the queue 通道的名称，消费者要接收信息，名称要与此相同，同一个连接下面会可能有多个通道

durable - true if we are declaring a durable queue (the queue will survive a server restart)  定义一个持久的队列，一般设置为true，当服务器挂掉之后，队列依然存在，

exclusive - true if we are declaring an exclusive queue (restricted to this connection)   定义一个独有队列（不允许别人连接）一般设置为false，不然怎么接受消息

autoDelete - true if we are declaring an autodelete queue (server will delete it when no longer in use)  当服务器不在用到此队列的时候，是否自动删除。一般设置为false，和durable一致

arguments - other properties (construction arguments) for the queue  这个不知道

Returns:

a declaration-confirm method to indicate the queue was successfully declared

Throws:

IOException - if an error is encountered

See Also:

AMQP.Queue.Declare, AMQP.Queue.DeclareOk