从零开始实现放置游戏（十）——实现战斗挂机（1）hessian服务端搭建

2023-11-01 15:30
文章标签 实现 搭建 服务端 放置 游戏 从零开始 挂机 hessian 战斗

本文主要是介绍从零开始实现放置游戏（十）——实现战斗挂机（1）hessian服务端搭建，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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

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

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

实现步骤

idlewow-facade

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

package com.idlewow.user.model;import com.idlewow.common.model.BaseModel;
import lombok.Data;import java.io.Serializable;@Data
public class UserAccount extends BaseModel implements Serializable {private String username;private String password;private String mail;private String phone;private String realName;private String idNo;private Integer status;private String remark;private String registerIp;
}

UserAccount.java

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

package com.idlewow.user.service;import com.idlewow.common.model.CommonResult;public interface UserService {CommonResult register(String username, String password, String ip);CommonResult login(String username, String password);
}

UserService.java

idlewow-core

新建包com.idlewow.user.mapper，添加mapper文件：

package com.idlewow.user.mapper;import com.idlewow.user.model.UserAccount;public interface UserAccountMapper {int register(UserAccount userAccount);UserAccount login(UserAccount userAccount);UserAccount findByUsername(String username);
}

UserAccountMapper.java

<?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.idlewow.user.mapper.UserAccountMapper"><resultMap id="BaseResultMap" type="com.idlewow.user.model.UserAccount"><result column="id" property="id"/><result column="username" property="username"/><result column="password" property="password"/><result column="mail" property="mail"/><result column="phone" property="phone"/><result column="real_name" property="realName"/><result column="id_no" property="idNo"/><result column="status" property="status"/><result column="remark" property="remark"/><result column="register_ip" property="registerIp"/><result column="create_user" property="createUser"/><result column="update_user" property="updateUser"/><result column="create_time" property="createTime"/><result column="update_time" property="updateTime"/><result column="is_delete" property="isDelete"/><result column="version" property="version"/></resultMap><!-- 注册 --><insert id="register">insert into user_account (username, password, register_ip, create_user)values (#{username}, #{password}, #{registerIp}, #{createUser})</insert><!-- 登陆 --><select id="login" resultMap="BaseResultMap">select *from user_accountwhere username = #{username} and password = #{password} and is_delete = 0</select><!-- id查询 --><select id="find" resultMap="BaseResultMap">select *from user_accountwhere id = #{id} and is_delete = 0</select><!-- 根据用户名查找用户 --><select id="findByUsername" resultMap="BaseResultMap">select *from user_accountwhere username = #{username} and is_delete = 0</select><!-- 列表查询总数 --><select id="count" resultType="int">select count(1)from map_mob<where>is_delete = 0<if test="mapId != null">and map_id = #{mapId}</if><if test="faction != null">and faction = #{faction}</if><if test="mobClass != null">and mob_class = #{mobClass}</if><if test="mobType != null">and mob_type = #{mobType}</if><if test="levelStart != null">and level &gt;= #{levelStart}</if><if test="levelEnd != null">and level &lt;= #{levelEnd}</if><if test="name != null and name != ''">and name like concat('%', #{name}, '%')</if></where></select><!-- 列表查询 --><select id="list" resultMap="BaseResultMap">select *from map_mob<where>is_delete = 0<if test="mapId != null">and map_id = #{mapId}</if><if test="faction != null">and faction = #{faction}</if><if test="mobClass != null">and mob_class = #{mobClass}</if><if test="mobType != null">and mob_type = #{mobType}</if><if test="levelStart != null">and level &gt;= #{levelStart}</if><if test="levelEnd != null">and level &lt;= #{levelEnd}</if><if test="name != null and name != ''">and name like concat('%', #{name}, '%')</if></where><if test="pageParam != null">limit ${(pageParam.pageIndex - 1) * pageParam.pageSize}, ${pageParam.pageSize}</if></select>
</mapper>

UserAccountMapper.xml

新建com.idlewow.user.manager包，添加manager类：

package com.idlewow.user.manager;import com.idlewow.user.mapper.UserAccountMapper;
import com.idlewow.user.model.UserAccount;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class UserAccountManager {@AutowiredUserAccountMapper userAccountMapper;public UserAccount findByUsername(String username) {return userAccountMapper.findByUsername(username);}public void register(String username, String password, String ip) {UserAccount userAccount = new UserAccount();userAccount.setUsername(username);userAccount.setPassword(password);userAccount.setRegisterIp(ip);userAccount.setCreateUser("idlewow");int effected = userAccountMapper.register(userAccount);if (effected == 0) {throw new RuntimeException("sql effected 0 rows");}}public UserAccount login(String username, String password) {UserAccount userAccount = new UserAccount();userAccount.setUsername(username);userAccount.setPassword(password);return userAccountMapper.login(userAccount);}
}

