角色分类及核心组成部分 RabbitMQ角色分类none不能访问management pluginmanagement列出自己可以通过AMQP登入的虚拟机查看自己的虚拟机节点virtual hosts的queues、exchange、bindings登信息查看和关闭自己的channels和connections查看有关自己的虚拟机节点的统计信息（包括其他用户在这个节点中的活动信息）Policymaker包含management的所有权限查看、创建、删除自己的virtual hosts所属的policies和parametersMonitoring包含management所有权限列出所有的virtual hosts（包括不能登录的virtual hosts）查看其它用户的connections和channels信息查看节点级别的数据，如clustering、memory查看所有的virtual hosts全局统计信息Administrator最高权限创建、删除virtual hosts查看、创建、删除 user查看、创建 permissions关闭所有用户的connectionsRabbitMQ核心组成部分工作流程：图片来源：学相伴 飞哥-RabbitMQ

RabbitMQ 安装官网下载RabbitMQ和Erlang的包（以CentOS7为例）# RabbitMQ https://www.rabbitmq.com/download.html # Erlang https://packages.erlang-solutions.com/erlang-solutions-2.0-1.noarch.rpm安装Erlang1、创建rabbitmq文件夹mkdir -p /usr/rabbitmq2、上传下载的压缩包到刚刚创建的文件夹3、安装Erlang# 解压 rmp -Uvh esl-erlang_23.2.3-1_centos_7_amd64.rpm # 安装 yum install -y erlang # 查看版本号 erl -v # 安装socat yum install -y socat 安装rabbitmqcurl方式安装（速度较慢）：curl -s https://packagecloud.io/install/repositories/rabbitmq/rabbitmq-server/script.rpm.sh | sudo bash上传压缩包解压安装：# 解压 rpm -Uvh rabbitmq-server-3.8.14-1.el7.noarch.rpm # 安装 yum install -y rabbitmq-server # 启动并查看状态 systemctl start rabbitmq-server.service systemctl status rabbitmq-server.service # 设置开机自启 systemctl enable rabbitmq-server.service管理界面及授权操作1.开启客户端Web插件rabbitmq-plugins enable rabbitmq_management注：默认账户guest只能在本机访问管理界面，所以需要进行授权操作2.授权账户# 新增用户 rabbitmqctl add_user admin 123456 # 分配操作权限 rabbitmqctl set_user_tags admin administrator # 为用户添加资源权限 # administrator默认拥有所以权限（无需再添加） rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"用户级别：administrator 登录、查看、管理monitoring 监控者：登录、查看policymaker 策略制定者：登录、指定策略management 普通管理员：登录rabbitmqctl add_user [username] password # 添加用户 rabbitmqctl set_user_tags [permissions] administrator # 分配操作权限 rabbitmqctl change_password [username] NewPassword # 更改密码 rabbitmqctl delete_user [username] # 删除用户 rabbitmqctl list_user # 查看用户列表 rabbitmqctl set_permissions -p / [username] ".*" ".*" ".*" # 分配资源权限Docker安装RabbitMQdocker run -d -p 15672:15672 -p 5672:5672 -p 25672:25672 -p 61613:61613 -p 1883:1883 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=123456 --name myrabbitmq rabbitmq:management查看运行日志：docker logs -f myrabbitmq查看端口是否被占用：netstat -naop|grep [port]

