从零到壹搭建一个商城架构--MySQL集群

Posted 2023-04-08 温润如风

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了从零到壹搭建一个商城架构--MySQL集群相关的知识，希望对你有一定的参考价值。

1）、集群原理

以上可以作为企业中常用的数据库解决方案

mysql-MMM是Master-Master Replication Manager for MySQL(mysql主主复制管理器)的简称，是Google的开源项目（Perl脚本）。MMM基于MySQL Replication 做的扩展架构，主要用来监控mysql主主复制并做失败转移，其原理是将真实数据库节点的IP(RIP)映射为虚拟IP(VIP)集。mysql-mm的监管端会提供多个虚拟IP(VIP)，包括一个可写VIP，多个可读VIP，通过监管的管理，这些IP会绑定在可用的mysql之上，当某一台mysql宕机时，监管会将VIP迁移至其他mysql。在整个监管过程中，需要在mysql中添加相关授权用户，以便让mysql可以支持监管机的维护。授权的用户包括一个mmm_monitor用户和一个mmm_agent用户，如果想使用mmm的备份工具则添加一个mmm_tools用户。

MHA(Master High Availability)目前在MySQL高可用方面是一个相对成熟的解决方案，由日本DeNA公司youshimaton(现就职于Facebook公司)开发，是一套优秀的作为MySQL高可用性环境下故障切换和主从提升的高可用软件。在MySQL故障切换过程中，MHA能做到在0~30秒之内自动完成数据库的故障切换操作（以2019的眼光来说太慢了），并且在进行故障切换的过程中，MHA能在最大程度上保证数据的一致性，以达到真正意义上的高可用。
InnDB Cluster支持自动Failover、强一致性、读写分离、读库高可用、读请求负载均衡横向扩展的特性，是比较完备的一套方案。但是不熟起来复杂，想要解决router单点问题，需要新增组件，如果没有其他更好的方案可考虑该方案。InnDB Cliuster主要由MySQL Shell、MySQL Router和MySQL服务器集群组成，三者协同工作，共同为MySQL提供完成的高可用性解决方案。MySQL Shell对管理人员提供管理接口，可以很方便的对集群进行配置和管理MySQL Router，可以根据部署的集群状况自动的初始化，是客户端连接实例。如果有节点宕机，集群会自动更新配置，集群包含单点写入和多点写入两种模式。在单主模式下，如果主节点宕机，从节点自动替换上来，MySQL Router自动探测，并将客户端连接到新节点。

2）、Docker安装模拟MySQL主从复制集群

下载mysql镜像

创建Master实例并启动

docker run -p 3307:3306 --name mysql-master \\
-v /mydata/mysql/master/log:/var/log/mysql \\
-v /mydata/mysql/master/data:/var/lib/mysql \\
-v /mydata/mysql/master/conf:/etc/mysql \\
-e MYSQL_ROOT_PASSWORD=root \\
-d mysql:5.7

参数说明：

-p 3307:3306 将容器的3306端口映射到主机的3307端口

-v /mydata/mysql/master/conf:/etc/mysql 将配置文件夹挂载到主机

-v /mydata/mysql/master/log:/var/log/mysql 将日志文件挂载到主机

-v /mydata/mysql/master/data:/var/lib/mysql 将数据文件挂载到主机

-e MYSQL_ROOT_PASSWORD=root 初始化root密码

进入到挂载的master目录，修改配置文件
```
vi /mydata/mysql/master/conf/my.cnf
```
如以下内容：

  [client]

  default-character-set=utf8

  

  [mysql]

  default-character-set=utf8

  

  [mysqld]

  init_connect=‘SET collaction_connection=utf8_unicode_ci’

  init_connect=‘SET NAMES utf8’

  character-set-server=utf8

  collation-server=utf8_unicode_ci

  skip-character-set-client-handshake

  skip-name-resolve

  #skip-name-resolve一定要加，不然连接mysql会特别慢

  #添加master主从复制部分配置

  server_id=1

  log-bin=mysql-bin

  read-only=0

  binlog-do-db=hslmall_ums

  binlog-do-db=hslmall_pms

  binlog-do-db=hslmall_oms

  binlog-do-db=hslmall_sms

  binlog-do-db=hslmall_wms

  binlog-do-db=hslmall_admin

  replicate-ignore-db=mysql

  replicate-ignore-db=sys

  replicate-ignore-db=information_schema

  replicate-ignore-db=performance_schema

重启master

创建Slave实例并启动

docker run -p 3317:3306 --name mysql-slave-01 \\
-v /mydata/mysal/slave/log:/var/log/mysql \\
-v /mydata/mysql/slave/data:/var/lib/mysql \\
-v /mydata/mysql/slave/conf:/etc/mysql \\
-e MYSQL_ROOT_PASSWORD=root \\
-d mysql:5.7

进入挂载的slave配置文件，加入以下内容

如以下内容：

 [client]

 default-character-set=utf8

 

 [mysql]

 default-character-set=utf8

 

 [mysqld]

 init_connect=‘SET collaction_connection=utf8_unicode_ci’

 init_connect=‘SET NAMES utf8’

 character-set-server=utf8

 collation-server=utf8_unicode_ci

 skip-character-set-client-handshake

 skip-name-resolve

 #skip-name-resolve一定要加，不然连接mysql会特别慢

 #添加master主从复制部分配置

 server_id=2

 log-bin=mysql-bin

 read-only=1

 binlog-do-db=hslmall_ums

 binlog-do-db=hslmall_pms

 binlog-do-db=hslmall_oms

 binlog-do-db=hslmall_sms

 binlog-do-db=hslmall_wms

 binlog-do-db=hslmall_admin

 replicate-ignore-db=mysql

 replicate-ignore-db=sys

 replicate-ignore-db=information_schema

 replicate-ignore-db=performance_schema

为master授权用户来他的同步数据

进入
```
docker exec -it mysql-master /bin/bash
```

进入mysql内部（mysql -uroot -p）

mysql -uroot -p
#授权root可以远程访问（主从无关，为了方便我们远程连接mysql）
grant all privileges on *.* to 'root'@'%' identified by 'root' with grant option;
flush privileges;
#添加用来同步的用户
GRANT REPLICATION SLAVE ON *.* to 'backup'@'%' identified by '123456';

查看master状态
```
show master status\\G
```

配置slave同步master数据

#进入slave容器
docker exec -it mysql-slave-01 /bin/bash
#进入mysql内部（mysql -uroot -p）
mysql -uroot -p
#授权root可以远程访问
grant all privileges on *.* to 'root'@'%' identified by 'root' with grant option;
flush privileges;
#设置主库连接
change master to master_host='192.168.56.10',master_user='backup',master_password='123456',master_log_file='mysql-bin.000001',master_log_pos=0,master_port=3307
#启动从库同步
start slave
#查看从库状态
show slave status\\G

示意图

Sharding-Proxy

根据官网说明进行文件配置

《Flowable流程引擎从零到壹》引入日志框架和部署流程定义

14天学习训练营导师课程：
邓澎波《Flowable流程引擎-基础篇【2022版】》
邓澎波《Flowable流程引擎-高级篇【2022版】》

学习笔记《Flowable流程引擎从零到壹》回城传送

❤️作者主页：小虚竹

❤️作者简介：大家好,我是小虚竹。Java领域优质创作者🏆，CSDN博客专家🏆，华为云享专家🏆，掘金年度人气作者🏆，阿里云专家博主🏆，51CTO专家博主🏆

❤️技术活，该赏

❤️点赞 👍 收藏 ⭐再看，养成习惯

PC端左侧加我微信，进社群，有送书等更多活动！

零：前言

今天学习的内容是引入日志框架和部署流程定义，和虚竹哥一起学习吧。

一、引入日志框架

上一篇文章初始化ProcessEngine流程引擎实例后，控制台没什么日志内容输出，只有提示日志没有正确配置。

从提示内容可知Flowable使用SLF4J作为内部日志框架。
本文使用log4j作为SLF4J的实现。因此在pom.xml文件中添加下列依赖：

<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-api</artifactId>
    <version>1.7.21</version>
</dependency>
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
    <version>1.7.21</version>
</dependency>

增加配置文件：log4j.properties文件

log4j.rootLogger=DEBUG, CA

log4j.appender.CA=org.apache.log4j.ConsoleAppender
log4j.appender.CA.layout=org.apache.log4j.PatternLayout
log4j.appender.CA.layout.ConversionPattern= %dhh:mm:ss,SSS [%t] %-5p %c %x - %m%n

重新运行应用，控制台就有日志出现了。

二、部署流程定义

构建一个简单的请假流程，Flowable引擎需要流程定义为BPMN 2.0格式 ，这是一个业界广泛接受的XML标准。
定义一个请假流程的流程步骤图，我们称为一个流程定义(process definition)。一个流程定义可以启动多个流程实例(process instance)。

以请假流程为例，流程定义定义了请假的各个步骤要做的事情；
一个流程实例是每个员工可以发起一个请假申请，直到这个请假申请的流程走完，这个流程实例才结束。

BPMN 2.0存储为XML，并包含可视化的部分：使用标准方式定义了每个步骤类型（人工任务，自动服务调用，等等）如何呈现，以及如何互相连接。这样BPMN 2.0标准使技术人员与业务人员能用双方都能理解的方式交流业务流程。

本次请假流程的流程定义为：

说明：

左侧的圆圈叫做启动事件(start event)。这是一个流程实例的起点。
第一个矩形是一个用户任务(user task)。这是流程中用户操作的步骤。在这个例子中，经理需要批准或驳回申请
取决于经理的决定，排他网关(exclusive gateway) (带叉的菱形)会将流程实例路由至批准或驳回路径
如果批准，则需要将申请注册至某个外部系统，并跟着另一个用户任务，将经理的决定通知给申请人。当然也可以改为发送邮件。
如果驳回，则为雇员发送一封邮件通知他。

实际的业务场景，流程定义步骤图是用可视化建模工具的，如Flowable Designer(Eclipse)或Flowable Web Modeler(Web应用)。
本文直接写XML，新手刚入门要熟悉下BPMN2.0及其概念。
将下面的XML保存在src/main/resources文件夹下名为holiday-request.bpmn20.xml的文件中。

注意：*.bpmn20.xml 这个后缀是固定的

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xmlns:xsd="http://www.w3.org/2001/XMLSchema"
             xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
             xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"
             xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI"
             xmlns:flowable="http://flowable.org/bpmn"
             typeLanguage="http://www.w3.org/2001/XMLSchema"
             expressionLanguage="http://www.w3.org/1999/XPath"
             targetNamespace="http://www.flowable.org/processdef">

    <process id="holidayRequest" name="请假流程" isExecutable="true">

        <startEvent id="startEvent"/>
        <sequenceFlow sourceRef="startEvent" targetRef="approveTask"/>

        <userTask id="approveTask" name="同意或拒绝请假"/>
        <sequenceFlow sourceRef="approveTask" targetRef="decision"/>

        <exclusiveGateway id="decision"/>
        <sequenceFlow sourceRef="decision" targetRef="externalSystemCall">
            <conditionExpression xsi:type="tFormalExpression">
                <![CDATA[
          $approved
        ]]>
            </conditionExpression>
        </sequenceFlow>
        <sequenceFlow  sourceRef="decision" targetRef="sendRejectionMail">
            <conditionExpression xsi:type="tFormalExpression">
                <![CDATA[
          $!approved
        ]]>
            </conditionExpression>
        </sequenceFlow>

        <serviceTask id="externalSystemCall" name="Enter holidays in external system"
                     flowable:class="org.flowable.CallExternalSystemDelegate"/>
        <sequenceFlow sourceRef="externalSystemCall" targetRef="holidayApprovedTask"/>

        <userTask id="holidayApprovedTask" name="Holiday approved"/>
        <sequenceFlow sourceRef="holidayApprovedTask" targetRef="approveEnd"/>

        <serviceTask id="sendRejectionMail" name="Send out rejection email"
                     flowable:class="org.flowable.SendRejectionMail"/>
        <sequenceFlow sourceRef="sendRejectionMail" targetRef="rejectEnd"/>

        <endEvent id="approveEnd"/>

        <endEvent id="rejectEnd"/>
    </process>

