首页 > 系统相关> 文章详细

linux 安装Mycat 并测试集成spring boot（详细）

2021-06-18 16:57:26 阅读：166 来源： 互联网

标签：spring boot mycat mysql id Mycat public

1、创建mycat用户

useradd -m mycat

#为mycat 设置密码

passwd mycat

2、创建mycat工作目录

mkdir -p /usr/local/mycat

3、下载mycat

http://dl.mycat.org.cn/1.6-RELEASE/

su mycat

cd /usr/local/mycat

wget http://dl.mycat.org.cn/1.6-RELEASE/Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz

#解压

tar -zxf Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz

#进入目录

cd mycat

4、准备两个mysql数据源

① window上有个 192.168.100.123:3306

②虚拟机上有个 localhost:3307

5、在两个mysql中新建数据库：test_mycat

create database test_mycat

6、在test_mycat中新建数据库表 tb_user

CREATE TABLE `tb_user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(32) NOT NULL,
`age` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4

7、配置 mycat/conf/schema.xml

root@ubuntu:/mysoft/mycat/mycat/conf# vim schema.xml 
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">

        <schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
                <!-- random sharding using mod sharind rule -->
                <table name="tb_user" primaryKey="id" autoIncrement="true" dataNode="dn1,dn2" rule="mod-long" />
        </schema>

        <dataNode name="dn1" dataHost="localhost1" database="test_mycat" />
        <dataNode name="dn2" dataHost="localhost2" database="test_mycat" />

        <dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"  writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>select user()</heartbeat>
                <!-- can have multi write hosts -->
                <writeHost host="hostM1" url="localhost:3307" user="your_user_name" password="your_password" >
                        <readHost host="hostS1" url="localhost:3307" user="your_user_name" password="your_password" />
                </writeHost>
        </dataHost>

        <dataHost name="localhost2" maxCon="1000" minCon="10" balance="0"  writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>select user()</heartbeat>
                <!-- can have multi write hosts -->
                <writeHost host="hostM2" url="192.168.100.81:3306" user="your_user_name" password="your_password" />
        </dataHost>

</mycat:schema>

8、由于schema中rule="mod-long"，所以要去设置一下 rule.xml，只需动一个地方，其他不变

9、配置server.xml

10、启动mycat

cd mycat/bin

./mycat console #以控制台的方式启动

注：mycat 支持的命令{ console | start | stop | restart | status | dump }

显示两个节点都链接成功

11、使用Navicat来测试

12、测试数据

13、测试成功。

14、集成spring boot

/*
* USER 实体类
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User implements Serializable {

    private static final long serialVersionUID = 1L;

    private Integer id;
    private String name;
    private Integer age;
    

}

@Mapper
public interface UserDao {

    public User getUser(int id);

    public List<User> userList();
}

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ming.springclould.dao.UserDao">

    <resultMap id="BaseResultMap" type="com.ming.springcloud.entities.User" >
        <result column="id" property="id" />
        <result column="name" property="name" />
        <result column="age" property="age" />
    </resultMap>

    <sql id="Base_Column_List">
                id,
                name,
                age
    </sql>

    <select id="getUser" resultMap="BaseResultMap">
        SELECT <include refid="Base_Column_List" />
        FROM tb_user
        WHERE id = #{id}
    </select>

    <select id="userList" resultMap="BaseResultMap">
        SELECT <include refid="Base_Column_List" />
        FROM tb_user
    </select>

</mapper>

@Service
public class UserService {

    @Resource
    private UserDao userDao;

    public User getUser(int id){
        return userDao.getUser(id);
    };

    public List<User> userList(){
        return userDao.userList();
    }
}

@RestController
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/user/get/{id}")
    public CommonResult getUser(@PathVariable int id){
        return new CommonResult(200,"",userService.getUser(id));
    }

    @GetMapping("/user/list")
    public CommonResult<List<User>> userList(){
        return new CommonResult(200,"",userService.userList());
    }
}

server:
  port: 2009

spring:
  application:
    name: MyCat-2009

  datasource:
    type: com.alibaba.druid.pool.DruidDataSource  #当前数据源操作类型
    #driver-class-name: com.mysql.cj.jdbc.Driver  #mysql-connector-java 6以上
    driver-class-name: com.mysql.jdbc.Driver      #mysql-connector-java 6以下
    url: jdbc:mysql://192.168.100.123:8066/TESTDB?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true
    username: root
    password: 123456

mybatis:
  mapper-locations: classpath:mapper/*.xml
  type-aliases-package: com.ming.springcloud.entities  #所有entity别名所在包

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>

15、启动测试

标签：spring,boot,mycat,mysql,id,Mycat,public
来源： https://blog.csdn.net/HMM316/article/details/118028233

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

linux 安装Mycat 并测试 集成spring boot（详细）

linux 安装Mycat 并测试集成spring boot（详细）