Netty, SpringBoot, MyBatis搭建游戏服务器 - 1

太过爱你忘了你带给我的痛 2021-11-27 02:30 813阅读 0赞

Netty, SpringBoot, MyBatis搭建游戏服务器 - 1  
各框架简介  
Netty是步的、事件驱动的网络应用程序框架和工具，,很适合做游戏服务器。

使用SpringBoot可以抛弃传统Spirng框架的繁琐配置和依赖版本管理，更方便地打包与部署。这里我们主要是使用SpringBoot的依赖注入功能。

MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。因为我们的数据库可能因为业务需求不断地变化，所以我们可以用MyBaits的逆向工程实时根据数据库的表生成实体类、Mapper接口，Mapper XML。或者利用注解注解写SQL语句查询。

目的  
我们要使用Netty构建一个游戏服务端，她可以接受客户端的信息，并根据业务逻辑做出响应。

Spring负责依赖注入，管理对象（游戏业务对象另外由缓存模块管理），使得项目代码直之间解耦合。

MyBatis负责依据业务需求持久化各类数据。

依赖配置  
项目使用Maven来管理依赖，依赖结构初步想法是

mmorpg  
gameserver  
mysql  
缓存模块  
游戏配置管理模块  
…  
gameclient  
下面是当前版本项目的pom文件

总项目定义文件

<groupId>com.wan37</groupId>  
    <artifactId>mmorpg</artifactId>  
    <version>0.0.1-SNAPSHOT</version>  
    <packaging>pom</packaging>

<name>mmorpg</name>  
    <description>Demo project for Spring Boot</description>

<modules>  
        <module>gameserver</module>  
        <module>mysql</module>  
    </modules>

<parent>  
        <groupId>org.springframework.boot</groupId>  
        <artifactId>spring-boot-starter-parent</artifactId>  
        <version>2.0.5.RELEASE</version>  
        <relativePath/>   
    </parent>

<dependencies>

<dependency>  
            <groupId>org.projectlombok</groupId>  
            <artifactId>lombok</artifactId>  
            <optional>true</optional>  
        </dependency>

<dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-configuration-processor</artifactId>  
            <optional>true</optional>  
        </dependency>

<dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-test</artifactId>  
            <scope>test</scope>  
        </dependency>  
    </dependencies>

<build>  
        <plugins>  
            <plugin>  
                <groupId>org.springframework.boot</groupId>  
                <artifactId>spring-boot-maven-plugin</artifactId>  
            </plugin>  
        </plugins>  
    </build>

<repositories>  
        <repository>  
            <id>spring-snapshots</id>  
            <name>Spring Snapshots</name>  
            <url>https://repo.spring.io/snapshot</url>  
            <snapshots>  
                <enabled>true</enabled>  
            </snapshots>  
        </repository>  
        <repository>  
            <id>spring-milestones</id>  
            <name>Spring Milestones</name>  
            <url>https://repo.spring.io/milestone</url>  
            <snapshots>  
                <enabled>false</enabled>  
            </snapshots>  
        </repository>  
    </repositories>

<pluginRepositories>  
        <pluginRepository>  
            <id>spring-snapshots</id>  
            <name>Spring Snapshots</name>  
            <url>https://repo.spring.io/snapshot</url>  
            <snapshots>  
                <enabled>true</enabled>  
            </snapshots>  
        </pluginRepository>  
        <pluginRepository>  
            <id>spring-milestones</id>  
            <name>Spring Milestones</name>  
            <url>https://repo.spring.io/milestone</url>  
            <snapshots>  
                <enabled>false</enabled>  
            </snapshots>  
        </pluginRepository>  
    </pluginRepositories>  
</project>

<?xml version="1.0" encoding="UTF-8"?>  
<project xmlns="http://maven.apache.org/POM/4.0.0"  
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  
    <parent>  
        <artifactId>mmorpg</artifactId>  
        <groupId>com.wan37</groupId>  
        <version>0.0.1-SNAPSHOT</version>  
    </parent>  
    <modelVersion>4.0.0</modelVersion>