</definitions>

现在我们已经有了流程BPMN 2.0 XML文件，现在需要将它部署到引擎中。

下面简单介绍下bpmn20.xml的几个重要的点

2.1、bpmn20.xml介绍

2.1.1、流对象（Flow Objects）：包括事件、活动、网关，是BPMN中的核心元素。

2.1.1.1、事件

作用：用于对流程生命周期中发生的事件进行建模。

分类

开始事件：开始事件指示流程从何处开始。

定义：
没有启动事件，需要调用startProcessInstanceByXXX方法执行该空开始事件。

图形表示：

XML表示：

<startEvent id="startEvent"/>

中间事件：

正常是任务和网关的混合体

结束事件：标志着流程的结束。

定义：
没有结束事件，当流程引擎检测到执行到该空结束事件时会自动执行，已结束整个流程。
图形表示：

xml表示：

<endEvent id="approveEnd"/>

2.1.1.2、任务（活动）

定义：
任务表示流程中具体要做的事情，通常一个任务表示工作需要被外部实体完成，比如人工任务和自动服务。
图形表示：
任务通常有圆角矩形表示，内部文字为任务名称或描述，左上角的图标表示任务类型。

分类

人工任务(user task)

定义：
最典型的任务。需要由人工来完成的任务，比如请假审批、财务审核等。
图形表示：

xml表示：
id是必须的，name是可选的，通过documentation元素对任务进行描述。任何bpmn2.0元素都可用documentation元素进行描述。

<userTask id="theTask" name="Schedule meeting" > <documentation> Schedule an engineering meeting for next week with the new hire. </documentation> </userTask>

到期日：
可通过dueDate字段设置任务的到期时间。

用户分配：
人工任务可分配给三种人：assignee（办理人、受让人），candidate(候选人)，candidateGroup(候选人组)

assignee是任务的实际办理人，任务只能同时有一个办理人。
任务可以有多个候选人，每个候选人都能看到该任务，候选人需要claim(拾取)任务成为assignee后，才能进行任务的办理，任务被拾取后其他候选人就看不到该任务了。候选人在拾取任务后可以unclaim，将任务归还，此时其他候选人可以看到并claim任务。
不想单独指定多个候选人，可以指定一个候选人组，一般为角色ID。

分配方式有三种：

画图时写死。
通过UEL表达式动态设置。
通过TaskListener监听器指定。

java服务任务(service task)

定义：
用于调用外部Java代码。

图形表示：

xml表示：

<serviceTask id="javaService" name="My Java Service Task" activiti:class="org.activiti.MyJavaDelegate" />

脚本任务(script task)

定义：

用于执行脚本文件(如javascript)

图形表示：

xml表示：

<scriptTask id="theScriptTask" name="Execute script" scriptFormat="groovy"> 
    <script> 
        sum = 0 
        for ( i in inputArray )  
            sum += i 
         
    </script> 
</scriptTask>

web服务任务

用于调用外部web接口服务。

邮件任务(非BPMN2.0规范)

用于发送邮件。

还有手工任务、java接收任务、shell任务等。

2.1.1.3、网关（节点）

作用：
用来控制流程的流向。

图形表示：
网关通常以菱形图形表示，内部带有一个图标。该图标显示网关的类型。

分类：

排他网关(exclusiveGateway)

定义：
也叫XOR网关，对所有的传出分支进行条件判断，仅选择一个条件为true的分支执行，当有多个分支条件满足时，默认执行xml中定义的第一个。若多个分支条件都不满足时，就走默认顺序流。如果没有默认顺序流，将抛出异常。

