UDPSender

UDPSender

基於NIO的UDP發送-接收器

輸入：

• 指令byte數組
• 【目標埠號】
• 【預設廣播發送，可指定ip發送】
• 【預設只發一次，可指定發送次數及延遲發送】

【】表示選用功能，可不使用

輸出：

• UDPReuslt結果物件（包含對方IP位址、結果陣列[byte類型的陣列]）

導入

在你專案app/build.gradle中加入如下的程式碼

    dependencies {
       ...
       compile 'com.jwkj:udpsender:v2.0.2'
    }

使用方法

快速上手

 UDPSender . getInstance ()
                . setInstructions ( byteAraary )
                . setTargetPort ( port )
                . start ( new UDPResultCallback () {
                    @ Override
                    public void onNext ( UDPResult result ) {
                        //do something
                    }
                });

完整demo

 UDPSender . getInstance ()
                . setInstructions ( byteAraary ) //设置发送的指令[可为空]
                . setReceiveTimeOut ( 70 * 1000 ) //设置接收超时时间[可不写，默认为60s]--超时70s就停止任务
                . setTargetPort ( port ) //设置发送的端口[必写]
                . setLocalReceivePort ( port ) //设置本机接收的端口[可不写，默认为目标端口]
                . setTargetIp ( "192.168.1.150" ) //设置目标ip地址，[可不写，默认广播]
                . schedule ( 2 , 3000 ) //执行2次，间隔三秒执行（上一次结束到下一次开始的时间）
                . start ( new UDPResultCallback () {

                    @ Override
                    public void onStart () {
                        //请求开始的时候回调
                    }

                    @ Override
                    public void onNext ( UDPResult result ) {
                        //每收到一个结果的时候就回调
                    }

                    @ Override
                    public void onCompleted () {
                        //请求结束的时候回调
                    }

                    @ Override
                    public void onError ( Throwable throwable ) {
                        //当发生错误的时候回调
                    }
                });

只接收數據

 UDPSender . getInstance ()
                . setLocalReceivePort ( 9988 ) //接收端口
                . start ( new UDPResultCallback () {
                    @ Override
                    public void onStart () {
                        ELog . hdl ( "开始了" );
                    }

                    @ Override
                    public void onNext ( UDPResult result ) {
                        ELog . hdl ( "收到结果" + result );
                    }

                    @ Override
                    public void onError ( Throwable throwable ) {
                        ELog . hdl ( "出错" + throwable );
                    }

                    @ Override
                    public void onCompleted () {
                        ELog . hdl ( "完成" );
                    }
                });

關閉任務

 UDPSender . getInstance (). stop ();

UDPReslt

 public class UDPResult {
    /**
     * 对方ip地址
     */
    private String ip ;
    /**
     * 对方返回的结果
     */
    private byte [] resultData ;
}

歷史更新記錄

v2.X版

v2.0.2 ( 2017.10.27 )

• 【修復】資料清理不及時，導致產生髒數據

v2.0.1

• 【修復】只能接收對方連接埠為自身接收連接埠的bug
• 【優化】底層庫程式碼優化，已經相對成熟，可用於生產環境

小提醒： 不建議使用v1.X版，建議使用最新版，使用方法不變

v1.X版

v1.4.0

• 【新增】指定ip時預設只發送一次包(如需多次發送，可透過schedule方法指定)

• 【bug】只能發送方指定端口，bug，不要使用此版本

v1.3.9

• 【修復】呼叫定時任務時突然停止導致下一次重新開始任務時立刻停止當前的任務

• 【bug】只能發送方指定端口，bug，不要使用此版本

v1.3.8

• 【修復】修復特殊情況下的崩潰

• 【bug】只能發送方指定端口，bug，不要使用此版本

v1.3.7

• 【修復】任務結束時自動關閉相關接口

• 【bug】只能發送方指定端口，bug，不要使用此版本

v1.3.6

• 【修復】多次呼叫onCompleted方法

• 【bug】只能發送方指定端口，bug，不要使用此版本

v1.3.5

• 【修復】關閉任務（UDPSender.getInstance().stop()）不走onCompleted方法

• 【新增】設定目標ip方法(預設廣播形式發送)

• 【bug】只能發送方指定端口，bug，不要使用此版本

更多歷史版本暫未記錄