经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » 游戏设计 » 查看文章
从零开始实现放置游戏(十)——实现战斗挂机(1)hessian服务端搭建
来源:cnblogs  作者:丶谦信  时间:2019/7/15 8:38:46  对本文有异议

  前面实现RMS系统时,我们让其直接访问底层数据库。后面我们在idlewow-game模块实现游戏逻辑时,将不再直接访问底层数据,而是通过hessian服务暴露接口给表现层。

  本章,我们先把hessian服务搭好,并做一个简单的测试,这里以用户注册接口为例。

  先简单介绍下,实现hessian接口,只需要在facade模块暴露接口,然后在core模块实现接口,最后在hessain模块配置好接口路由,将其启动即可。

实现步骤

idlewow-facade

  新建包com.idlewow.user.model,在此包下添加模型类:

  1. package com.idlewow.user.model;
  2. import com.idlewow.common.model.BaseModel;
  3. import lombok.Data;
  4. import java.io.Serializable;
  5. @Data
  6. public class UserAccount extends BaseModel implements Serializable {
  7. private String username;
  8. private String password;
  9. private String mail;
  10. private String phone;
  11. private String realName;
  12. private String idNo;
  13. private Integer status;
  14. private String remark;
  15. private String registerIp;
  16. }
UserAccount.java

  新建包com.idlewow.user.service,在此包下添加接口类:

  1. package com.idlewow.user.service;
  2. import com.idlewow.common.model.CommonResult;
  3. public interface UserService {
  4. CommonResult register(String username, String password, String ip);
  5. CommonResult login(String username, String password);
  6. }
UserService.java

idlewow-core

    新建包com.idlewow.user.mapper,添加mapper文件:

  1. package com.idlewow.user.mapper;
  2. import com.idlewow.user.model.UserAccount;
  3. public interface UserAccountMapper {
  4. int register(UserAccount userAccount);
  5. UserAccount login(UserAccount userAccount);
  6. UserAccount findByUsername(String username);
  7. }
