mocket

模拟

 Lightweight, Typesafe, Reliable, Guaranty delivery, Ordered, High performant java nio sockets build 
on top of udp.

下载

• 使用jitpack作为存储库
• 将模拟添加到依赖项

如下图：

1. 梅文

< project >
...
    < repositories >
    ...
        < repository >
            < id >jitpack.io</ id >
            < url >https://jitpack.io</ url >
        </ repository >
    </ repositories >
</ project >

    < dependencies >
        ...
        < dependency >
            < groupId >com.github.Nishant-Pathak</ groupId >
            < artifactId >mocket</ artifactId >
            < version >v1.0</ version >
        </ dependency >
    </ dependencies >

2. 摇篮

    allprojects {
        repositories {
            .. .
            maven { url ' https://jitpack.io ' }
        }
    }

    dependencies {
        compile ' com.github.Nishant-Pathak:mocket:v1.0 '
    }

简单服务器

搭建服务器：

   ServerBuilder < byte []> serverBuilder = new ServerBuilder < byte []>()
        . port ( serverPort );
   Server < byte []> server = serverBuilder . build ();

阅读：

    while ( true ) {
      // blocking read
      Pair < SocketAddress , byte []> readBytes = server . read ();
    }

写：

    // write to server
    server . write ( read . getSecond (), read . getFirst ());

写签名：

  /**
   * writed data to the given address
   * @param data to send to addredd
   * @param address of the client connected
   * @throws IOException if error occurs while writing to the socket
   * @throws InterruptedException if write is interrupted
   */
  void write ( T data , SocketAddress address ) throws IOException , InterruptedException ;

简单客户端

构建客户端：

    ClientBuilder < byte []> builder = new ClientBuilder < byte []>()
        . host ( "127.0.0.1" , 8080 );
    Client < byte []> client = builder . build ();

阅读：

    // blocking read
    byte [] data = client . read ();

写：

   client . write ( data );

写签名：

  /**
   * write object of type T on the wire
   * it used @{@link com.network.mocket.handler.MocketStreamHandler} to parse the object
   * @param data object to send on wire to the server.
   * @throws IOException if error occurs while writing to the socket
   * @throws InterruptedException if write is interrupted
   */
  void write ( T data ) throws IOException , InterruptedException ;

编写自定义映射器

实现java接口并将其添加到客户端和服务器构建器中

        builder . addHandler ( new MyCustomHandler ())

 public interface MocketStreamHandler < P > {
  /**
   * Used to encode object to byte stream
   * @param in inout object of tye {P}
   * @return byte array representing object
   * @throws ParseException throws if fails to encode or decode
   */
  byte [] encode ( P in ) throws ParseException ;

  /**
   * Used to decode bytestream to object
   * @param out inout object of tye {P}
   * @return byte array representing object
   * @throws ParseException throws if fails to encode or decode
   */
  P decode ( byte [] out ) throws ParseException ;
}

例子

示例服务器客户端可以在此处找到示例。

安卓应用程序演示

使用案例

1. 数据中心内的服务-服务通信。
2. 在 Android 应用程序中使用，可在片状网络中获得更好的性能。
3. 在基于传感器的 Android Things 设备中使用，将定期数据推送到服务器。

*某些网关可能会阻止 UDP 流量。

下一个里程碑

1. 添加 ssl 支持。
2. 支持 TCP。
3. 多部分 TCP 支持。

贡献

我非常乐意以反馈、错误报告甚至更好的形式接受外部对项目的贡献 - 拉取请求:)

如果您想提交拉取请求，请努力遵循 CONTRIBUTING.md 中的指南。

执照

版权所有 (C) 2016 - 2017 尼尚特帕塔克

 Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.