如何使android的UDP连接(How to make a UDP connection in a

2019-07-31 15:57发布

我努力使我之间的连接galaxy tab和我的laptop 。 所以我想在我的笔记本电脑和客户活动我的选项卡上运行服务器的活动,但它不工作。 这里是服务器和客户端的代码。 哪里错了吗?

服务器:

public class MainActivity extends Activity {

@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    TextView txt = (TextView)findViewById(R.id.textView1);

    int port = 12345;
    byte [] message = new byte [1500];
    DatagramPacket p = new DatagramPacket (message,message.length);
    try {
        InetAddress serveraddr = InetAddress.getByName("192.168.1.116");
        DatagramSocket s = new DatagramSocket (port,serveraddr);
        while (true){
            s.receive(p);
            String text = new String (message,0,p.getLength());
            txt.setText(text);
        }
    } catch (SocketException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

客户:

public class MainActivity extends Activity {

@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    final EditText edt = (EditText)findViewById(R.id.editText1);
    Button btn = (Button)findViewById(R.id.button1);
    btn.setOnClickListener(new View.OnClickListener() {

        public void onClick(View arg0) {
            String msg = edt.getText().toString();
            int port = 12345;
            try {
                DatagramSocket s = new DatagramSocket();
                InetAddress local  = InetAddress.getByName("192.168.1.116");
                int msg_lenght = msg.length();
                byte []message = msg.getBytes();
                DatagramPacket p = new DatagramPacket(message,msg_lenght,local,port);
                s.send(p);
            } catch (SocketException e) {                   
                e.printStackTrace();
            } catch (UnknownHostException e) {                  
                e.printStackTrace();
            } catch (IOException e) {               
                e.printStackTrace();
            }               
        }
    });
}

下面是日志

09-17 23:49:55.190:d / dalvikvm(5892):晚启用CheckJNI 09-17 23:49:55.690:d /剪贴板(5892):隐藏在开始输入剪贴板对话框:由别人完成... ! 09-17 23:49:59.590:d / AndroidRuntime(5892):关闭VM 09-17 23:49:59.590:W / dalvikvm(5892):线程ID = 1:螺纹与未捕获的异常(组= 0x40c4f1f8)09离开-17 23:49:59.590:E / AndroidRuntime(5892):致命异常:主09-17 23:49:59.590:E / AndroidRuntime(5892):android.os.NetworkOnMainThreadException 09-17 23:49:59.590:电子/ AndroidRuntime(5892):在android.os.StrictMode $ AndroidBlockGuardPolicy.onNetwork(StrictMode.java:1099)09-17 23:49:59.590:E / AndroidRuntime(5892):在libcore.io.BlockGuardOs.sendto(BlockGuardOs。的java:175)09-17 23:49:59.590:E / AndroidRuntime(5892):在libcore.io.IoBridge.sendto(IoBridge.java:463)09-17 23:49:59.590:E / AndroidRuntime(5892) :在java.net.PlainDatagramSocketImpl.send(PlainDatagramSocketImpl.java:182)09-17 23:49:59.590:E / AndroidRuntime(5892):在java.net.DatagramSocket.send(DatagramSocket.java:307)09-17 23:49:59.590:E / AndroidRuntime(5892):在com.example.udpclient.MainActivity $ 1.onClick(MainActivity.java:36)09-17 23:49:59.590:E / Androi dRuntime(5892):在android.view.View.performClick(View.java:3620)09-17 23:49:59.590:E / AndroidRuntime(5892):在android.view.View $ PerformClick.run(View.java :14322)09-17 23:49:59.590:E / AndroidRuntime(5892):在android.os.Handler.handleCallback(Handler.java:605)09-17 23:49:59.590:E / AndroidRuntime(5892):在android.os.Handler.dispatchMessage(Handler.java:92)09-17 23:49:59.590:E / AndroidRuntime(5892):在android.os.Looper.loop(Looper.java:137)09-17 23 :49:59.590:E / AndroidRuntime(5892):在android.app.ActivityThread.main(ActivityThread.java:4507)09-17 23:49:59.590:E / AndroidRuntime(5892):在java.lang.relfect包。 Method.invokeNative(本机方法)09-17 23:49:59.590:E / AndroidRuntime(5892):在java.lang.reflect.Method.invoke(Method.java:511)09-17 23:49:59.590:电子/ AndroidRuntime(5892):在com.android.internal.os.ZygoteInit $ MethodAndArgsCaller.run(ZygoteInit.java:978)09-17 23:49:59.590:E / AndroidRuntime(5892):在com.android.internal。 os.ZygoteInit.main(ZygoteInit.java:745)09-17 23时49分59秒 0.590:E / AndroidRuntime(5892):在dalvik.system.NativeStart.main(本机方法)09-17 23:50:34.320:I /过程(5892):发送信号。 PID:5892 SIG:9

Answer 1:

09-17 23:49:59.590: E/AndroidRuntime(5892): android.os.NetworkOnMainThreadException
09-17 23:49:59.590: E/AndroidRuntime(5892):     at android.os.StrictMode$AndroidBlockGuardPolicy.onNetwork(StrictMode.java:1099)
09-17 23:49:59.590: E/AndroidRuntime(5892):     at libcore.io.BlockGuardOs.sendto(BlockGuardOs.java:175)

你不应该在UI线程做网络或时间强化班作业

参见: 安卓:NoClassDefFoundError的一些应用程序的用户或Android开发者信息

结帐: activity.runOnUi



Answer 2:

你必须在服务器中的onCreate无限循环。 你不应该! 创建一个线程用于轮询插座。



Answer 3:

  • 你不能在UI线程发送UDP数据包,因此一个新的单独的线程必须创建。

只是一个快速的解决方案...

创建一个字符串udpOutputData:
String udpOutputData;

在代码中创建一个新的线程:

    //-----UDP send thread
Thread udpSendThread = new Thread(new Runnable() {

        @Override
        public void run() {


                while (true) {  

                    try {
                        Thread.sleep(100);
                    } 

                    catch (InterruptedException e1) {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                    }

                        if (sendUdp == true) {

                            try {

                                // get server name
                                InetAddress serverAddr = InetAddress.getByName(outputIP);
                                Log.d("UDP", "C: Connecting...");

                                // create new UDP socket
                                DatagramSocket socket = new DatagramSocket();

                                // prepare data to be sent
                                byte[] buf = udpOutputData.getBytes();

                                // create a UDP packet with data and its destination ip & port
                                DatagramPacket packet = new DatagramPacket(buf, buf.length, serverAddr, broadcastPort);
                                Log.d("UDP", "C: Sending: '" + new String(buf) + "'");

                                // send the UDP packet
                                socket.send(packet);

                                socket.close();

                                Log.d("UDP", "C: Sent.");
                                Log.d("UDP", "C: Done.");


                            } 

                            catch (Exception e) {
                                Log.e("UDP", "C: Error", e);

                            }

                                try {
                                    Thread.sleep(100);
                                }

                                catch (InterruptedException e) {
                                    // TODO Auto-generated catch block
                                    e.printStackTrace();
                                }


                                sendUdp = false;
                        }

                }
        }

});

创建调用您要发送一些的UDP数据每次的方法:

    public void sendUdp(String udpMsg) {

       udpOutputData = udpMsg;
       sendUdp = true;
    }

调用方法并传递一个字符串为您要发送一个UDP包的输出数据每次:

String s = "hello from app";
sendUdp(s);


Answer 4:

有2个问题与您的代码

  1. 与网络上的主线程(UI线程)工作

09-17 23:49:59.590:E / AndroidRuntime(5892):致命异常:主09-17 23:49:59.590:E / AndroidRuntime(5892):android.os.NetworkOnMainThreadException

  1. while(true)在主线程上:

     while(true) { s.receive(p); String text = new String (message,0,p.getLength()); txt.setText(text); } 


文章来源: How to make a UDP connection in android
标签: java android udp