快捷導(dǎo)航

Java編寫簡易rabbitmq生產(chǎn)者與消費(fèi)者的代碼

更新時(shí)間：2023年11月13日 15:08:52 作者：追逐夢(mèng)想永不停

開發(fā)時(shí)經(jīng)常與其它系統(tǒng)用rabbitmq對(duì)接,當(dāng)需要自測(cè)時(shí),還是自己寫rabbitmq生產(chǎn)者、消費(fèi)者自測(cè)方便些,下面給大家總結(jié)使用java編寫簡易rabbitmq的方法,感興趣的朋友一起看看吧

一、前言

開發(fā)時(shí)經(jīng)常與其它系統(tǒng)用rabbitmq對(duì)接，當(dāng)需要自測(cè)時(shí)，還是自己寫rabbitmq生產(chǎn)者、消費(fèi)者自測(cè)方便些。

下面總結(jié)下不用框架、使用java編寫簡易rabbitmq的方法。

二、代碼

1.導(dǎo)入jar包

(1)如果是maven，那就用

<dependency>
		    <groupId>com.rabbitmq</groupId>
		    <artifactId>amqp-client</artifactId>
		    <version>3.3.4</version>
		</dependency>

(2)如果沒用maven，那就找一個(gè)amqp-client-3.3.4.jar文件，然后引入項(xiàng)目

2.生產(chǎn)者代碼

package RABBIT_MQ;
import com.rabbitmq.client.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class RabbitMQSender {
    //交換機(jī)
    private final static String exchange_name = "x.mySys.test";
    //路由鍵
    private final static String route_key = "topmess";
    public static void main(String[] args) throws IOException, TimeoutException {
        //定義一個(gè)鏈接工廠
        ConnectionFactory connectionFactory = new ConnectionFactory();
        //設(shè)置服務(wù)地址
        connectionFactory .setHost("10.123.123.123");
        //設(shè)定端口
        connectionFactory .setPort(5673);
        //設(shè)定用戶名
        connectionFactory .setUsername("myuser");
        //設(shè)定密碼
        connectionFactory .setPassword("mypass");
        //設(shè)定虛擬機(jī)
        connectionFactory .setVirtualHost("my_host");
        //從mq工具類獲取連接信息
        Connection connection = connectionFactory.newConnection();
        //獲取一個(gè)通道
        Channel channel = connection.createChannel();
        String message = "Hello World!";
        channel.basicPublish(exchange_name, route_key, null, message.getBytes());
        System.out.println("運(yùn)行完畢，已發(fā)送消息【" + message + "】");
        channel.close();
        connection.close();
    }
}

說明：
(1)其中的配置，按照自己的rabbitmq配置更改
(2)生產(chǎn)者配置了交換機(jī)名與路由鍵

3.消費(fèi)者代碼

package RABBIT_MQ;
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 RabbitMQReceiver {
    private static String queue_name="q.mySys.test";
    public static void main(String[] args) throws IOException, TimeoutException {
        //定義一個(gè)鏈接工廠
        ConnectionFactory connectionFactory = new ConnectionFactory();
        //設(shè)置服務(wù)地址
        connectionFactory .setHost("10.123.123.123");
        //設(shè)定端口
        connectionFactory .setPort(5673);
        //設(shè)定用戶名
        connectionFactory .setUsername("myuser");
        //設(shè)定密碼
        connectionFactory .setPassword("mypass");
        //設(shè)定虛擬機(jī)
        connectionFactory .setVirtualHost("my_host");
        //從mq工具類獲取連接信息
        Connection connection = connectionFactory.newConnection();
        //獲取一個(gè)通道
        Channel channel = connection.createChannel();
        //監(jiān)聽該隊(duì)列，false代表手動(dòng)確認(rèn)
        channel.basicConsume(queue_name,false,new DefaultConsumer(channel){
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties basicProperties, byte[] body) throws IOException{
                System.out.println("接收到的消息："+ new String(body,"UTF-8"));
            }
        });
        System.out.println("運(yùn)行完畢，等待mq接收消息");
    }
}

說明：
(1)其中的配置，按照自己的rabbitmq配置更改
(2)消費(fèi)者配置了監(jiān)聽隊(duì)列
(3)消費(fèi)者啟動(dòng)后一直開啟，除非手動(dòng)關(guān)閉項(xiàng)目運(yùn)行

到此這篇關(guān)于Java編寫簡易rabbitmq生產(chǎn)者與消費(fèi)者的文章就介紹到這了,更多相關(guān)Java rabbitmq生產(chǎn)者與消費(fèi)者內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: