文档章节

rabbitmq使用教程 一直更新

杨中仁
 杨中仁
发布于 2016/10/07 14:55
字数 313
阅读 130
收藏 1

前端时间更新了mac下面安装rabbitmq 下面介绍一下使用这个mq的教程。

首先,打开mq的官网。找到Java的用例。然后试了一下,成功了。

http://www.rabbitmq.com/tutorials/tutorial-one-java.html

main方法方式用例

package org.young.common.test;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * Created by young on 16/10/7.
 */
public class Send {

    private final static String QUEUE_NAME = "mq.queue";

    public static void main(String[] argv) throws java.io.IOException {

        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
//        factory.setUsername("young");
//        factory.setPassword("young");
//        factory.setVirtualHost("/");
//        factory.setPort(5672);

        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();


        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        String message = "Hello World!";
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
        System.out.println(" [x] Sent '" + message + "'");

        channel.close();
        connection.close();

    }

}
package org.young.common.test;

import com.rabbitmq.client.*;

import java.io.IOException;

/**
 * Created by young on 16/10/7.
 */
public class Recv {

    private final static String QUEUE_NAME = "mq.queue";

    public static void main(String[] argv)
            throws java.io.IOException,
            java.lang.InterruptedException {

        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
//        factory.setUsername("young");
//        factory.setPassword("young");
//        factory.setVirtualHost("/");
//        factory.setPort(5672);


        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

        Consumer consumer = 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 + "'");
            }
        };
        channel.basicConsume(QUEUE_NAME, true, consumer);

    }
}

 

 [*] Waiting for messages. To exit press CTRL+C
 [x] Received 'Hello World!'

 

这样 上面的步骤就完成了。后来查看一下源码 发现 如果你什么都不设置。源码下面是有默认设置的。

 

下面要是遇到什么问题,会在这篇文章下面更新。

 

 

© 著作权归作者所有

共有 人打赏支持
上一篇: JVM调优参数设置
下一篇: mac安装rabbitmq
杨中仁
粉丝 61
博文 37
码字总数 24184
作品 0
南京
程序员
私信 提问
RabbitMQ 实战教程 文集

RabbitMQ 实战教程 文集 此系列博客经梁总(梁桂钊的博客)授权录入本站点,下面推荐下梁总的技术公众号【服务端的思维】,公众号不定时更新技术文章,干货满满!! RabbitMQ 实战教程(一) He...

chenssy
10/06
0
0
win10安装rabbitmq3.7.2报错

大家好,最近新安装了win10系统,安装了rabbitmq一直不能启动, Erlang 9.1版本+rabbitmq3.7.2版本,配置好了:ERLANG_HOME,然后安装mq,按照教程执行: rabbitmq-plugins.bat enable rabb...

樱木花道VS康
06/21
1K
1
RabbitMQ 3.6.2 milestone4 发布

RabbitMQ 3.6.2 milestone4 发布了。 更新内容: 1.服务器 Bug 修复 略 功能改进 Connections now emit stats unconditionally when they are blocked and unblocked by resource alarms. T......

淡漠悠然
2016/04/18
1K
1
center 安装 rabbitMQ

centerOs 安装 消息队列 rabbitMQ 下载 https://www.erlang-solutions.com/resources/download.html 编辑文件 centOS7 安装 使用 yum 安装, 推荐安装方式(解决依赖) 下载 rabbitMQ-server ht...

anziguoer
08/28
0
0
RabbitMQ 3.7.4-rc.3 发布,Bug 修复

RabbitMQ 3.7.4-rc.3 发布了。RabbitMQ 是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 写成,因此也是继承了这...

淡漠悠然
02/27
713
0

没有更多内容

加载失败,请刷新页面

加载更多

错误: 找不到或无法加载主类

在IDEA的使用过程中,经常断掉服务或者重启服务,最近断掉服务重启时突然遇到了一个启动报错: 错误:找不到或无法加载主类 猜测:1,未能成功编译; 尝试:菜单---》Build---》Rebuild Pro...

安小乐
16分钟前
1
0
vue路由传参,刷新页面,引发的bug

最近遇到一个bug 通过vue路由跳转到页面, 然后接参控制(v-if ),成功显示 而刷新页面,显示失败。 苦苦地找了半天原因,打印参数发现正确,再打印下类型......,路由跳过来会保持传参时的...

hanbb
16分钟前
0
0
【58沈剑 架构师之路】InnoDB,select为啥会阻塞insert?

MySQL的InnoDB的细粒度行锁,是它最吸引人的特性之一。 但是,如《InnoDB,5项最佳实践》所述,如果查询没有命中索引,也将退化为表锁。 InnoDB的细粒度锁,是实现在索引记录上的。 一,Inn...

张锦飞
19分钟前
0
0
冒泡,选择和插入排序比较

/** * 冒泡排序,两层嵌套循环,内层局部比较后,找出最大或者最小数据并交换数据,使其局部有序,外层用于比较剩余元素,相较于选择排序,选择排序相当于是冒泡的一个优化版本(减少了交换...

strict_nerd
20分钟前
0
0
html内联(行内)元素、块级(块状)元素和行内块元素分类

HTML可以将元素分类方式分为内联(行内)元素、块级(块状)元素和行内块元素三种。 注:HTML是标签语言,那么既然是标签,就可以自己定义一些自己元素(如<wode>自定义的元素</wode>等),自...

NB-One
26分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部