android規(guī)定即使socket發(fā)送這種操作也不能放在主線程里

quasiceo 2016-03-10

展開全文

android規(guī)定即使socket發(fā)送這種操作也不能放在主線程里。NetworkOnMainThreadException

UDP Socket基本思路小程序(2) 多線程簡單聊天程序

發(fā)表于2年前(2014-05-21 21:48) 閱讀（768） | 評論（0） 6人收藏此文章, 我要收藏

贊0

摘要參考：傳智播客畢老師Java基礎(chǔ)視頻

發(fā)送端

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
 
 
/**
 * 發(fā)送端
 * @author Administrator
 *
 */
public class Send implements Runnable{
     
    private DatagramSocket ds;
     
    public Send(DatagramSocket ds){
        this.ds = ds;
    }
     
    @Override
    public void run() {
        try{
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            String line = null;
            while((line = br.readLine()) != null){
                byte[] b = line.getBytes();
                DatagramPacket dp = new DatagramPacket(b, b.length, InetAddress.getByName("127.0.0.1"), 8888);
                //發(fā)送廣播，群聊
//              DatagramPacket dp = new DatagramPacket(b, b.length, InetAddress.getByName("192.168.123.255"), 8888);
                ds.send(dp);
                if("over".equalsIgnoreCase(line))
                    break;
            }
            ds.close();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

接收端

import java.net.DatagramPacket;
import java.net.DatagramSocket;
 
/**
 * 接收端
 * @author Administrator
 *
 */
public class Receive implements Runnable {
 
    private DatagramSocket ds;
 
    public Receive(DatagramSocket ds) {
        this.ds = ds;
    }
 
    @Override
    public void run() {
        try {
            while (true) {
                byte[] b = new byte[1024];
                DatagramPacket dp = new DatagramPacket(b, b.length);
                ds.receive(dp);
                String ip = dp.getAddress().getHostAddress();
                int port = dp.getPort();
                String text = new String(dp.getData(), 0, dp.getLength());
                System.out.println(ip+":" + port + "==" + text);
                if("over".equalsIgnoreCase(text)){
                    System.out.println("-----退出聊天-----");
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
}

測試

import java.io.IOException;
import java.net.DatagramSocket;
/**
 * 測試
 * @author Administrator
 *
 */
public class ChatTest {
     
    public static void main(String[] args) throws IOException {
 
        DatagramSocket dsend = new DatagramSocket();
        DatagramSocket dsRece= new DatagramSocket(8888);
        Send s = new Send(dsend);
        Receive r = new Receive(dsRece);
        new Thread(s).start();
        new Thread(r).start();
    }
}