<artifactId>mysql</artifactId>  
    <packaging>jar</packaging>

<dependency>  
            <groupId>org.mybatis.spring.boot</groupId>  
            <artifactId>mybatis-spring-boot-starter</artifactId>  
            <version>1.3.2</version>  
        </dependency>

<dependency>  
            <groupId>mysql</groupId>  
            <artifactId>mysql-connector-java</artifactId>  
            <scope>runtime</scope>  
        </dependency>

<dependency>  
            <groupId>com.alibaba</groupId>  
            <artifactId>druid</artifactId>  
            <version>1.0.26</version>  
        </dependency>

<dependency>  
            <groupId>com.github.pagehelper</groupId>  
            <artifactId>pagehelper</artifactId>  
            <version>4.1.6</version>  
        </dependency>

<dependency>  
            <groupId>com.alibaba</groupId>  
            <artifactId>fastjson</artifactId>  
            <version>1.1.43</version>  
        </dependency>

</dependencies>

<build>  
        <plugins>  
            <plugin>  
                <groupId>org.springframework.boot</groupId>  
                <artifactId>spring-boot-maven-plugin</artifactId>  
            </plugin>

<plugin>  
                <groupId>org.mybatis.generator</groupId>  
                <artifactId>mybatis-generator-maven-plugin</artifactId>  
                <version>1.3.2</version>  
                <configuration>  
                    <configurationFile>src\\main\\resources\\mybatis\\generatorConfig.xml</configurationFile>  
                      
                    <verbose>true</verbose>  
                      
                    <overwrite>true</overwrite>  
                </configuration>  
                <executions>  
                    <execution>  
                        <id>GenerateMyBatis Artifacts</id>  
                        <goals>  
                            <goal>generate</goal>  
                        </goals>  
                    </execution>  
                </executions>  
                <dependencies>  
                    <dependency>  
                        <groupId>org.mybatis.generator</groupId>  
                        <artifactId>mybatis-generator-core</artifactId>  
                        <version>1.3.2</version>  
                    </dependency>  
                </dependencies>  
            </plugin>

</plugins>  
    </build>

</project>  
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
37  
38  
39  
40  
41  
42  
43  
44  
45  
46  
47  
48  
49  
50  
51  
52  
53  
54  
55  
56  
57  
58  
59  
60  
61  
62  
63  
64  
65  
66  
67  
68  
69  
70  
71  
72  
73  
74  
75  
76  
77  
78  
79  
80  
81  
82  
83  
84  
85  
86  
87  
88  
89  
90  
91  
92  
93  
94  
95  
96  
97  
98  
99  
100  
101  
服务端模块

<parent>  
        <artifactId>mmorpg</artifactId>  
        <groupId>com.wan37</groupId>  
        <version>0.0.1-SNAPSHOT</version>  
    </parent>

<artifactId>gameserver</artifactId>  
    <version>0.0.1-SNAPSHOT</version>  
    <packaging>jar</packaging>

<name>gameserver</name>  
    <description>A game server project for Spring Boot</description>

<dependencies>  
          
        <dependency>  
            <groupId>io.netty</groupId>  
            <artifactId>netty-all</artifactId>  
            <version>4.1.29.Final</version>  
        </dependency>

<dependency>  
            <groupId>com.wan37</groupId>  
            <artifactId>mysql</artifactId>  
            <version>0.0.1-SNAPSHOT</version>  
        </dependency>

</dependencies>

</project>

1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
37  
38  
39  
40  
41  
42  
43  
44  
45  
46  
47  
48  
49  
50  
51  
52  
53  
54  
55  
56  
Spring和myBatis的配置文件  
gameserver模块中的application.yml

spring:  
  datasource:  
    url: jdbc:mysql://localhost:3306/game?useUnicode=true&characterEncoding=utf-8&useSSL=true  
    username: root  
    password: 123456  
    driver-class-name: com.mysql.jdbc.Driver  
    type: com.alibaba.druid.pool.DruidDataSource

