网络编程---Java飞机大战联机

解析服务器端代码

代码是放在app/lib下的src下的main/java，而与之前放在app/src/main下路径不同

Main函数

Main函数里只放着创建MyServer类的一行

public static void main(String args[]){
        new MyServer();
    }

MyServer构造函数

1.获取本机IP地址

//获取本机IP地址
            InetAddress addr = InetAddress.getLocalHost();
            System.out.println("local host:" + addr);

2.创建serverSocket（创建服务器套接字并绑定到一个端口上）

//创建server socket
            ServerSocket serverSocket = new ServerSocket(9999);
            System.out.println("listen port 9999");

3.accept方法监听等待

//等待客户端连接
            while(true){
                System.out.println("waiting client connect");
                //从连接请求队列中取出一个客户的连接请求，然后创建与客户连接的Socket对象，并将它返回
                // 如果队列中没有连接请求，accept()方法就会一直等待，直到接收到了连接请求才返回
                Socket socket = serverSocket.accept();
                //连接成功，返回socket对象
                System.out.println("accept client connect" + socket);
                new Thread(new Service(socket)).start();
            }

4.监听成功，创建线程进行通信（上一步while循环内最后一行）

创建线程进行通信

• 线程构造函数内，new数据传输通道

 class Service implements Runnable{
        private Socket socket;
        private BufferedReader in = null;

        public Service(Socket socket){
            this.socket = socket;
            try{
                //InputStreamReader把字节流转化成字符流
                //BufferedReader用于读取字符流。它继承自Reader类，提供了按行读取文件的功能
                in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            }catch (IOException ex){
                ex.printStackTrace();
            }
        }

• 重写的run函数内，用一个while来不断读入客户端传来的流（用BufferedReader）

@Override
        public void run() {
            System.out.println("wait client message " );
            try {
                while ((content = in.readLine()) != null) {
                    //从socket连接读取到bye标识客户端发出断开连接请求
                    if(content.equals("bye")){
                        System.out.println("disconnect from client,close socket");
                        //关闭socket输入输出流
                        socket.shutdownInput();
                        socket.shutdownOutput();
                        socket.close();   //关闭socket连接
                        break;
                    }else {
                        //从socket连接读取到的不是断开连接请求，则像客户端发信息
                        this.sendMessge(socket);
                    }
                }
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }

• 如何sendMessage：用PrintWriter

public void sendMessge(Socket socket) {
            PrintWriter pout = null;
            try{
                String message = "hello,client!";
                System.out.println("messge to client:" + message);

                //OutputStreamWriter：将字符流转换为字节流
                //BufferedWriter：是缓冲字符输出流
                //PrintWriter：字符类型的打印输出流
                pout = new PrintWriter(new BufferedWriter(
                        new OutputStreamWriter(socket.getOutputStream(),"utf-8")),true);
                //利用输出流输出数据
                pout.println(message);

            }catch (IOException ex){
                ex.printStackTrace();
            }
        }

解析客户端代码

1.与服务器的连接

NetConn netConn = new NetConn(handler);

2.与服务器的信息交流

其中的writer在与服务器进行连接会把它进行赋值，它是获得了socket输出流的PrintWriter，把信息给到服务器。（注：接收服务器的信息是在netConn线程的run方法里用了一个while）

new Thread(){
                @Override
                public void run(){
                    Log.i(TAG, "send message to server");
                        writer.println("hello,server");
                }
            }.start();

NetConn是一个线程

在重写的 run 方法里

1.创建socket并连接对象

//创建socket对象
                socket = new Socket();
                //connect,要保证服务器已启动
                socket.connect(new InetSocketAddress
                        ("10.0.2.2",9999),5000);

2.获取socket的输入输出流

//获取socket输入输出流
                in = new BufferedReader(new InputStreamReader(socket.getInputStream(),"utf-8"));
                writer = new PrintWriter(new BufferedWriter(
                        new OutputStreamWriter(
                                socket.getOutputStream(),"utf-8")),true);
                Log.i(TAG,"connect to server");

3.再建一个线程，接收服务器的数据

//接收服务器返回的数据
                Thread receiveServerMsg =  new Thread(){
                    @Override
                    public void run(){
                        String fromserver = null;
                        try{
                            while((fromserver = in.readLine())!=null)
                            {
                                //发送消息给UI线程
                                Message msg = new Message();
                                msg.what = 1;
                                msg.obj = fromserver;
                                toClientHandler.sendMessage(msg);
                            }
                        }catch (IOException ex){
                            ex.printStackTrace();
                        }
                    }
                };

感觉hander像个快递员？？？把在服务器接收数据线程里，接收到的东西，打包成message，通过sendMessage函数，发给UI线程（就是那些Activity），进行相应操作。

以下是MainActivity内的Handler

handler = new Handler(Looper.getMainLooper()){
            //当数据处理子线程更新数据后发送消息给UI线程，UI线程更新UI
            @Override
            public void handleMessage(Message msg){
                if(msg.what == 1){
                    txt.setText(msg.obj.toString());
                }
            }
        };