文档章节

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
杨中仁
粉丝 60
博文 36
码字总数 23334
作品 0
南京
程序员
私信 提问
RabbitMQ 实战教程 文集

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

chenssy
10/06
0
0
PHP版 RabbitMQ官方中文入门教程

工作中用到 RabbitMQ,但是RabbitMQ官方的 Tutorials 是英文Python和Jave的,官网的教程很好,正好最近业余在撸Python,所以直接来搞个PHP版本的,仅供PHP菜鸟一起来入门学习,如有错误和问题...

Yuansir
2013/06/03
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
0
0
springCloud-10. RabbitMQ基础使用

目标 A.完成RabbitMQ消息发送 B.完成RabbitMQ消息接收 前面已有RabbitMQ的安装教程,这里就不再讲安装 1.修改配置 2.创建RabbitMQ消息接收类 3.创建RabbitMQ消息发送类 4.启动项目,刷新htt...

贺小康
08/09
0
0
RabbitMQ基础教程之基本使用篇

RabbitMQ基础教程之基本使用篇 最近因为工作原因使用到RabbitMQ,之前也接触过其他的mq消息中间件,从实际使用感觉来看,却不太一样,正好趁着周末,可以好好看一下RabbitMQ的相关知识点;希...

小灰灰Blog
06/02
0
0

没有更多内容

加载失败,请刷新页面

加载更多

腾讯与Github的魔幻会面背后的故事…

10月22日,腾讯开源管理办公室有幸邀请到Github新晋CEO Nat Friedman,前来鹅厂参观交流。目前腾讯已经有近70个项目在Github上开源,共获得17w stars,世界排名11位。Github是腾讯开源的主阵...

腾讯开源
22分钟前
1
0
单例模式

单例模式(Singleton pattern)属于创建型设计模式。 保证一个类仅有一个实例,并提供一个访问它的全局访问点。 通常我们可以让一个全局变量使得一个对象被访问,但它不能防止你实例化多个对...

NinjaFrog
27分钟前
0
0
TypeScript基础入门之装饰器(三)

转载 TypeScript基础入门之装饰器(三) 继续上篇文章[TypeScript基础入门之装饰器(二)] 访问器装饰器 Accessor Decorator在访问器声明之前声明。 访问器装饰器应用于访问器的属性描述符,可用...

durban
45分钟前
2
0
spring5调研学习(转载)

Spring框架的新功能 这一章主要提供Spring框架新的功能和变更。 升级到新版本的框架可以参考。Spring git。 内容列表 Spring 5.x框架新的功能 Spring 4.x框架新的功能 Spring 3.x框架新的功能...

小海bug
55分钟前
2
0
为何Spring框架能这么流行?

想要学习更多关于Spring框架在Java开发者中如此流行?看这篇文章可以学到更多! Spring框架特性 Spring是用于应用开发中的一款强大,轻量级框架。更广泛地说,你可以认为Spring框架是一个定义...

java知识分子
57分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部