UserAccountMapper.java
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.idlewow.user.mapper.UserAccountMapper">
  4. <resultMap id="BaseResultMap" type="com.idlewow.user.model.UserAccount">
  5. <result column="id" property="id"/>
  6. <result column="username" property="username"/>
  7. <result column="password" property="password"/>
  8. <result column="mail" property="mail"/>
  9. <result column="phone" property="phone"/>
  10. <result column="real_name" property="realName"/>
  11. <result column="id_no" property="idNo"/>
  12. <result column="status" property="status"/>
  13. <result column="remark" property="remark"/>
  14. <result column="register_ip" property="registerIp"/>
  15. <result column="create_user" property="createUser"/>
  16. <result column="update_user" property="updateUser"/>
  17. <result column="create_time" property="createTime"/>
  18. <result column="update_time" property="updateTime"/>
  19. <result column="is_delete" property="isDelete"/>
  20. <result column="version" property="version"/>
  21. </resultMap>
  22. <!-- 注册 -->
  23. <insert id="register">
  24. insert into user_account (username, password, register_ip, create_user)
  25. values (#{username}, #{password}, #{registerIp}, #{createUser})
  26. </insert>
  27. <!-- 登陆 -->
  28. <select id="login" resultMap="BaseResultMap">
  29. select *
  30. from user_account
  31. where username = #{username} and password = #{password} and is_delete = 0
  32. </select>
  33. <!-- id查询 -->
  34. <select id="find" resultMap="BaseResultMap">
  35. select *
  36. from user_account
  37. where id = #{id} and is_delete = 0
  38. </select>
  39. <!-- 根据用户名查找用户 -->
  40. <select id="findByUsername" resultMap="BaseResultMap">
  41. select *
  42. from user_account
  43. where username = #{username} and is_delete = 0
  44. </select>
  45. <!-- 列表查询总数 -->
  46. <select id="count" resultType="int">
  47. select count(1)
  48. from map_mob
  49. <where>
  50. is_delete = 0
  51. <if test="mapId != null">
  52. and map_id = #{mapId}
  53. </if>
  54. <if test="faction != null">
  55. and faction = #{faction}
  56. </if>
  57. <if test="mobClass != null">
  58. and mob_class = #{mobClass}
  59. </if>
  60. <if test="mobType != null">
  61. and mob_type = #{mobType}
  62. </if>
  63. <if test="levelStart != null">
  64. and level &gt;= #{levelStart}
  65. </if>
  66. <if test="levelEnd != null">
  67. and level &lt;= #{levelEnd}
  68. </if>
  69. <if test="name != null and name != ''">
  70. and name like concat('%', #{name}, '%')
  71. </if>
  72. </where>
  73. </select>
  74. <!-- 列表查询 -->
  75. <select id="list" resultMap="BaseResultMap">
  76. select *
  77. from map_mob
  78. <where>
  79. is_delete = 0
  80. <if test="mapId != null">
  81. and map_id = #{mapId}
  82. </if>
  83. <if test="faction != null">
  84. and faction = #{faction}
  85. </if>
  86. <if test="mobClass != null">
  87. and mob_class = #{mobClass}
  88. </if>
  89. <if test="mobType != null">
  90. and mob_type = #{mobType}
  91. </if>
  92. <if test="levelStart != null">
  93. and level &gt;= #{levelStart}
  94. </if>
  95. <if test="levelEnd != null">
  96. and level &lt;= #{levelEnd}
  97. </if>
  98. <if test="name != null and name != ''">
  99. and name like concat('%', #{name}, '%')
  100. </if>
  101. </where>
  102. <if test="pageParam != null">
  103. limit ${(pageParam.pageIndex - 1) * pageParam.pageSize}, ${pageParam.pageSize}
  104. </if>
  105. </select>
  106. </mapper>
UserAccountMapper.xml

  新建com.idlewow.user.manager包,添加manager类:

  1. package com.idlewow.user.manager;
  2. import com.idlewow.user.mapper.UserAccountMapper;
  3. import com.idlewow.user.model.UserAccount;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.stereotype.Component;
  6. @Component
  7. public class UserAccountManager {
  8. @Autowired
  9. UserAccountMapper userAccountMapper;
  10. public UserAccount findByUsername(String username) {
  11. return userAccountMapper.findByUsername(username);
  12. }
  13. public void register(String username, String password, String ip) {
  14. UserAccount userAccount = new UserAccount();
  15. userAccount.setUsername(username);
  16. userAccount.setPassword(password);
  17. userAccount.setRegisterIp(ip);
  18. userAccount.setCreateUser("idlewow");
  19. int effected = userAccountMapper.register(userAccount);
  20. if (effected == 0) {
  21. throw new RuntimeException("sql effected 0 rows");
  22. }
  23. }
  24. public UserAccount login(String username, String password) {
  25. UserAccount userAccount = new UserAccount();
  26. userAccount.setUsername(username);
  27. userAccount.setPassword(password);
  28. return userAccountMapper.login(userAccount);
  29. }
  30. }
UserAccountManager.java

   新建com.idlewow.user.service.impl包,添加接口的实现类:

  1. package com.idlewow.user.service.impl;
  2. import com.idlewow.common.model.CommonResult;
  3. import com.idlewow.user.manager.UserAccountManager;
  4. import com.idlewow.user.model.UserAccount;
  5. import com.idlewow.user.service.UserService;
  6. import org.apache.logging.log4j.LogManager;
  7. import org.apache.logging.log4j.Logger;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.stereotype.Service;
  10. @Service("userService")
  11. public class UserServiceImpl implements UserService {
  12. private final Logger logger = LogManager.getLogger(this.getClass().getName());
  13. @Autowired
  14. UserAccountManager userAccountManager;
  15. public CommonResult register(String username, String password, String ip) {
  16. try {
  17. UserAccount userAccount = userAccountManager.findByUsername(username);
  18. if (userAccount != null) {
  19. return CommonResult.fail("此用户名已被注册!");
  20. }
  21. userAccountManager.register(username, password, ip);
  22. return CommonResult.success();
  23. } catch (Exception ex) {
  24. logger.error("用户注册失败:" + ex.getMessage(), ex);
  25. return CommonResult.fail("用户注册失败");
  26. }
  27. }
  28. @Override
  29. public CommonResult login(String username, String password) {
  30. try {
  31. UserAccount userAccount = userAccountManager.login(username, password);
  32. if (userAccount == null) {
  33. return CommonResult.fail("用户名或密码错误!");
  34. }
  35. if (userAccount.getStatus() == 1) {
  36. return CommonResult.fail("账号已冻结!");
  37. }
  38. return CommonResult.success("", userAccount);
  39. } catch (Exception ex) {
  40. logger.error("用户登录失败:" + ex.getMessage(), ex);
  41. return CommonResult.fail("用户登录失败");
  42. }
  43. }
  44. }
UserServiceImpl.java

  注意,这里ServiceImple类上面有个注解 @Service("userService")。后面我们再添加这种对外的服务类时,都要加这个注解。

 idlewow-hessian

  hessian用于服务(器)间通信,实际上也是由一个DispatherServlet接收请求,并转发到各个Service中处理,和springmvc差不多,只不过返回的是二进制数据,而不是视图。我们在pom下添加下列依赖,可以发现依赖的包和mvc差不多。另外,作为启动项目,在plugins节点下,我们配置了启动插件tomcat7以及启动端口20000。

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5. <parent>
  6. <artifactId>idlewow</artifactId>
  7. <groupId>idlewow</groupId>
  8. <version>1.0-SNAPSHOT</version>
  9. </parent>
  10. <modelVersion>4.0.0</modelVersion>
  11.  
  12. <artifactId>idlewow-hessian</artifactId>
  13. <packaging>war</packaging>
  14.  
  15. <dependencies>
  16. <dependency>
  17. <groupId>idlewow</groupId>
  18. <artifactId>idlewow-facade</artifactId>
  19. <version>1.0-SNAPSHOT</version>
  20. </dependency>
  21. <dependency>
  22. <groupId>idlewow</groupId>
  23. <artifactId>idlewow-core</artifactId>
  24. <version>1.0-SNAPSHOT</version>
  25. </dependency>
  26. <dependency>
  27. <groupId>com.caucho</groupId>
  28. <artifactId>hessian</artifactId>
  29. <version>4.0.60</version>
  30. </dependency>
  31. <dependency>
  32. <groupId>org.springframework</groupId>
  33. <artifactId>spring-context</artifactId>
  34. <version>5.1.6.RELEASE</version>
  35. </dependency>
  36. <dependency>
  37. <groupId>org.springframework</groupId>
  38. <artifactId>spring-context-support</artifactId>
  39. <version>5.1.6.RELEASE</version>
  40. </dependency>
  41. <dependency>
  42. <groupId>org.springframework</groupId>
  43. <artifactId>spring-core</artifactId>
  44. <version>5.1.6.RELEASE</version>
  45. </dependency>
  46. <dependency>
  47. <groupId>org.springframework</groupId>
  48. <artifactId>spring-web</artifactId>
  49. <version>5.1.6.RELEASE</version>
  50. </dependency>
  51. <dependency>
  52. <groupId>org.springframework</groupId>
  53. <artifactId>spring-webmvc</artifactId>
  54. <version>5.1.6.RELEASE</version>
  55. </dependency>
  56. <dependency>
  57. <groupId>org.springframework</groupId>
  58. <artifactId>spring-aop</artifactId>
  59. <version>5.1.6.RELEASE</version>
  60. </dependency>
  61. <dependency>
  62. <groupId>org.springframework</groupId>
  63. <artifactId>spring-jdbc</artifactId>
  64. <version>5.1.6.RELEASE</version>
  65. </dependency>
  66. <dependency>
  67. <groupId>org.springframework</groupId>
  68. <artifactId>spring-tx</artifactId>
  69. <version>5.1.6.RELEASE</version>
  70. </dependency>
  71. <dependency>
  72. <groupId>javax.servlet</groupId>
  73. <artifactId>javax.servlet-api</artifactId>
  74. <version>4.0.1</version>
  75. <scope>provided</scope>
  76. </dependency>
  77. <dependency>
  78. <groupId>org.aspectj</groupId>
  79. <artifactId>aspectjweaver</artifactId>
  80. <version>1.9.3</version>
  81. </dependency>
  82. <dependency>
  83. <groupId>org.mybatis</groupId>
  84. <artifactId>mybatis-spring</artifactId>
  85. <version>2.0.1</version>
  86. </dependency>
  87. <dependency>
  88. <groupId>org.apache.commons</groupId>
  89. <artifactId>commons-dbcp2</artifactId>
  90. <version>2.6.0</version>
  91. </dependency>
  92. </dependencies>
  93. <build>
  94. <plugins>
  95. <plugin>
  96. <groupId>org.apache.maven.plugins</groupId>
  97. <artifactId>maven-compiler-plugin</artifactId>
  98. <configuration>
  99. <source>1.8</source>
  100. <target>1.8</target>
  101. </configuration>
  102. </plugin>
  103. <plugin>
  104. <groupId>org.apache.tomcat.maven</groupId>
  105. <artifactId>tomcat7-maven-plugin</artifactId>
  106. <version>2.2</version>
  107. <configuration>
  108. <uriEncoding>UTF-8</uriEncoding>
  109. <port>20000</port>
  110. <path>/</path>
  111. </configuration>
  112. </plugin>
  113. <plugin>
  114. <groupId>org.apache.maven.plugins</groupId>
  115. <artifactId>maven-war-plugin</artifactId>
  116. <version>2.6</version>
  117. </plugin>
  118. </plugins>
  119. </build>
  120. </project>
pom.xml

  然后,我们需要在web.xml中配置hessian的servlet,以及添加一个字符编码的filter等等,如下:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee"
  3. xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
  4. version="3.0">
  5. <context-param>
  6. <param-name>contextConfigLocation</param-name>
  7. <param-value>classpath:spring/applicationContext.xml</param-value>
  8. </context-param>
  9. <listener>
  10. <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  11. </listener>
  12. <filter>
  13. <filter-name>CharacterEncodingFilter</filter-name>
  14. <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
  15. <init-param>
  16. <param-name>encoding</param-name>
  17. <param-value>utf-8</param-value>
  18. </init-param>
  19. </filter>
  20. <filter-mapping>
  21. <filter-name>CharacterEncodingFilter</filter-name>
  22. <url-pattern>/remoting/*</url-pattern>
  23. </filter-mapping>
  24. <servlet>
  25. <servlet-name>remoting</servlet-name>
  26. <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  27. <init-param>
  28. <param-name>contextConfigLocation</param-name>
  29. <param-value>classpath:spring/hessian-servlet.xml</param-value>
  30. </init-param>
  31. <load-on-startup>2</load-on-startup>
  32. </servlet>
  33. <servlet-mapping>
  34. <servlet-name>remoting</servlet-name>
  35. <url-pattern>/remoting/*</url-pattern>
  36. </servlet-mapping>
  37. </web-app>
web.xml

  在/resource/spring目录下,新建hessian服务的配置文件hessian-servlet.xml。这个xml主要配置对外暴露的hessian服务。现在我们只配置了UserService,后面每次添加对外的服务接口时,都需要在这里添加配置。

  1. <beans xmlns="http://www.springframework.org/schema/beans"
  2. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xmlns:mvc="http://www.springframework.org/schema/mvc"
  4. xsi:schemaLocation="
  5. http://www.springframework.org/schema/beans
  6. http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
  7. http://www.springframework.org/schema/mvc
  8. http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd
  9. ">
  10.  
  11. <mvc:annotation-driven/>
  12.  
  13. <bean name="/UserService" class="org.springframework.remoting.caucho.HessianServiceExporter">
  14. <property name="service" ref="userService"/>
  15. <property name="serviceInterface" value="com.idlewow.user.service.UserService"/>
  16. </bean>
  17. </beans>
hessian-servlet.xml

  除了这3个配置外,还需要配置applicationContext.xml, jdbc.propetries, dataSource.xml, log4j2.xml,和RMS系统大体一致,这里就不再重复了。具体可在源码中查看。

  全部搞定后,只要把hessian项目启动,即可调用hessian接口了。启动步骤和rms一样,maven命令也是tomcat7:run,工作目录切换到hessian目录下即可。

运行效果

  在game模块中调用hessian时,也是通过在xml中配置注入的方式调用。这里我们还没开始写game模块,为了测试,先简单写一个入口类(即带main函数的类)调用。类似于C#中写控制台程序调用。

  在/src/test/java包下新建一个类HessianTest.java如下:

  1. import com.caucho.hessian.client.HessianProxyFactory;
  2. import com.idlewow.common.model.CommonResult;
  3. import com.idlewow.user.service.UserService;
  4. import org.apache.logging.log4j.LogManager;
  5. import org.apache.logging.log4j.Logger;
  6. public class HessianTest {
  7. protected static final Logger logger = LogManager.getLogger(HessianTest.class);
  8. public static void main(String[] args) {
  9. String url = "http://localhost:20000/remoting/UserService";
  10. HessianProxyFactory factory = new HessianProxyFactory();
  11. try {
  12. UserService userService = (UserService) factory.create(UserService.class, url);
  13. CommonResult commonResult = userService.register("testuser", "123456", "127.0.0.1");
  14. logger.info(commonResult);
  15. } catch (Exception e) {
  16. logger.error(e.getMessage(), e);
  17. e.printStackTrace();
  18. }
  19. }
  20. }
HessianTest.java

  在这个类中,我们指定hessian服务地址,并利用代理工厂创建一个服务代理。然后调用用户注册方法。测试的时候,先把hessian项目启动。然后执行这个main方法即可。

运行效果如下图,可以看到,接口调用成功,并把执行结果在日志中打印了出来。

小结

  本节把hessian服务搭建运行起来,并实现了用户注册登录的接口。后面game模块凡是访问底层数据,均需调用hessian服务。

  本章源码下载:https://idlestudio.ctfile.com/fs/14960372-387256708

  本文原文地址:https://www.cnblogs.com/lyosaki88/p/idlewow_10.html

 

原文链接:http://www.cnblogs.com/lyosaki88/p/idlewow_10.html

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号