SSL加密与分布式IM系统-InChat1.1.3版本试用说明

时间 2019-11-24

标签 ssl 加密分布式系统 inchat1.1.3 inchat 版本试用说明栏目 SSL 繁體版

原文原文链接

本文首发于本博客猫叔的博客，转载请申明出处html

2019年1月15号-InChat发布V1.1.3版本

InChat前端

一个轻量级、高效率的支持多端（应用与硬件Iot）的异步网络应用通信框架java

v1.1.3版本使用说明

v1.1.0-alpha版本使用说明 InChatV1.1.2版本使用说明git

历史更新说明

1.1.2版本github

捕获未注册连接断开异常，完善异常处理
修改项目启动流程，仿Selector启动模式
添加HTTP接口三个：发送通知消息,获取在线用户数,获取在线用户列表,暂不支持用户自定义HTTP接口（对于传统web API咱们但愿用户用本身的框架与流程）
服务端发送通知接口改成enum处理

1.1.3版本web

添加SSL加密，实现https与wss功能
接受用户自定义证书（浏览器信任与不信任都可以访问）
InChat配置可改成分布式或着单机版
引入Redis，处理集群信息与消息互通
若是有生产须要或者个别需求，发现BUG，欢迎留言，项目会更新新的API

关于InChat的Maven依赖

fastjson 》 1.2.53
gson 》 2.8.5
netty 》 4.1.32.Final
commons-lang 》 3.5
slf4j-log4j12 》 1.7.25
jedis 》 3.0.1

建立项目

建立一个空的Maven项目，并引入InChatMaven包，(注意，请不要使用与本项目相同的包目录)。redis

可能你只须要这样的Maven依赖便可算法

<dependencies>
    <dependency>
        <groupId>com.github.UncleCatMySelf</groupId>
        <artifactId>InChat</artifactId>
        <version>1.1.3</version>
    </dependency>
</dependencies>
复制代码

对接InChat的接口与实现

InChat启动参数能够自配置

你只须要继承InChat的默认配置类InitNetty便可，以下数据库

public class MyInit extends InitNetty {
    /** 自定义启动监听端口 */
    @Override
    public int getWebport() {
        return 8090;
    }
    /** 是否启动分布式 true-启动、false-不启动 */
    @Override
    public Boolean getDistributed() {
        return true;
    }
    /** 是否启动加密功能 */
    @Override
    public boolean isSsl() {
        return true;
    }
}
复制代码

请注意，分布式为测试版，因此暂不支持SSL加密，若是启动分布式请关闭SSL加密功能json

如何自定义证书？

#keytool -genkey -keysize 2048 -validity 365 -keyalg RSA -dnam e "CN=in-chat.cn" -keypass 123456 -storepass 123456 -keystore inchat.jks

keytool为JDK提供的生成证书工具

keysize 2048 密钥长度2048位（这个长度的密钥目前可认为没法被暴力破解）
validity 365 证书有效期365天
keyalg RSA 使用RSA非对称加密算法
dname "CN=gornix.com" 设置Common Name为gornix.com，这是个人域名
keypass 654321 密钥的访问密码为123456
storepass 123456 密钥库的访问密码为123456（其实这两个密码也能够设置同样，一般都设置同样，方便记）
keystore gornix.jks 指定生成的密钥库文件为inchat.jks

若是你试着本身建立了本身的证书，那么你须要去重写InitNetty中的几个信息：jksFile,jksStorePassword,jksCertificatePassword。你的jks文件只须要放到resources目录下就好，两个密码就是你以前设定相同的密码。本项目已经提供了默认的inchat.jks,请用户在Maven包中复制并粘贴到本身的项目中的resources文件夹中便可。

获取聊天消息数据

此接口与原先同样，仅修改了方法名

public class DataBaseServiceImpl implements InChatToDataBaseService {

    @Override
    public Boolean writeMessage(InChatMessage message) {
        System.out.println(message.toString());
        return true;
    }
}
复制代码

登陆校验与群聊消息

此接口没有作过多的修改

public class VerifyServiceImpl implements InChatVerifyService {

    @Override
    public boolean verifyToken(String token) {
        return true;
    }

    @Override
    public JSONArray getArrayByGroupId(String groupId) {
        JSONArray jsonArray = JSONArray.parseArray("[\"1111\",\"2222\",\"3333\"]");
        return jsonArray;
    }
}
复制代码

服务端发送通知消息枚举类

此接口具备Demo模板，用户须要继承InChat框架的FromServerService接口，同时该接口注释也有实例demo，咱们须要实现一个自定义的枚举，你能够这样写：

public enum  FromServerServiceImpl implements FromServerService {

    //你能够自定义本身的系统消息，请以Integer-String的形式
    TYPE1(1,"【系统通知】您的帐号存在异常，请注意安全保密信息。"),
    TYPE2(2,"【系统通知】恭喜您连续登陆超过5天，奖励5积分。");

    private Integer code;

    private String message;

    FromServerServiceImpl(Integer code, String message){
        this.code = code;
        this.message = message;
    }

    public Integer getCode() {
        return code;
    }

    //实现接口的方法，遍历本枚举的code，获取对应的消息，做为系统消息发送
    public String findByCode(Object code) {
        Integer codes = (Integer)code;
        for (FromServerServiceImpl item: FromServerServiceImpl.values()) {
            if (item.code == codes){
                return item.message;
            }
        }
        return null;
    }

    public void setCode(Integer code) {
        this.code = code;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }


}
复制代码

启动项目

1.1.3版本的启动项目变得异常的简单，你只须要配置启动的配置工厂便可。可是若是咱们启动了分布式的话，咱们还须要配置redis信息。

public class application {

    public static void main(String[] args) {
        //配置你的自定义配置
        ConfigFactory.initNetty = new MyInit();
        //配置校验类
        ConfigFactory.inChatVerifyService = new VerifyServiceImpl();
        //配置消息接收处理类
        ConfigFactory.inChatToDataBaseService = new DataBaseServiceImpl();
        //配置服务端系统消息枚举，这里的值无所谓 TYPE1或者TYPE2或者TYPEN都可以
        ConfigFactory.fromServerService = FromServerServiceImpl.TYPE1;
        //配置分布式Redis地址，端口目前默认的，下一版能够支持修改。
        ConfigFactory.RedisIP = "192.168.192.132";
        //启动InChat
        InitServer.open();
    }

}
复制代码

项目效果

启动成功

DEBUG - -Dio.netty.threadLocalDirectBufferSize: 0
DEBUG - -Dio.netty.maxThreadLocalCharBufferSize: 16384
 INFO - 服务端启动成功【192.168.56.1:8090】
 INFO - [RedisConfig.getJedis]:链接成功，测试链接PING->PONG
复制代码

若是你开通了分布式，那么你能够试着启动两个应用程序。

DEBUG - -Dio.netty.threadLocalDirectBufferSize: 0
DEBUG - -Dio.netty.maxThreadLocalCharBufferSize: 16384
 INFO - 服务端启动成功【192.168.56.1:8070】
 INFO - [RedisConfig.getJedis]:链接成功，测试链接PING->PONG
复制代码

读者能够到项目中使用原来的两个前端页面。

分别登陆两个用户在两个应用程序，并进行互相通讯便可。启动分布式请关闭SSL，分布式为测试版，暂不支持SSL

目前，分布式版本接通了点对点与群聊的功能，你们能够试试。下一版本会添加一个分布式的组件用来统一数据与接口功能。

关于加密的，请提早让电脑认同信任证书