# 安装
rpm -ivh erlang-21.3.8.9-1.el7.x86_64.rpm 
rpm -ivh socat-1.7.3.2-1.el6.lux.x86_64.rpm 
rpm -ivh rabbitmq-server-3.8.1-1.el7.noarch.rpm 

# 卸载
#rpm -qa | grep rabbitmq

# 启用管理插件
rabbitmq-plugins enable rabbitmq_management

# 启动rabbitmq
systemctl start rabbitmq-server.service
#systemctl status rabbitmq-server.service
#systemctl restart rabbitmq-server.service
#systemctl stop rabbitmq-server.service

# 查看进程
ps -ef | grep rabbitmq

# 添加管理员账号密码
rabbitmqctl add_user admin admin

# 分配账号角色
rabbitmqctl set_user_tags admin administrator

# 修改密码（需要修改一次密码，否则无法登录）
rabbitmqctl change_password admin 123456

# 查看用户列表
rabbitmqctl list_users

	<dependencies>
		<dependency>
			<groupid>org.springframework.boot</groupid>
			<artifactid>spring-boot-starter-amqp</artifactid>
		</dependency>

		<dependency>
			<groupid>com.alibaba</groupid>
			<artifactid>fastjson</artifactid>
		</dependency>

		<dependency>
			<groupid>org.projectlombok</groupid>
			<artifactid>lombok</artifactid>
		</dependency>
	</dependencies>

package com.indi.srb.rabbitutil.config;

@configuration
public class mqconfig {
    @bean
    public messageconverter messageconverter(){
        // json字符串转换器
        return new jackson2jsonmessageconverter();
    }
}

package com.indi.srb.rabbitutil.constant;

public class mqconst {
    public static final string exchange_topic_sms = "exchange.topic.sms";//交换机
    public static final string routing_sms_item = "routing.sms.item";//路由
    public static final string queue_sms_item  = "queue.sms.item";//消息队列
}

package com.indi.srb.rabbitutil.service;

@service
@slf4j
public class mqservice {
    @resource
    private amqptemplate amqptemplate;

    /**
     * 发送消息
     * @param exchange  交换机
     * @param routingkey    路由
     * @param message   消息
     * @return
     */
    public boolean sendmessage(string exchange,string routingkey, object message){
        log.info("发送消息");
        amqptemplate.convertandsend(exchange,routingkey,message);
        return true;
    }
}

package com.indi.srb.base.dto;

@data
@apimodel(description = "短信")
public class smsdto {
    @apimodelproperty(value = "手机号")
    private string mobile;

    @apimodelproperty(value = "消息内容")
    private string message;
}

		<!-- 需要依赖rabbit-mq -->
		<dependency>
			<groupid>com.indi</groupid>
			<artifactid>rabbit-mq</artifactid>
			<version>1.0-snapshot</version>
		</dependency>

  #spring:
  rabbitmq:
    host: 虚拟机ip
    port: 5672
    virtual-host: /srbhost
    username: srbuser
    password: 123456

    // 根据bindcode获取手机号
	string getmobilebybindcode(string bindcode);

    @override
    public string getmobilebybindcode(string bindcode) {
        querywrapper<userinfo> querywrapper = new querywrapper<>();
        querywrapper.select("mobile").eq("bind_code",bindcode);
        userinfo userinfo = basemapper.selectone(querywrapper);
        return userinfo.getmobile();
    }

    @resource
    private userinfoservice userinfoservice;

    @resource
    private mqservice mqservice;

    @transactional(rollbackfor = exception.class)
    @override
    public string notify(map<string, object> parammap) {
        log.info("发消息");
        string mobile = userinfoservice.getmobilebybindcode(bindcode);
        smsdto smsdto = new smsdto();
        smsdto.setmobile(mobile);
        smsdto.setmessage("充值成功");
        mqservice.sendmessage(mqconst.exchange_topic_sms,mqconst.routing_sms_item,smsdto);
        return "success";
    }

		<!-- 需要依赖rabbit-mq -->
		<dependency>
			<groupid>com.indi</groupid>
			<artifactid>rabbit-mq</artifactid>
			<version>1.0-snapshot</version>
		</dependency>

  #spring:
  rabbitmq:
    host: 虚拟机ip
    port: 5672
    virtual-host: /srbhost
    username: srbuser
    password: 123456

package com.indi.srb.sms.receiver;

@component
@slf4j
public class smsreceiver {
    @resource
    private smsservice smsservice;

    // 此处的exchange与key必须与发消息传的一致
    @rabbitlistener(bindings = @queuebinding(
            value = @queue(value = mqconst.queue_sms_item, durable = "true"),
            exchange = @exchange(value = mqconst.exchange_topic_sms),
            key = {mqconst.routing_sms_item}
    ))
    public void send(smsdto smsdto) throws ioexception {
        log.info("smsreceiver 消息监听");
        map<string, object> param = new hashmap<>();
        param.put("code", smsdto.getmessage());
        smsservice.send(smsdto.getmobile(), smsproperties.template_code, param);
    }
}