UserAccountManager.java

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

package com.idlewow.user.service.impl;import com.idlewow.common.model.CommonResult;
import com.idlewow.user.manager.UserAccountManager;
import com.idlewow.user.model.UserAccount;
import com.idlewow.user.service.UserService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service("userService")
public class UserServiceImpl implements UserService {private final Logger logger = LogManager.getLogger(this.getClass().getName());@AutowiredUserAccountManager userAccountManager;public CommonResult register(String username, String password, String ip) {try {UserAccount userAccount = userAccountManager.findByUsername(username);if (userAccount != null) {return CommonResult.fail("此用户名已被注册！");}userAccountManager.register(username, password, ip);return CommonResult.success();} catch (Exception ex) {logger.error("用户注册失败：" + ex.getMessage(), ex);return CommonResult.fail("用户注册失败");}}@Overridepublic CommonResult login(String username, String password) {try {UserAccount userAccount = userAccountManager.login(username, password);if (userAccount == null) {return CommonResult.fail("用户名或密码错误！");}if (userAccount.getStatus() == 1) {return CommonResult.fail("账号已冻结！");}return CommonResult.success("", userAccount);} catch (Exception ex) {logger.error("用户登录失败：" + ex.getMessage(), ex);return CommonResult.fail("用户登录失败");}}
}

UserServiceImpl.java

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

idlewow-hessian

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

<?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>idlewow</artifactId><groupId>idlewow</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>idlewow-hessian</artifactId><packaging>war</packaging><dependencies><dependency><groupId>idlewow</groupId><artifactId>idlewow-facade</artifactId><version>1.0-SNAPSHOT</version></dependency><dependency><groupId>idlewow</groupId><artifactId>idlewow-core</artifactId><version>1.0-SNAPSHOT</version></dependency><dependency><groupId>com.caucho</groupId><artifactId>hessian</artifactId><version>4.0.60</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.1.6.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context-support</artifactId><version>5.1.6.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-core</artifactId><version>5.1.6.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-web</artifactId><version>5.1.6.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>5.1.6.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-aop</artifactId><version>5.1.6.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>5.1.6.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-tx</artifactId><version>5.1.6.RELEASE</version></dependency><dependency><groupId>javax.servlet</groupId><artifactId>javax.servlet-api</artifactId><version>4.0.1</version><scope>provided</scope></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId><version>1.9.3</version></dependency><dependency><groupId>org.mybatis</groupId><artifactId>mybatis-spring</artifactId><version>2.0.1</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-dbcp2</artifactId><version>2.6.0</version></dependency></dependencies><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><configuration><source>1.8</source><target>1.8</target></configuration></plugin><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.2</version><configuration><uriEncoding>UTF-8</uriEncoding><port>20000</port><path>/</path></configuration></plugin><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-war-plugin</artifactId><version>2.6</version></plugin></plugins></build>
</project>