图形表示：

xml表示：

<exclusiveGateway id="exclusiveGw" name="Exclusive Gateway" />

并行网关(parallelGateway)

定义：

并行网关模拟多个同时并行执行的流程这种情况。两个特点：

具有fork-join行为(发散和汇聚,想起了java中的fork-join线程框架)，即从并行网关传出的流程会并行执行，传入并行网关的流程会进入里面等待，知道并行的流程都进入到并行网关后，再一起发散出去。
并行网关忽略分支的条件判断。
图形表示：

xml表示：

<parallelGateway id="myParallelGateway" />

包含网关(inclusiveGateway)

定义：
看作是排他网关和并行网关的组合，包含网关既能进行条件判断，又能并行执行多个分支。

图形：

xml表示：

<inclusiveGateway id="myInclusiveGateway" />

还是事件网关等。

2.1.2、顺序流

定义：
顺序流就是事件，活动和网关之间的连线，显示为一条实线带有箭头，在BPMN图形中每个顺序流都有一个源头和一个目标引用，包含了活动，事件或网关的id。

<sequenceFlow id="myFlow" name="MyFlow" sourceRef="sourceId" targetRef="targetId" />

分类：

条件顺序流

定义：
给顺序流添加表达式条件，当条件判断为true时，该顺序流将会被执行。这意味着如果多个顺序流的条件都为true时，会有多个顺序流并行执行。

图形表示：

XML表示：
条件序列流在XML中表现为常规序列流，其中包含conditionExpression子元素。当前conditionalExpression仅可与UEL一起使用。

<sequenceFlow id="flow" sourceRef="theStart" targetRef="theTask"> 
    <conditionExpression xsi:type="tFormalExpression"> 
        <![CDATA[$order.price > 100 && order.price < 250]]> 
    </conditionExpression>
</sequenceFlow>

默认顺序流

定义：
所有BPMN 2.0任务和网关都可以具有默认序列流。当且仅当其他条件顺序流都为false时，才选择执行默认顺序流。默认序列流的条件总是被忽略。

图形表示：
默认序列流是开始处带有斜杠标记的常规顺序流。

xml表示：
通过default属性执行默认顺序流。flow2为排他网关的默认顺序流。

<exclusiveGateway id="exclusiveGw" name="Exclusive Gateway" default="flow2" />         
      <sequenceFlow id="flow1" sourceRef="exclusiveGw" targetRef="task1">     
          <conditionExpression xsi:type="tFormalExpression">
            $conditionA    
          </conditionExpression> 
       </sequenceFlow> 
      <sequenceFlow id="flow2" sourceRef="exclusiveGw" targetRef="task2"/> 
      <sequenceFlow id="flow3" sourceRef="exclusiveGw" targetRef="task3"> 
         <conditionExpression xsi:type="tFormalExpression">
            $conditionB
         </conditionExpression> 
      </sequenceFlow>
</exclusiveGateway>

2.2、部署流程定义

先了解下ProcessEngine下提供了哪些主要的服务：

RepositoryService:资源管理的一些服务
RuntimeService：流程运行时的服务
TaskService:任务处理的服务
HistoryService：历史信息，历史流转的服务

实现部署：

获取流程引擎对象
将流程定义部署至Flowable引擎
需要使用RepositoryService，其可以从ProcessEngine对象获取
使用RepositoryService，可以通过XML文件的路径创建一个新的部署(Deployment)
并调用*deploy()*方法实际执行
输出deployment对象的id和名称。

package com.xiaoxuzhu.flowable.test;

import org.flowable.engine.ProcessEngine;
import org.flowable.engine.ProcessEngineConfiguration;
import org.flowable.engine.RepositoryService;
import org.flowable.engine.impl.cfg.StandaloneProcessEngineConfiguration;
import org.flowable.engine.repository.Deployment;
import org.junit.Test;