mybatis:  
  mapper-locations: classpath\*:mapper/\*.xml  
  check-config-location: true  
  type-aliases-package: com.wan37.mysql.pojo.entity  
    
debug: true  
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
MyBitis配置类（分页助手不知是否能用到）

package com.wan37.gameServer.config;

import com.github.pagehelper.PageHelper;  
import org.mybatis.spring.annotation.MapperScan;  
import org.springframework.context.annotation.Bean;  
import org.springframework.context.annotation.Configuration;

import java.util.Properties;

/\*\*  
 \* @author 钱伟健 gonefutre  
 \* @date 2017/9/12 22:27.  
 \* @E-mail gonefuture@qq.com  
 \*/

/\*  
 \* 注册MyBatis分页插件PageHelper  
 \*/

@Configuration  
@MapperScan(basePackages = \{"com.wan37"\})  
public class MybatisConfig \{

@Bean  
    public PageHelper pageHelper() \{  
        System.out.println("MyBatisConfiguration.pageHelper()");  
        PageHelper pageHelper = new PageHelper();  
        Properties p = new Properties();  
        p.setProperty("offsetAsPageNum", "true");  
        p.setProperty("rowBoundsWithCount", "true");  
        p.setProperty("reasonable", "true");  
        pageHelper.setProperties(p);  
        return pageHelper;  
    \}  
\}  
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
MyBatis逆向工程文件

<?xml version="1.0" encoding="UTF-8" ?>  
<!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"  
        "http://mybatis.org/dtd/mybatis-generator-config\_1\_0.dtd" >  
<generatorConfiguration >  
      
      
      
    <classPathEntry location="C:\\project\\mmorpg\\mysql\\mysql-connector-java-5.1.47.jar"/>  
      
    <context id="msql" targetRuntime="MyBatis3" >

<plugin type="org.mybatis.generator.plugins.SerializablePlugin" />  
          
          
          
        <plugin type="org.mybatis.generator.plugins.ToStringPlugin" />

<commentGenerator>  
            <property name="suppressAllComments" value="true"/>  
            <property name="supperssDate" value="false"/>  
        </commentGenerator>  
          
        <jdbcConnection driverClass="com.mysql.jdbc.Driver"  
                        connectionURL="jdbc:mysql://localhost:3306/game"  
                        userId="root"  
                        password="123456" />  
          
        <javaTypeResolver>  
              
            <property name="forceBigDecimals" value="false"/>  
        </javaTypeResolver>  
          
        <javaModelGenerator targetPackage="com.wan37.mysql.pojo.entity" targetProject="src/main/java">  
              
            <property name="enableSubPackages" value="true"/>  
              
            <property name="trimStrings" value="true"/>  
        </javaModelGenerator>

<sqlMapGenerator targetPackage="mapper" targetProject="src/main/resources">  
              
            <property name="enableSubPackages" value="true"/>  
        </sqlMapGenerator>  
          
        <javaClientGenerator targetPackage="com.wan37.mysql.pojo.mapper" targetProject="src/main/java"  
                             type="XMLMAPPER" >  
              
            <property name="enableSubPackages" value="true"/>  
        </javaClientGenerator>  
          
          
          
          
        <table tableName="game\_role"/>  
        <table tableName="player"/>  
        <table tableName="player\_roles"/>

</context>  
</generatorConfiguration>  
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
37  
38  
39  
40  
41  
42  
43  
44  
45  
46  
47  
48  
49  
50  
51  
52  
53  
54  
55  
56  
57  
58  
59  
60  
61  
62  
63  
64  
65  
66  
67  
68  
69  
70  
71  
72  
73  
74  
75  
76  
77  
78  
79  
整合Netty  
我使用的办法是把Netty服务的Handler，启动类都都变成由Spring管理的类。通过在类定义上加@Component注解，SpringBoot启动时会自动扫描注解并将Bean注入到容器中。使用 @PostConstruct修饰启动方法来启动Netty服务。

