WOIM——一个基于Netty、SpingBoot开发的分布式、嵌入式、组件化、高度自定义、高可扩展的Java即时通讯(IM)框架

阅读：评论：0

WOIM

Introduction

WOIM是一个基于Netty、SpingBoot开发的分布式、嵌入式、组件化、高度自定义、高可扩展的Java即时通讯框架，可以轻松嵌入你自己的用户系统，以提供即时通讯服务,同时也可作为消息推送系统，成为连接双端的桥梁。

Features

分布式

支持分布式集群部署，单机无法满足用户量需求时可水平扩展。
嵌入式

只需实现自己的连接鉴权逻辑，便可非侵入式地嵌入已有的用户系统。
组件化

从连接管理到消息处理通道再到业务逻辑都是可拆卸、组装的。
高度自定义

非侵入式，支持二次开发和功能集成，对于内置默认的各个组件以及业务逻辑可进行替换及自定义开发，你可以通过WOIM搭建最适合你自己的即时通讯服务。
高可扩展

内置了序列化和反序列化逻辑，真正的消息类型自定义，配置了相应的处理逻辑后，你便可以向客户端推送任何自定义的消息类型，包括但不限于私聊、群聊消息、系统推送。
完善的IM功能

内置了私聊、群聊、离线消息、会话管理等一系列功能（出于对隐私的尊重，没有内置漫游消息的功能，但支持二次开发实现），支持多种消息类型的扩展，文字、语音、图片、文件，支持多端登录。
同端口，多协议，热插拔

支持多种传输协议，默认使用protobuf、websocket，支持自定义协议扩展，同端口下可多协议切换，协议热插拔。

Quick Start

初始化数据库表格
- 方法一：配置文件中配置
  
  默认为NONE模式，不进行数据库的初始化，可选模式有NEW（删除旧表，创建新表），SAFE（不存在则创建）模式
```
woi:woim:db-initialization-mode: SAFE
```
- 方法二：执行sql脚本
  
  执行提供的sql脚本

依赖引入

本项目暂未上传至中央仓库，可clone后安装到本地maven仓库

服务端

maven

    <dependency><groupId&h</groupId><artifactId>woi-woim</artifactId><version>1.0.0</version></dependency>

客户端

maven

    <dependency><groupId&h</groupId><artifactId>woi-woim-client</artifactId><version>1.0.0</version></dependency>

gradle

    implementation &#h:woi-woim-client:1.0.0'

使用及开发

详见example模块

服务端

快速开发

注解开启WOIM

@SpringBootApplication
@EnableWOIM //todo enable woim
public class WoiWOIMExampleApplication {public static void main(String[] args) {SpringApplication.run(WoiWOIMExampleApplication.class, args);}
}

实现WOIMConfigurator

//or implements WOIMConfigurator
@Component
public class ExampleConfigurator extends DefaultWOIMConfigurator{@Overridepublic WOIMVerifier getChannelVerifier() {//todo 配置自己的连接授权方法，适配自己的用户系统return null;}
}

集群

编写配置文件

woi:woim:server-addr: 127.0.0.1:8080,127.0.0.1:8081,127.0.0.1:8082

客户端

快速开发

//init client
WOIMClient client = new WOIMClient.Builder().setInetHost("127.0.0.1").setPort(6666).setEventListener(new CustomEventListener()).setConfigurator(new CustomConfigurator()).build();
//auth
client.authSafely("token",null,null);
//send message
client.push(new PrivateMsg());
//the customized message you pushed must be serializable!!!