`

rabbitmq使用入门

阅读更多

      

RabbitMQ简介

MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。通常用于不同进程和服务之间的业务解耦。

简单说明

MQ是消费-生产者模型的一个典型的代表,一端往消息队列中不断写入消息,而另一端则可以读取或者订阅队列中的消息。

基本概念

Broker:简单来说就是消息队列服务器实体。

Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。

Queue:消息队列载体,每个消息都会被投入到一个或多个队列。

Binding:绑定,它的作用就是把exchange和queue按照路由规则绑定起来。

Routing Key:路由关键字,exchange根据这个关键字进行消息投递。

vhost:虚拟主机,一个broker里可以开设多个vhost,用作不同用户的权限分离。

producer:消息生产者,就是投递消息的程序。

consumer:消息消费者,就是接受消息的程序。

channel:消息通道,在客户端的每个连接里,可建立多个channel,每个channel代表一个会话任务。

RabbitMQ使用指南

安装

sudo apt-get install rabbitmq-server
service rabbitmq-server start

rabbitmq管理

基本信息管理

rabbitmqctl用于管理rabbitmq-server,常用的命令包括了 status, report

管理插件

启用管理插件

rabbitmq-plugins enable rabbitmq_management

访问url: HTTP://192.168.1.119:15672/;用户名:guest;密码:guest;

RabbitMQ程序使用入门

创建Maven工程

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

<dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>3.8.1</version>
    <scope>test</scope>
</dependency>

Consumer

import com.rabbitmq.client.*;
import java.io.IOException;

public class Application {

    public static void main(String[] argv) throws Exception {

        String QUEUE_NAME = "hello";
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.168.1.119");
        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);

    }
}

producer

import com.rabbitmq.client.*;
import junit.framework.TestCase;

import java.io.IOException;

/**
 * Created by fiboliu on 16-1-21.
 */
public class ApplicationTest extends TestCase {

    public void testMain() throws Exception {
        String QUEUE_NAME = "hello";
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.168.1.119");
        Connection connection = null;
        Channel channel = null;

        try {
            connection = factory.newConnection();
            channel = connection.createChannel();
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            String message = "Hello World!";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
            System.out.println(" [x] Sent '" + message + "'");
        } catch (Exception e) {

        } finally {
            try {
                channel.close();
                connection.close();
            } catch (Exception e) {

            }
        }
    }
}

创建

参考文献:

http://blog.csdn.net/column/details/rabbitmq.html

分享到:
评论

相关推荐

    RabbitMQ从入门到放弃

    ### RabbitMQ从入门到放弃——理解消息队列与RabbitMQ #### 消息队列简介 消息队列(Message Queue, MQ)作为一种重要的中间件技术,它提供了应用程序间的一种通信方式,通过写入和读取出入列队的消息来进行通信,...

    RabbitMq开发入门.docx

    在使用 RabbitMQ 之前,需要先配置好连接,确保双方的连接配置一致。否则,无法传递消息。连接配置包括主机名、端口号、用户名、密码等信息。 2. MQ sending principle RabbitMQ 的发送原理可以分为三步:第一步是...

    RabbitMQ快速入门及API介绍(401M)

    RabbitMQ快速入门及API介绍(401M) QQ截图 20191220230107.png?x-oss-process=style/pnp8 (42.73KB, 下载次数:227) 下载附件 2019-12-2023 :01 上传【课程介绍】:第一章 : RabbitMQ介绍:消息中间件概念、RabbitMQ...

    RabbitMQ极速入门.zip

    【RabbitMQ极速入门】 RabbitMQ是一款广泛使用的开源消息队列系统,它基于Advanced Message Queuing Protocol(AMQP)标准,提供可靠、灵活的消息传递服务。作为一个分布式系统的支柱,RabbitMQ允许不同组件之间...

    消息中间件rabbitmq的入门.zip

    消息中间件rabbitmq的入门

    Rabbitmq入门到精通.doc

    【RabbitMQ 入门到精通】:RabbitMQ 是一款流行的消息中间件,它基于 AMQP(Advanced Message Queuing Protocol)协议实现,用于在分布式系统中高效地传输消息,从而实现异步处理、解耦和流量控制。本教程旨在帮助...

    rabbitMq入门

    【标题】:“rabbitMQ入门” 在IT行业中,消息队列是一种常见的中间件技术,用于解耦应用程序组件,提高系统的可扩展性和可靠性。RabbitMQ是一个开源的消息代理和队列服务器,广泛应用于分布式系统中。本篇文章将带...

    rabbitMQ代码案例 简单入门

    这个“rabbitMQ代码案例 简单入门”的资料包为初学者提供了了解和学习RabbitMQ的基础知识。 首先,让我们了解一下RabbitMQ的基本概念: 1. **消息队列**:RabbitMQ的核心是消息队列,它负责存储和转发消息。生产者...

    十六、RabbitMQ快速入门

    【RabbitMQ快速入门】 RabbitMQ是一款广泛使用的开源消息队列系统,它基于AMQP(Advanced Message Queuing Protocol)协议,提供高可用性、可靠性和可扩展性,是分布式系统中实现异步任务处理、解耦组件以及负载...

    RabbitMQ 入门教程(JAVA)

    ### RabbitMQ 入门教程(JAVA) #### 一、RabbitMQ 概述 RabbitMQ 是一个消息中间件,其主要功能是接收来自生产者的消息,并根据规则将其路由、缓冲以及持久化后传递给消费者。RabbitMQ 和消息传递系统通常会使用...

    Rabbitmq笔记+入门教程+示例

    **开发语言**:RabbitMQ 使用 Erlang 语言编写,Erlang 是一种面向并发的编程语言,非常适合构建高并发和容错性强的系统。 **AMQP**:这是一种开放的协议标准,用于实现消息队列之间的通信。AMQP 协议支持多种消息...

    20.消息中间件之RabbitMQ入门讲解

    消息中间件之RabbitMQ入门讲解”的主题中,我们将深入理解RabbitMQ的核心概念,如何通过控制台进行管理,以及如何在Spring Cloud框架下创建消息生产者和消费者。 首先,让我们了解RabbitMQ的基本概念。RabbitMQ的...

    Linux中安装RabbitMQ急速入门.md

    Linux中安装RabbitMQ急速入门,快速安装,纯小白可直接上手,内容详细步骤明确,只要按照文档中来操作,成功率100%

    .NET中RabbitMQ的入门源码案例

    MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统 源码说明地址:https://www.cnblogs.com/personblog/p/10681741.html

    RabbitMQ从入门到进阶

    - Binding:绑定,定义交换器和队列之间的关系,使用RoutingKey指定路由规则。 - Queue:消息队列,存储消息供消费者消费。 工作流程如下: 1. 生产者连接服务器,创建连接和信道。 2. 生产者声明交换器和队列,...

    rabbitmq基础入门

    RabbitMQ基础入门主要涵盖了MQ的基本概念、使用MQ的原因、MQ的分类以及RabbitMQ的详细知识。MQ,即Message Queue,是一种基于FIFO(先进先出)原则的消息队列服务,用于不同进程间的通信,尤其在互联网架构中,它起...

    RabbitMQ入门介绍,初学者宝典

    RabbitMQ入门介绍,初学者宝典,chm文档,方便阅读。

    第一节-rabbitmq安装以及入门.pdf

    RabbitMQ使用Erlang语言编写,因其性能和稳定性,被众多互联网公司如滴滴、美团、携程、去哪儿等采纳。 RabbitMQ之所以高性能,一方面是由于它使用了Erlang语言,Erlang的性能可以与原生socket的延迟相媲美。另一...

    RabbitMQ入门操作手册.pdf

    【RabbitMQ入门操作手册】提供了全面的RabbitMQ学习指南,从基础概念到实际操作,帮助初学者快速掌握这个强大的消息队列系统。RabbitMQ是一个基于AMQP(Advanced Message Queuing Protocol)的开源消息代理,其核心...

    RabbitMQ入门代码

    在这个“RabbitMQ入门代码”中,我们将深入探讨如何使用Java来与RabbitMQ进行交互,包括队列持久化、消息持久化、Direct交换机、Fanout交换机和Topic交换机的基础测试代码。 首先,让我们从基础开始,了解如何在...

Global site tag (gtag.js) - Google Analytics