pom.xml

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

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee"xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"version="3.0"><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:spring/applicationContext.xml</param-value></context-param><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener><filter><filter-name>CharacterEncodingFilter</filter-name><filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class><init-param><param-name>encoding</param-name><param-value>utf-8</param-value></init-param></filter><filter-mapping><filter-name>CharacterEncodingFilter</filter-name><url-pattern>/remoting/*</url-pattern></filter-mapping><servlet><servlet-name>remoting</servlet-name><servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class><init-param><param-name>contextConfigLocation</param-name><param-value>classpath:spring/hessian-servlet.xml</param-value></init-param><load-on-startup>2</load-on-startup></servlet><servlet-mapping><servlet-name>remoting</servlet-name><url-pattern>/remoting/*</url-pattern></servlet-mapping>
</web-app>

web.xml

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

<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:mvc="http://www.springframework.org/schema/mvc"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-3.1.xsdhttp://www.springframework.org/schema/mvchttp://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd"><mvc:annotation-driven/><bean name="/UserService" class="org.springframework.remoting.caucho.HessianServiceExporter"><property name="service" ref="userService"/><property name="serviceInterface" value="com.idlewow.user.service.UserService"/></bean>
</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如下：

import com.caucho.hessian.client.HessianProxyFactory;
import com.idlewow.common.model.CommonResult;
import com.idlewow.user.service.UserService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;public class HessianTest {protected static final Logger logger = LogManager.getLogger(HessianTest.class);public static void main(String[] args) {String url = "http://localhost:20000/remoting/UserService";HessianProxyFactory factory = new HessianProxyFactory();try {UserService userService = (UserService) factory.create(UserService.class, url);CommonResult commonResult = userService.register("testuser", "123456", "127.0.0.1");logger.info(commonResult);} catch (Exception e) {logger.error(e.getMessage(), e);e.printStackTrace();}}
}

HessianTest.java

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

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

小结

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

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

项目交流群：329989095

这篇关于从零开始实现放置游戏（十）——实现战斗挂机（1）hessian服务端搭建的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/323967。

相关文章

AJAX请求上传下载进度监控实现方式

AJAX请求上传下载进度监控实现方式

《AJAX请求上传下载进度监控实现方式》在日常Web开发中,AJAX（AsynchronousJavaScriptandXML）被广泛用于异步请求数据,而无需刷新整个页面,：本文主要介绍AJAX请... 目录1. 前言2. 基于XMLHttpRequest的进度监控2.1 基础版文件上传监控2.2 增强版多
阅读更多...
Redis分片集群的实现

Redis分片集群的实现

《Redis分片集群的实现》Redis分片集群是一种将Redis数据库分散到多个节点上的方式,以提供更高的性能和可伸缩性,本文主要介绍了Redis分片集群的实现,具有一定的参考价值,感兴趣的可以了解一... 目录1. Redis Cluster的核心概念哈希槽（Hash Slots）主从复制与故障转移2.
阅读更多...
springboot+dubbo实现时间轮算法

springboot+dubbo实现时间轮算法

《springboot+dubbo实现时间轮算法》时间轮是一种高效利用线程资源进行批量化调度的算法,本文主要介绍了springboot+dubbo实现时间轮算法,文中通过示例代码介绍的非常详细,对大家... 目录前言一、参数说明二、具体实现1、HashedwheelTimer2、createWheel3、n
阅读更多...
使用Python实现一键隐藏屏幕并锁定输入

使用Python实现一键隐藏屏幕并锁定输入

《使用Python实现一键隐藏屏幕并锁定输入》本文主要介绍了使用Python编写一个一键隐藏屏幕并锁定输入的黑科技程序,能够在指定热键触发后立即遮挡屏幕,并禁止一切键盘鼠标输入,这样就再也不用担心自己... 目录1. 概述2. 功能亮点3.代码实现4.使用方法5. 展示效果6. 代码优化与拓展7. 总结1.
阅读更多...
Mybatis 传参与排序模糊查询功能实现

Mybatis 传参与排序模糊查询功能实现

《Mybatis传参与排序模糊查询功能实现》：本文主要介绍Mybatis传参与排序模糊查询功能实现,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧... 目录一、#{ }和${ }传参的区别二、排序三、like查询四、数据库连接池五、mysql 开发企业规范一、#{ }和${ }传参的
阅读更多...
Docker镜像修改hosts及dockerfile修改hosts文件的实现方式

Docker镜像修改hosts及dockerfile修改hosts文件的实现方式

《Docker镜像修改hosts及dockerfile修改hosts文件的实现方式》：本文主要介绍Docker镜像修改hosts及dockerfile修改hosts文件的实现方式,具有很好的参考价... 目录docker镜像修改hosts及dockerfile修改hosts文件准备 dockerfile 文
阅读更多...
基于SpringBoot+Mybatis实现Mysql分表

基于SpringBoot+Mybatis实现Mysql分表

《基于SpringBoot+Mybatis实现Mysql分表》这篇文章主要为大家详细介绍了基于SpringBoot+Mybatis实现Mysql分表的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可... 目录基本思路定义注解创建ThreadLocal创建拦截器业务处理基本思路1.根据创建时间字段按年进
阅读更多...
SpringBoot3实现Gzip压缩优化的技术指南

SpringBoot3实现Gzip压缩优化的技术指南

《SpringBoot3实现Gzip压缩优化的技术指南》随着Web应用的用户量和数据量增加,网络带宽和页面加载速度逐渐成为瓶颈,为了减少数据传输量,提高用户体验,我们可以使用Gzip压缩HTTP响应,... 目录1、简述2、配置2.1 添加依赖2.2 配置 Gzip 压缩3、服务端应用4、前端应用4.1 N
阅读更多...
SpringBoot实现数据库读写分离的3种方法小结

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一：基于AbstractRoutingDataSource实现动态
阅读更多...
Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

《PythonFastAPI+Celery+RabbitMQ实现分布式图片水印处理系统》这篇文章主要为大家详细介绍了PythonFastAPI如何结合Celery以及RabbitMQ实现简单的分布式... 实现思路FastAPI 服务器Celery 任务队列RabbitMQ 作为消息代理定时任务处理完整
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2