zoukankan      html  css  js  c++  java
  • RabbitMQ + Springboot +“Hello Word”

    https://www.rabbitmq.com/getstarted.html 

    官网文档

    (P) - > [|||]

    我们将呼叫我们的消息发布者(发送者)发送和我们的消息消费者(接收者) Recv发布者将连接到RabbitMQ,发送单个消息,然后退出

    创建一个Send.java 根据 springboot 配置文件配置

    @Component
    public class Send {
    //设置类命名队列
    private final static String QUEUE_NAME = "hello";

    @Value("${spring.rabbitmq.host}")
    private String host;
    @Value("${spring.rabbitmq.port}")
    private int port;
    @Value("${spring.rabbitmq.username}")
    private String username;
    @Value("${spring.rabbitmq.password}")
    private String password;

    public void send(){
    //船舰到服务器的链接
    ConnectionFactory factory = new ConnectionFactory();
    factory.setPort(port);
    factory.setPassword(password);
    factory.setUsername(username);
    factory.setHost(host);
    Connection connection = null;
    Channel channel = null;
    try{
    connection = factory.newConnection();
    channel = connection.createChannel() ;
    channel.queueDeclare(QUEUE_NAME,false,false,false,null);
    for(int i = 0;i<5;i++) {
    String value = "hello··········";
    channel.basicPublish("", QUEUE_NAME, null, value.getBytes());
    }
    }catch (Exception e){

    }finally {
    try {
    //关闭链接 不然一直消耗
    channel.close();
    connection.close();
    }catch (Exception e){
    e.printStackTrace();
    }
    }

    }
    }

    配置文件

    ########### rabbitmq  ############
    spring.rabbitmq.host=XXX.xxx.xxx.xx
    spring.rabbitmq.port=xxx
    spring.rabbitmq.username=xxx
    spring.rabbitmq.password=xxx

    启动类

        @Override
        public void run(String... args) throws Exception {
            Send.init();
            
        }

    项目启动后 到

     查看

    发送的信息

    消费端接收

    public static void main (String [] argv) throws Exception{
            //创建服务器的链接
            ConnectionFactory factory = new ConnectionFactory();
            //创建
            factory.setHost("xxxx.xxxx.xxxx.xxxx");
            factory.setPassword("guest");
            factory.setUsername("guest");
            factory.setPort(xxxx);
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel() ;
            channel.queueDeclare(QUEUE_NAME,false,false,false,null);
            DefaultConsumer defaultConsumer = new DefaultConsumer(channel){
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                    String s = new String(body);
                    System.out.println("接受到的消息:"+s);
                }
            };
            channel.basicConsume(QUEUE_NAME,true,defaultConsumer);
    
       }

     

  • 相关阅读:
    How to Automate IIS 7 Configuration with .NET
    windows phone 学习
    Redis VS. Memcached
    ROWNUM使用方法
    摘自----聊聊盛大的经验值
    理解Sql语句
    Odp.net 动态创建变量in
    ORACLE PLSQL DEVELOPER 中显示科学计数法
    http error 500.22 internal server error
    Resharper8 visual studio 中文版 快捷键无法使用
  • 原文地址:https://www.cnblogs.com/wudixiaoguaishou/p/11400162.html
Copyright © 2011-2022 走看看