最近要求要用rn做一個(gè)udp通信的軟件视卢，首先先了解下這些udp這些概念。
然后在android里面開始寫組件

簡單介紹

這里需要用到DatagramSocket方法

try {
    /******* 接收數(shù)據(jù)流程**/
    // 創(chuàng)建一個(gè)數(shù)據(jù)報(bào)套接字惠毁，并將其綁定到指定到當(dāng)前要發(fā)送的端口，如8084
    datagramSocket = new DatagramSocket(8084);
    // 組裝數(shù)據(jù)報(bào),綁定要發(fā)送的ip地址崎页，本地測試如127.0.0.1
    inetAddress =  new InetSocketAddress("127.0.0.1", 8085);
} catch (SocketException e) {
    e.printStackTrace();
}

創(chuàng)建好了連接就發(fā)送信息

public void sendMsg(String data){
        // 要發(fā)送的數(shù)據(jù)data
        mes = data;
        byte[] buf = mes.getBytes();
        DatagramPacket sendPacket = new DatagramPacket(buf, buf.length, inetAddress);
        try{
            // 組裝成功后發(fā)送
            datagramSocket.send(sendPacket);
        }catch (IOException e){
            e.printStackTrace();
        }
    }

接收信息鞠绰，

public void receive(){
    try {
        if (receiveSocket == null) {
            // 創(chuàng)建DatagramSocket，綁定8085端口,
            receiveSocket = new DatagramSocket(8085);
        }
        // 預(yù)留1024字節(jié)緩沖區(qū)
        byte[] bytes = new byte[1024];
        datagramPacket= new DatagramPacket(bytes, 0, bytes.length);
        // 啟用新線程監(jiān)聽receive方法飒焦，因?yàn)閞eceiveSocket.receive() 方法會(huì)阻塞線程蜈膨，
        // 所有必須要開新的線程
        newThreads = new Thread(new NewThread());
        newThreads.start();
    } catch (SocketException e) {
        e.printStackTrace();
    }
}
// 創(chuàng)建線程
class NewThread extends Thread{
        @Override
        public void run() {
            // 因?yàn)?receiveSocket.receive是阻塞方法，只有接收到數(shù)據(jù)后牺荠，才會(huì)執(zhí)行下一個(gè)for循環(huán)內(nèi)容翁巍，
            // 這里可以隨便給個(gè)最大值，比如100000
            for(int i = 0 ; i < 100000 ; i++) {
                try {
                    receiveSocket.receive(datagramPacket);
                    // 獲取接收到的數(shù)據(jù)（為string類型）休雌，然后去掉前后的空格
                    String msg = new String(datagramPacket.getData()).trim();
                    // 把數(shù)據(jù)組合成 jsonobject
                    JSONObject msgObj = new JSONObject();
                    try{
                        msgObj.put("msgs", msg);
                    }catch (JSONException e){
                        e.printStackTrace();
                    }
                    // 然后放到j(luò)sonarray里面,我這里最好是以json的格式傳到rn的
                    message.put(msgObj);
                } catch (SocketException e) {
                    e.printStackTrace();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

有的手機(jī)接收不到通知

如果你的手機(jī)收不到通知曙咽，其他的可以，那么你的手機(jī)應(yīng)該是把接受廣播的功能關(guān)了挑辆，因?yàn)槭謾C(jī)為了省電吧例朱，
執(zhí)行下面的打開接收通知就可以了，

WifiManager wifiManager = (WifiManager)getApplicationContext().getSystemService(WIFI_SERVICE);
WifiInfo wifiInfo = wifiManager.getConnectionInfo();
multicastLock=wifiManager.createMulticastLock("multicast.test");
multicastLock.acquire();

上面方法在MainActivity里面的onCreate里面執(zhí)行

全部代碼：

發(fā)送數(shù)據(jù)

package com.socket;

import android.util.Log;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.SocketException;

public class DatagramServer {
    private int MAX_LENGTH = 1024; // 最大接收字節(jié)長度
    private int port = 8084;  
    private byte[] receMsgs = new byte[MAX_LENGTH];
    private DatagramSocket datagramSocket = null;
    private DatagramPacket datagramPacket = null;
    public String message = "";
    private String tag = "sockets";
    private String mes= "i had send";
    private InetSocketAddress inetAddress;
    public void openServer(){
        try {
            datagramSocket = new DatagramSocket(port);
            inetAddress =  new InetSocketAddress("127.0.0.1", 8085);
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }

    public void sendMsg(String data){
        mes = data;
        byte[] buf = mes.getBytes();
        inetAddress =  new InetSocketAddress("127.0.0.1", 8085);
        DatagramPacket sendPacket = new DatagramPacket(buf, buf.length, inetAddress);
        try{
            datagramSocket.send(sendPacket);
        }catch (IOException e){
            e.printStackTrace();
        }
    }
}

接收數(shù)據(jù)

package com.socket;
import android.util.Log;
import com.facebook.react.bridge.Arguments;
import com.facebook.react.bridge.WritableMap;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

public class DatagramClint {

    private DatagramSocket receiveSocket = null;
    private int receivePort = 8085;
    private DatagramPacket datagramPacket;
    public JSONArray message = new JSONArray();
    private String tag = "sockets";
    private Thread newThreads;
    public void receive(){
        try {
            if (receiveSocket == null) {
                receiveSocket = new DatagramSocket(receivePort);
            }
            byte[] bytes = new byte[1024];
            datagramPacket= new DatagramPacket(bytes, 0, bytes.length);
             newThreads = new Thread(new NewThread());
             newThreads.start();
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }

    class NewThread extends Thread{
        @Override
        public void run() {
            for(int i = 0 ; i < Integer.MAX_VALUE ; i++) {
                try {
                    receiveSocket.receive(datagramPacket);
                    Long times = new Date().getTime();
                    String msg = new String(datagramPacket.getData()).trim();
                    JSONObject tmpObj = new JSONObject();
                    try{
                        tmpObj.put("msgs", msg);
                        tmpObj.put("time", times);
                    }catch (JSONException e){
                        e.printStackTrace();
                    }
                    message.put(tmpObj);
                } catch (SocketException e) {
                    e.printStackTrace();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }

}

封裝成rn方法

package com.socket;

import android.util.JsonToken;
import android.util.Log;

import com.facebook.react.bridge.Callback;
import com.facebook.react.bridge.Promise;
import com.facebook.react.bridge.ReactApplicationContext;
import com.facebook.react.bridge.ReactContextBaseJavaModule;
import com.facebook.react.bridge.ReactMethod;

import org.json.JSONArray;

public class DatagramUtils extends ReactContextBaseJavaModule{
    ReactApplicationContext context;

    private DatagramClint datagramClint;
    private DatagramServer datagramServer;
    public DatagramUtils(ReactApplicationContext reactContext) {
        super(reactContext);
        context = reactContext;
    }

    @Override
    public String getName(){
        return "datagram";
    }

    @ReactMethod
    public void serverOpent(){
        datagramServer = new DatagramServer();
        datagramServer.openServer();
    }

    @ReactMethod
    public void sendMsg(String mes){
        datagramServer.sendMsg(mes);
    }

    @ReactMethod
    public void clintOpent(){
        datagramClint = new DatagramClint();
        datagramClint.receive();
    }
    @ReactMethod
    public void receiveMsg(Callback calback){
        String data = "";
        // 以string的方式傳遞數(shù)據(jù)
        calback.invoke(datagramClint.message.toString());
    }
}

package rn的方法

package com.socket;
import com.facebook.react.ReactPackage;
import com.facebook.react.bridge.NativeModule;
import com.facebook.react.bridge.ReactApplicationContext;
import com.facebook.react.uimanager.ViewManager;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

public class DatagramPackage implements ReactPackage{
    @Override
    public List<ViewManager> createViewManagers(ReactApplicationContext reactContext) {
        return Collections.emptyList();
    }
    @Override
    public List<NativeModule> createNativeModules(ReactApplicationContext reactContext) {
        List<NativeModule> modules = new ArrayList<>();
        modules.add(new DatagramUtils(reactContext));
        return modules;
    }
}

添加到主函數(shù)里面

@Override
protected List<ReactPackage> getPackages() {
    return Arrays.<ReactPackage>asList(
        new MainReactPackage(),
        new DatagramPackage()
    );
}

前端用法：

import {
  NativeModules,
} from 'react-native';

// 首先打開通信
NativeModules.datagram.clintOpent();
NativeModules.datagram.serverOpent();
//然后根據(jù)方法傳遞過去信息
press() {
    NativeModules.datagram.sendMsg(this.state.text);

    // 這里返回監(jiān)聽的數(shù)據(jù)
    NativeModules.datagram.receiveMsg(rs=>{
        this.setState({
            // 返回回來的string數(shù)據(jù)轉(zhuǎn)換成數(shù)組鱼蝉，
          data: JSON.parse(rs)
        })
      });
}

緩存問題

在實(shí)現(xiàn)發(fā)送信息的時(shí)候會(huì)出現(xiàn)洒嗤，當(dāng)下次接收到的數(shù)據(jù)字（a長度）節(jié)小于前一次的（b長度）的時(shí)候，接收到的信息只會(huì)更新前a個(gè)數(shù)據(jù)魁亦，b-a后面的數(shù)據(jù)依然存在渔隶，比如第一次發(fā)送abc，第二次發(fā)送12洁奈，這時(shí)接收到的數(shù)據(jù)就是12c而不是我們想要的12间唉。 這時(shí)因?yàn)閡dp存在緩存問題，所以要清空緩存利术。

清空緩存方法

方法：在取出數(shù)據(jù)后呈野，執(zhí)行如下方法

// 上面的這個(gè)創(chuàng)建緩存區(qū)的方法可以提取出來
byte[] bytes = new byte[1024];
// 然后在
Arrays.fill(bytes,(byte)0);

然后就清空了緩存區(qū)域

廣播問題

需要先了解下ip和子網(wǎng)掩碼二進(jìn)制轉(zhuǎn)化：
IP地址是一個(gè)32位的二進(jìn)制數(shù)，通常被分割為4個(gè)“8位二進(jìn)制數(shù)”（也就是4個(gè)字節(jié)）印叁。IP地址通常用“點(diǎn)分十進(jìn)制”表示成（a.b.c.d）的形式被冒，其中，a,b,c,d都是0~255之間的十進(jìn)制整數(shù)轮蜕。例：點(diǎn)分十進(jìn)IP地址（100.4.5.6）昨悼，實(shí)際上是32位二進(jìn)制數(shù)（01100100.00000100.00000101.00000110）

假如計(jì)算機(jī)的IP位址是192.15.156.205，子網(wǎng)掩碼是255.255.255.224跃洛，
先把子網(wǎng)掩碼255.255.255.224做 NOT 運(yùn)算﹐可以得出﹕
00000000.00000000.00000000.00011111
然后再和IP做一次 OR 運(yùn)算﹐就可以得到 Broadcast Address:
11000000.00001111.10011100.11001101 OR 00000000.00000000.00000000.00011111
(192.15.156.205 OR 255.255.255.224)
得出﹕ 11000000.00001111.10011100.11011111
(192.15.156.223)
192.15.156.223就是那個(gè)子網(wǎng)的廣播地址了. 知道廣播地址后就可以以這個(gè)地址來發(fā)送消息了率触，局域網(wǎng)的都可以接收到了。

當(dāng)網(wǎng)絡(luò)間進(jìn)行通信時(shí)汇竭，如需確定是否在同一網(wǎng)絡(luò)葱蝗，則用某臺(tái)主機(jī)的網(wǎng)絡(luò)號(hào)與另一臺(tái)主機(jī)的子網(wǎng)掩碼進(jìn)行與運(yùn)算痊剖，觀察網(wǎng)絡(luò)號(hào)與與運(yùn)算的結(jié)果是否相同。
其中還有了解下子網(wǎng)掩碼垒玲，不然還是不知所以,子網(wǎng)掩碼

參考地址
參考地址

個(gè)人博客地址