30分钟学玩转RabbitMQ

最近在学习RabbitMQ，在网上找了不少资料发现都特高端。动辄集群部署，分布式架构什么的，对于一个初学者实在不够友好。心想求人不如求自己，为什么不自己整理一套资料呢？于是《30分钟学玩转RabbitMQ》诞生。

一、准备工作

据说RabbitMQ是可以部署到Windows环境的，不过作为一个专业级的开发人员怎么能够让这样的事情发生呢？自然我们的准备工作从Linux开始。首先在虚拟机中安装CentOS 7，选择英文，最小安装，默认开启网络以及创建一个root用户：

完成以后进入系统，由于最小安装有一些基本的命令无法使用，因此在进入一下步之前先将ifconfig、vim以及基本的编译环境准备好：

<!-- 安装ifconfig -->
yum install net-tools

<!-- 安装vim -->
yum install yum

<!-- 准备基础编译环境 -->
yum install gcc glibc-devel make ncurses-devel openssl-devel xmlto

接下来我们从官网下载安装包rabbitmq-server-3.7.2-1.el7.noarch.rpm和otp_src_19.3.tar.gz（千万别问我Erlang是什么，我也是第一次知道这门语言）。上传到虚拟机后执行命令：

<!-- 解压包 -->
[[email protected] ~]# tar -xvf otp_src_19.3.tar.gz
[[email protected] ~]# ll

[[email protected] ~]# mkdir /usr/local/erlang
[[email protected] ~]# cd otp_src_19.3
[[email protected] otp_src_19.3]# ./configure --prefix=/usr/local/erlang --without-javac
[[email protected] otp_src_19.3]# make && make install

编译&安装完成以后配置Erlang环境变量：

[[email protected] otp_src_19.3]# vim /etc/profile

#追加环境变量到文件末尾
ERL_HOME=/usr/local/erlang
PATH=$ERL_HOME/bin:$PATH
export ERL_HOME PATH

[[email protected] otp_src_19.3]# source /etc/profile

接下来可以正式安装RabbitMQ：

[[email protected] otp_src_19.3]# cd ..
[[email protected] ~]# rpm -ivh --nodeps rabbitmq-server-3.7.2-1.el7.noarch.rpm

运行RabbitMQ需要首先开放15672和5672端口：

[[email protected] ~]# firewall-cmd --zone=public --add-port=15672/tcp --permanent
[[email protected] ~]# firewall-cmd --zone=public --add-port=5672/tcp --permanent
[[email protected] ~]# firewall-cmd --reload

正常情况下RabbitMQ已经安装完成，最后测试一下：

[[email protected] ~]# rabbitmq-plugins enable rabbitmq_management
[[email protected] ~]# rabbitmq-server

正常启动以后，我们可以在本地使用浏览器中访问管理页面：http://<虚拟机IP>:15672/

  大功告成...

至此，我们的准备工作已经完成了80%。接下来我们需要为RabbitMQ创建用户并赋权。

[[email protected] ~]# rabbitmqctl add_user root root
[[email protected] ~]# rabbitmqctl set_user_tags root administrator
[[email protected] ~]# rabbitmqctl set_permissions -p / root ‘.*‘ ‘.*‘ ‘.*‘
<!-- 后台启动 -->
[[email protected] ~]# rabbitmq-server -detached

重新通过在本地浏览器访问管理页面，输入用户名和密码。

二、简单开发指南

深入的开发案例网上很多，我就不在这里重复的发明轮子了。作为一个指南，这里主要介绍两种开发方式，更加具体的用例我可能会在以后的文章中专门介绍。

1.单独使用——一个简单的消息生产者

通过maven引入依赖

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

创建生产者：

package com.learnhow.rabbitmq;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

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

public class App {
    // 队列名称
    public final static String QUEUE_NAME = "Hello.rabbitMQ";

