前面实现 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_account
- where username = #{username} and password = #{password} and is_delete = 0
- </select>
- <!-- id 查询 -->
- <select id="find" resultMap="BaseResultMap">
- select *
- from user_account
- where id = #{id} and is_delete = 0
- </select>
- <!-- 根据用户名查找用户 -->
- <select id="findByUsername" resultMap="BaseResultMap">
- select *
- from user_account
- where 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 >= #{levelStart}
- </if>
- <if test="levelEnd != null">
- and level <= #{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 >= #{levelStart}
- </if>
- <if test="levelEnd != null">
- and level <= #{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 {
- @Autowired
- UserAccountMapper 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());
- @Autowired
- UserAccountManager 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("用户注册失败");
- }
- }
- @Override
- public 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/beans
- http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
- http://www.springframework.org/schema/mvc
- http://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
来源: https://www.cnblogs.com/lyosaki88/p/idlewow_10.html