net-pull

Providing idiomatic interfaces of the client & server to implement the net pull-stream.

dependency

<dependency>
    <groupId>com.zmannotes</groupId>
    <artifactId>net-pull</artifactId>
    <version>2.1.3</version>
</dependency>

interfaces

IClient

public interface IClient<T> {

    /**
     * 连接目标服务地址
     * @param ip    ip
     * @param port  端口
     */
    void connect(String ip, int port) ;

    /**
     * 主动断开连接
     */
    void disconnect();

    /**
     * 成功连接到server时的回调函数
     * @param callback 回调函数
     */
    IClient onConnected(Consumer<T> callback);

    /**
     * 连接断开时回调
     * @param callback 回调函数
     */
    IClient onDisconnected(Runnable callback);

    /**
     * 连接发生异常时回调
     * @param callback  回调函数
     */
    IClient onThrowable(Consumer<Throwable> callback);

}

IServer

public interface IServer {

    /**
     * 启动Server，监听端口
     * @param port 监听的端口
     */
    void listen(int port);

    /**
     * 停止server，断开所有连接
     */
    void close();

    /**
     * 有新client接入时，回调callback函数
     *
     * @param callback  回调函数，参数：Integer: 连接唯一id，IDuplex：双工流
     */
    IServer onAccept(BiConsumer<Integer, T> callback);

    /**
     * 连接断开时回调
     * @param callback 回调函数，参数为：connectionId 连接唯一id
     *
     */
    IServer onDisconnect(Consumer<Integer> callback);

    /**
     * server停止成功时回调
     * @param callback 回调函数
     */
    IServer onClosed(Runnable callback);

    /**
     * server运行发生异常时回调
     * @param callback 回调函数
     */
    IServer onThrowable(Consumer<Throwable> callback);

}

example

clientTest
        .onConnected(connectCallback)
        .onDisconnected(disconnectCallback)
        .onThrowable(throwableCallback)
        .connect("ip", 0);