    public static void main(String[] args) throws IOException, TimeoutException {
        // 连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 配置连接属性
        factory.setHost("192.168.31.244"); // 虚拟机地址
        factory.setPort(5672); // 端口号
        factory.setUsername("root"); // 用户名
        factory.setPassword("root"); // 密码

        // 得到连接，创建通道
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        // 声明一个叫Hello.rabbitMQ的队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        String message = "Hello RabbitMQ";

        // 发送消息
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));

        // 关闭通道和连接
        channel.close();
        connection.close();
    }
}

执行完成以后切换到浏览器的管理页面：

我们发现刚才在main函数中声明的QUEUE NAME已经出现了。

2.Spring AMQP——与Spring Boot集成

Maven依赖：

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.RELEASE</version>
</parent>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
</dependencies>

Spring Boot启动项，声明测试队列：

package org.dispatcher;

import org.springframework.amqp.core.Queue;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class DispatcherApplication {
    @Bean
    public Queue helloQueue() {
        return new Queue("helloQueue");
    }

    public static void main(String[] args) throws Exception {
        SpringApplication.run(DispatcherApplication.class, args);
    }
}

消息生产者：

package org.dispatcher.controller;

import java.util.Date;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class Producer {
    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {
        String sendMsg = "Hi~ " + new Date();
        this.rabbitTemplate.convertAndSend("helloQueue", sendMsg);
    }
}

消息接收者：

package org.dispatcher.controller;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@RabbitListener(queues = "helloQueue")
public class Receiver {
    @RabbitHandler
    public void process(String msg) {
        System.out.println("Receiver: " + msg);
    }
}

Restful接口：

package org.dispatcher.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/rabbitmq")
public class RabbitMqController {
    private static final String SUCCESS = "SUCCESS";
    private static final String FAILURE = "FAILURE";

    @Autowired
    private Producer producer;

    @GetMapping("/push")
    public String push() {
        producer.send();
        return SUCCESS;
    }

}

配置文件application.yml：

server:
  port: 8081
spring:
  rabbitmq:
    host: 192.168.31.244
    port: 5672
    username: root
    password: root
    virtual-host: /
    publisher-confirms: true

启动Spring Boot，访问：http://localhost:8081/rabbitmq/push，再切换到管理页面：

新的QUEUE NAME证明Spring Boot与RabbitMQ整合成功。

原文地址：https://www.cnblogs.com/learnhow/p/8362289.html

时间： 2024-11-15 13:09:58

30分钟学玩转RabbitMQ的相关文章

【30分钟学完】canvas动画|游戏基础(2)：从零开始画画

前言 上篇主要是理论的概述,本篇会多些实践,来讲讲canvas的基础用法,并包含一些基础三角函数的应用,推荐没有canvas基础的朋友阅读,熟悉的朋友可以跳过. 本人能力有限,欢迎牛人共同讨论,批评指正. 一起来画画吧 canvas的API有很多,如果一一列举30分钟你是绝对看不完的,而且怎么流水账还不如自己去看文档呢(笑),本教程的思路是用实例一步一步从无到有讲解基础用法. canvas相关文档 准备工作 布置画布:通过添加<canvas>标签,添加canvas元素: 获取画布:通过<

【30分钟学完】canvas动画|游戏基础(extra1)：颜色那些事

前言 本篇主要讲解关于计算机颜色系统的概念,后续结合一些canvas的应用.因为是"你不知道也没关系"的边缘知识,所以作为本系列教程的扩展,没有兴趣的同学可以跳过. 开始我们万紫千红的故事吧! 本人能力有限,欢迎牛人共同讨论,批评指正. 先从老朋友CSS讲起 我们熟悉的CSS风格颜色表示方式,大体有下面几种,canvas大体是直接沿用这些写法的,但最后包含透明度的写法有些许不同. #RRGGBB:十六进制格式,红绿蓝分别用两位十六进制数表示. #RGB:简写的十六进制格式,转换成6位格