public class Test03 

    /**
     * 部署流程
     */
    @Test
    public void testDeploy() 
        ProcessEngineConfiguration configuration = new StandaloneProcessEngineConfiguration();
        //数据库配置
        configuration.setJdbcDriver("com.mysql.cj.jdbc.Driver");
        configuration.setJdbcUsername("root");
        configuration.setJdbcPassword("123456");
        configuration.setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn?serverTimezone=UTC&nullCatalogMeansCurrent=true");
        //自动创建表结构-表不存在时
        configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
        ProcessEngine processEngine = configuration.buildProcessEngine();
        // 部署流程 获取RepositoryService对象
        RepositoryService repositoryService = processEngine.getRepositoryService();
        Deployment deployment = repositoryService.createDeployment()// 创建Deployment对象
                .addClasspathResource("holiday-request.bpmn20.xml") // 添加流程部署文件
                .name("流程名称：请假流程") // 设置部署流程的名称
                .deploy(); // 执行部署操作
        System.out.println("deployment.getId() = " + deployment.getId());
        System.out.println("deployment.getName() = " + deployment.getName());

执行日志成功的截图：

成功后会在表结构插入数据：
act_re_deployment: 流程定义部署表，每部署一次就增加一条记录

act_re_procdef ：流程定义表，部署每个新的流程定义都会在这张表中增加一条记录

act_ge_bytearray ：流程资源表，流程部署的 bpmn xml文件会保存在该表中

2.3、查询流程定义

    @Test
    public void testDeployQuery() 
        // 配置数据库相关信息 获取 ProcessEngineConfiguration
        ProcessEngineConfiguration configuration = new StandaloneProcessEngineConfiguration();
        //数据库配置
        configuration.setJdbcDriver("com.mysql.cj.jdbc.Driver");
        configuration.setJdbcUsername("root");
        configuration.setJdbcPassword("123456");
        configuration.setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn?serverTimezone=UTC&nullCatalogMeansCurrent=true");
        //自动创建表结构-表不存在时
        configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
        // 获取流程引擎对象
        ProcessEngine processEngine = configuration.buildProcessEngine();
        // 部署流程 获取RepositoryService对象
        RepositoryService repositoryService = processEngine.getRepositoryService();
        // 获取流程定义对象
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
                .deploymentId("1")
                .singleResult();
        System.out.println("processDefinition.getId() = " + processDefinition.getId());
        System.out.println("processDefinition.getName() = " + processDefinition.getName());
        System.out.println("processDefinition.getDeploymentId() = " 以上是关于从零到壹搭建一个商城架构--MySQL集群的主要内容，如果未能解决你的问题，请参考以下文章 
 从零到壹学习Hyperledger Fabric第七讲：Peer配置剖析
 从零到壹学习密码学第二讲：hash 算法
 09《JAVA从零到壹》第九讲：异常处理（文末有课后作业）
 08《JAVA从零到壹》第八讲：系统常用类（文末有课后作业）
 10《JAVA从零到壹》第十讲：集合框架（文末有课后作业）
 《Flowable流程引擎从零到壹》引入日志框架和部署流程定义

从零到壹搭建一个商城架构--MySQL集群

1）、集群原理

2）、Docker安装模拟MySQL主从复制集群

Sharding-Proxy

《Flowable流程引擎从零到壹》引入日志框架和部署流程定义

文章目录

零：前言

一、引入日志框架

二、部署流程定义

2.1、bpmn20.xml介绍

2.1.1、流对象（Flow Objects）：包括事件、活动、网关，是BPMN中的核心元素。

2.1.1.1、事件

分类

开始事件：开始事件指示流程从何处开始。

中间事件：

结束事件：标志着流程的结束。

2.1.1.2、任务（活动）

分类

人工任务(user task)

java服务任务(service task)

脚本任务(script task)

web服务任务

邮件任务(非BPMN2.0规范)

2.1.1.3、网关（节点）

分类：

排他网关(exclusiveGateway)

并行网关(parallelGateway)

包含网关(inclusiveGateway)

2.1.2、顺序流

分类：

条件顺序流

默认顺序流

2.2、部署流程定义

2.3、查询流程定义