12.代码自动生成器 代码自动生成器package com.sw.mybatisplus; import com.baomidou.mybatisplus.annotation.DbType; import com.baomidou.mybatisplus.annotation.FieldFill; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.generator.AutoGenerator; import com.baomidou.mybatisplus.generator.config.DataSourceConfig; import com.baomidou.mybatisplus.generator.config.GlobalConfig; import com.baomidou.mybatisplus.generator.config.PackageConfig; import com.baomidou.mybatisplus.generator.config.StrategyConfig; import com.baomidou.mybatisplus.generator.config.po.TableFill; import com.baomidou.mybatisplus.generator.config.rules.DateType; import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy; import java.util.ArrayList; /** * @Author suaxi * @Date 2021/4/5 22:10 */ public class CodeGenerator { public static void main(String[] args) { AutoGenerator generator = new AutoGenerator(); //全局配置 GlobalConfig gc = new GlobalConfig(); String projectPath = System.getProperty("user.dir"); gc.setOutputDir(projectPath + "/src/main/java"); gc.setAuthor("suaxi"); //是否打开输出目录 gc.setOpen(false); //是否覆盖之前的 gc.setFileOverride(false); //正则匹配去掉Serivce前的 I gc.setServiceName("%sService"); gc.setIdType(IdType.ID_WORKER); gc.setDateType(DateType.ONLY_DATE); gc.setSwagger2(true); generator.setGlobalConfig(gc); //设置数据源 DataSourceConfig dsc = new DataSourceConfig(); dsc.setUrl("jdbc:mysql://localhost:3306/mybatis_plus?useSSL=true&serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf-8"); dsc.setDriverName("com.mysql.cj.jdbc.Driver"); dsc.setUsername("root"); dsc.setPassword("123456"); dsc.setDbType(DbType.MYSQL); generator.setDataSource(dsc); //包配置 PackageConfig pc = new PackageConfig(); pc.setModuleName("demo"); pc.setParent("com.sw"); pc.setEntity("pojo"); pc.setMapper("mapper"); pc.setService("service"); pc.setController("controller"); generator.setPackageInfo(pc); //策略配置 StrategyConfig sc = new StrategyConfig(); //映射的表名 sc.setInclude(""); sc.setNaming(NamingStrategy.underline_to_camel); sc.setColumnNaming(NamingStrategy.underline_to_camel); sc.setEntityLombokModel(true); //逻辑删除 sc.setLogicDeleteFieldName("delete"); //自动填充 TableFill createTime = new TableFill("create_Time", FieldFill.INSERT); TableFill updateTime = new TableFill("update_Time", FieldFill.INSERT_UPDATE); ArrayList<TableFill> list = new ArrayList<>(); list.add(createTime); list.add(updateTime); sc.setTableFillList(list); //乐观锁 sc.setVersionFieldName("version"); //请求链接驼峰转下划线：localhost:8088/test/user_id_age sc.setControllerMappingHyphenStyle(true); generator.setStrategy(sc); //执行自动生成 generator.execute(); } }

11.条件构造器 QueryWrapper 条件构造器条件查询：@Test void findTest(){ //查询姓名、邮箱不为空，且年龄大于25的用户信息 QueryWrapper<User> wrapper = new QueryWrapper<>(); wrapper.isNotNull("name") .isNotNull("email") .ge("age",25); mapper.selectList(wrapper).forEach(System.out::println); } @Test void findTest01(){ //查询一个名字为刘波的用户 QueryWrapper<User> wrapper = new QueryWrapper<>(); wrapper.ge("name","刘波"); User user = mapper.selectOne(wrapper); System.out.println(user); } @Test void findTest02(){ //查询年龄在20-30岁之间的用户 QueryWrapper<User> wrapper = new QueryWrapper<>(); wrapper.between("age", 20, 30); Integer result = mapper.selectCount(wrapper); System.out.println(result); }模糊查询：@Test void findTest03(){ //查询名字中不包含“刘”，且邮箱以"t"开头的用户 //likeRight str% //likeLeft %str QueryWrapper<User> wrapper = new QueryWrapper<>(); wrapper.notLike("name", "刘") .likeRight("email", "t"); List<Map<String, Object>> maps = mapper.selectMaps(wrapper); maps.forEach(System.out::println); }子查询:@Test void findTest04(){ //查询id大于5的用户 /* WHERE deleted=0 AND id IN ( select id from user where id > 5 ) */ QueryWrapper<User> wrapper = new QueryWrapper<>(); wrapper.inSql("id", "select id from user where id > 5"); List<Object> maps = mapper.selectObjs(wrapper); maps.forEach(System.out::println); }排序：@Test void findTest05(){ //通过id降序排列 QueryWrapper<User> wrapper = new QueryWrapper<>(); wrapper.orderByDesc("id"); List<User> users = mapper.selectList(wrapper); users.forEach(System.out::println); }

10.性能分析 性能分析注册Bean：//性能分析 @Bean @Profile({"dev", "test"}) public PerformanceInterceptor performanceInterceptor(){ PerformanceInterceptor interceptor = new PerformanceInterceptor(); //sql最大执行时间，超过则不执行，单位：ms interceptor.setMaxTime(100); //是否格式化 interceptor.setFormat(true); return interceptor; }

9.逻辑删除 逻辑删除物理删除：从数据库中直接移除逻辑删除：数据库中没有移除，而是通过一个变量来使该条数据失效1.数据库增加delete字段，默认值为02.实体类增加属性@TableLogic private int deleted;3.注册Bean//逻辑删除 @Bean public ISqlInjector sqlInjector(){ return new LogicSqlInjector(); }4.application.yml配置mybatis-plus: global-config: db-config: logic-delete-value: 1 logic-not-delete-value: 05.单元测试//逻辑删除测试 @Test void logicDeleteTest(){ userMapper.deleteById(1L); //sql：UPDATE user SET deleted=1 WHERE id=? AND deleted=0 User user = userMapper.selectById(1L); System.out.println(user); //输出结果为null //查询时会自动过滤delete=1的值 }

8.删除 删除根据id删除单条记录根据ids批量删除条件删除根据map删除

7.分页查询 分页查询1.在Config中配置分页插件//分页插件 @Bean public PaginationInterceptor paginationInterceptor(){ return new PaginationInterceptor(); }2.分页测试//分页测试 @Test void pageTest(){ //pageNum, pageSize Page<User> page = new Page<>(1,5); userMapper.selectPage(page,null); page.getRecords().forEach(System.out::println); //SELECT id,name,age,email,version,create_time,update_time FROM user LIMIT 0,5 }