import com.wan37.gameServer.server.handler.ServerHandler;  
import io.netty.bootstrap.ServerBootstrap;  
import io.netty.channel.\*;  
import io.netty.channel.nio.NioEventLoopGroup;  
import io.netty.channel.socket.SocketChannel;  
import io.netty.channel.socket.nio.NioServerSocketChannel;  
import lombok.extern.slf4j.Slf4j;  
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;  
import javax.annotation.Resource;

/\*\*  
 \* @author gonefuture  gonefuture@qq.com  
 \* time 2018/9/10 11:36  
 \* @version 1.00  
 \* Description: 游戏服务端  
 \*/  
@Slf4j  
@Component  
@ChannelHandler.Sharable  
public class GameServer \{

@Resource  
    private ServerHandler serverHandler;

//绑定端口  
    private void bind(int port) throws Exception \{  
        // 逻辑线程组  
        EventLoopGroup bossGroup = new NioEventLoopGroup();  
        // 工作线程  
        EventLoopGroup workGroup = new NioEventLoopGroup();

ServerBootstrap bootstrap = new ServerBootstrap(); // 启动器  
        bootstrap.group(bossGroup, workGroup)  
                .channel(NioServerSocketChannel.class)  
                .option(ChannelOption.SO\_BACKLOG, 1024) // 最大客户端连接数为1024  
                //是否启用心跳保活机制  
                .childOption(ChannelOption.SO\_KEEPALIVE, true)  
        .childHandler(new ChannelInitializer<SocketChannel>() \{

@Override  
            protected void initChannel(SocketChannel ch) throws Exception \{  
                // 这里添加业务处理handler  
                ch.pipeline().addLast( serverHandler);  
            \}  
        \});

try \{  
            ChannelFuture future = bootstrap.bind(port).sync();  
            if (future.isSuccess()) \{  
                System.out.println("Server starts success at port:"+port);  
            \}  
            future.channel().closeFuture().sync();  
        \} catch (Exception e) \{  
            throw new RuntimeException(e);  
        \} finally \{  
            bossGroup.shutdownGracefully();  
            workGroup.shutdownGracefully();  
        \}  
    \}

public static void main(String\[\] args) throws Exception \{  
        int port = 8000;  
        new GameServer().bind(port);  
    \}

@PostConstruct  
    public void start() \{  
        int port = 8000;  
        try \{  
          bind(port);  
        \} catch (Exception e) \{  
            throw new RuntimeException(e);  
        \}  
    \}

1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
37  
38  
39  
40  
41  
42  
43  
44  
45  
46  
47  
48  
49  
50  
51  
52  
53  
54  
55  
56  
57  
58  
59  
60  
61  
62  
63  
64  
65  
66  
67  
68  
69  
70  
71  
72  
73  
74  
75  
76  
77  
78  
79  
80  
81  
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
37  
38  
39  
40  
41  
42  
43  
44  
45  
46  
47  
48  
49  
50  
51  
52  
53  
54  
55  
56  
57  
58  
59  
60  
61  
62  
63  
64  
65  
66  
67  
68  
69  
70  
71  
72  
73  
74  
75  
76  
77  
78  
79  
80  
81  
期间遇到的各种问题  
整合的时候遇到过很多问题

整合Netty时，由于使用new关键字创建Handler实例，导致在Handle中装配的服务实例为空，不能使用。  
MyBatis配置类写在了mysql模块而没有写在gameserver模块,导致mapper文件扫描不到。  
逆向工程时产生了同名的mapper xml文件未及时删除，导致出现mapper result map 重复的错误。  
结语  
当前只整合了持久化模块，接下来还要编写请求分发的部分和整合缓存模块。  
\---------------------   
作者：gonefuture   
来源：CSDN   
原文：https://blog.csdn.net/weixin\_35040169/article/details/82773714   
版权声明：本文为博主原创文章，转载请附上博文链接！