【30分钟学完】canvas动画|游戏基础(extra1-1)：美图我也行

前言 本文是接续系列教程的extra1,主要是介绍颜色系统在canvas中的应用. 本来是与extra1一起成文的,因为segmentfault莫名其妙的字数限制bug只能分割放送了. canvas操纵像素 你如果认为canvas只是画图工具,那接下来的操作会颠覆你的认知.canvas提供api可以获取画布上任何一个像素,并可以自由的操作他们. 获取像素 直接访问像素的功能由canvas上下文中的ImageData对象提供,它提供了以下一组方法,都会返回ImageData对象. getImage

每天坚持30分钟学python——python基础

变量 在使用变量之前,必须先赋值 变量名可以包含字母.数字.下划线,但变量名不能以数字开头 大小写敏感 等号即为赋值 >>> first=3 >>> second=8 >>> three=first+second >>> print(three) 字符串 加上’’或者""即为字符串 在字符串中出现单引号或者双引号需要用\转义 转义字符\可以转义很多字符,比如\n表示换行,\t表示制表符,字符\本身也要转义,所以\\

（再转）30分钟学STL

msflexgrid%E7%9A%84%E7%BC%96%E8%BE%91 http://index.ttplayer.com/songlist/502549479 http://list.mp3.baidu.com/songlist/502170769 http://zhangmen.baidu.cn/songlist/502681933 http://list.mp3.baidu.com/songlist/502684741 http://zhangmen.baidu.cn/songlist

每天坚持30分钟学python

Python介绍 应用领域:Web开发.数据库编程.桌面GUI应用开发.科学与数值计算.教育教学.网络应用开发.软件开发(控制.管理.测试等).游戏与3D影像:游戏开发.网站建设.机器人和航天飞机控制等领域,Python几乎可以用在任何场合. 版本:目前,Python有两个版本,一个是2.x版,一个是3.x版,这两个版本是不兼容的.本教程采用Python 3.4.1. Python是跨平台的,它可以运行在Windows.Mac和各种Linux/Unix系统上.在Windows上写Python程序

【30分钟学完】canvas动画|游戏基础(4)：边界与碰撞

前言 本系列前几篇中常出现物体跑到画布外的情况,本篇就是为了解决这个问题. 阅读本篇前请先打好前面的基础. 本人能力有限,欢迎牛人共同讨论,批评指正. 越界检测 假定物体是个圆形,如图其圆心坐标即是物体的x轴和y轴坐标. 越界是常见的场景,一般会有两种场景的越界:一是整个物体移出区域,二是物体接触到区域边界.我们以画布边界为例进行讨论,示例中矩形边界即是: let top = 0; let bottom = canvas.height; let left = 0; let right = can

Swift简单入门教程：30分钟玩转Swift

通常来说,编程语言教程中的第一个程序应该在屏幕上打印“Hello, world”.在 Swift 中,可以用一行代码实现:    println("hello, world") 如果你写过 C 或者 Objective-C 代码,那你应该很熟悉这种形式——在 Swift 中,这行代码就是一个完整的程序.你不需要为了输入输出或者字符串处理导入一个单独的库.全局作用域中的代码会被自动当做程序的入口点,所以你也不需要main函数.你同样不需要在每个语句结尾写上分号. 这个教程会通过一系列编程

30分钟带你玩转正则表达式

        30分钟带你玩转正则表达式   定义: 正则表达式说白了就是有普通字符.以及特殊字符组成的文子模式.{匹配模式标准} 正则表达式将会作为一个模板与所搜索的字符串进行匹配.可以让使用者轻易达到搜寻/删除/取代某些特定字符的处理程序.此外vim.grep.find.awk.sed等命令都支持正则表达式 注:在这里希望大家搞明白一件事,那就是通配符和正则表达式的区别与关系: 1.正则表达式是用来匹配字符串的,这个就不解释了2.通配符是用来通配的,也就是shell在做Pathname E