README.md · trent01/sds

# Socket Delivery Server

该框架是提供TCP Socket长连接的高可用方案。核心方案参考 ![socket负载均衡方案](https://github.com/1991wangliang/distribute-netty)。框架采用的核心技术框架：netty springcloud redis eureka

框架主要是为了提供一个可以负载大量socket tcp长连接的通讯服务。分为两部分delivery分发负载模块、socketServer通讯模块。
模块delivery依赖redis共享数据，提供双服务提高高可用性能；socketServer基于eureka负载可提供无上限的拓展支持，提供海量socket长连接请求业务。

## SDS的架构图：

![](readme/sds.jpg)

## 目录介绍

delivery 分发服务库   
socketServer socket通讯服务库  
demo    演示案例

框架将delivery与socketServer均以第三方库的方式做的封装。再使用时只需要依赖他们就可以。

## demo说明

详细请下载demo文件夹下的代码

首先要按照jar，在sds源码下分别对delivery与socketServer执行clean install 安装jar

````
        <dependency>
            <groupId>com.lorne.sds</groupId>
            <artifactId>socket-server</artifactId>
            <version>1.0.0</version>
        </dependency>
        
        
        
        <dependency>
            <groupId>com.lorne.sds</groupId>
            <artifactId>delivery</artifactId>
            <version>1.0.0</version>
        </dependency>
````

主要业务实现

socket-demo 主要实现`SocketEventService`接口

````

@Override
    public void onReadListener(ChannelHandlerContext ctx, String uniqueKey, Object msg) {
        //读取数据事件
        System.out.println(msg);
    }

@Override
    public void onConnectionListener(ChannelHandlerContext ctx, String uniqueKey) {
        //连接服务事件
        System.out.println(uniqueKey);
    }

@Override
    public void onDisConnectionListener(ChannelHandlerContext ctx, String uniqueKey) {
        //断开连接事件
    }

@Override
    public void onHeartNoWriteDataListener(ChannelHandlerContext ctx, String uniqueKey) {
        //心跳写入超时监听
    }

@Override
    public void onHeartNoReadDataListener(ChannelHandlerContext ctx, String uniqueKey) {
        //心跳读取超时监听
    }

@Override
    public boolean hasOpenHeartCheck() {
        //是否开启心跳检查
        return true;
    }

````

delivery-demo 主要实现`DeliveryServerSendEventService`接口

````
@Service
public class DeliveryServerSendEventServiceImpl implements DeliveryServerSendEventService {

@Autowired
    private DeliveryServerService deliveryServerService;

@Override
    public void onDeliveryListener(ChannelHandlerContext ctx, Object msg) {
        //获取服务
        Server server =  deliveryServerService.getOkServer();
        //发送信息
        SocketUtils.send(ctx.channel(),server.toString().getBytes());
    }
}

````

## 启动说明

框架依赖eureka和redis，在启动项目之前要确保这两个服务已开启。

然后在运行两个demo。

demo配置请参看`application.properties`的参数说明

trent01/sds

简介

发行版

贡献者

近期动态

trent01/sds .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

trent01/sds