UdpNetty

udpnetty

Nettyに基づいて、UDPトランシーバーツールがカプセル化されており、メッセージの再送信、再送信時間、および再送信間隔の設定をサポートします。

紹介された

JitPackリポジトリをプロジェクトに追加します（プロジェクトルートディレクトリの下のbuild.gradleファイル）

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

依存関係を追加します

 dependencies {
    implementation ' com.github.shenbengit:UdpNetty:Tag '
}

使用例

コードの例

基本的な使用

 UdpManager manager = UdpManager . getInstance ();
UdpConfig config = new UdpConfig . Builder ()
        . setLoggable ( true ) //是否显示日志
        . setResendLimit ( 3 ) //重发次数
        . setResendEnable ( true ) //是否启用重发
        . setResendInterval ( 3000L ) //重发间隔
        . build ();
//初始化配置
manager . init ( config );

//丢弃消息回调
manager . setDiscardMessageCallback ( new DiscardMessageCallback () {
     @ Override
     public void onDiscardMsg ( MessageBean msg ) {
                
     }
});

//接收消息回调，最好一开始设置，避免发送端异常接收不到
manager . setReceiveMessageCallback ( new ReceiveMessageCallback () {
    @ Override
    public void onReceiveMsg ( String msg , InetSocketAddress sender ) {
                
    }
    
    @ Override
    public void onException ( Exception e ) {
    
    }
});

//仅启用发送消息功能
manager . startClient ();

//仅开启接收消息功能
manager . startServer ( 8888 );

//接收、发送消息都开启
manager . start ( 7777 );

//关闭发送消息
manager . stopClient ();

//关闭接收功能
manager . stopServer ();

//关闭发送端和接收端
manager . stop ();

複数のポートを聴く必要がある場合は、次の使用例を参照してください

 UdpServer udpServer = new UdpServer ( 7777 , new ReceiveMessageCallback () {

    @ Override
    public void onReceiveMsg ( String msg , InetSocketAddress sender ) {
                
    }
    
    @ Override
    public void onException ( Exception e ) {
    
    }
});

//开启
udpServer . start ();

//关闭
udpServer . stop ();

ライセンス