网络编程---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 socketServerSocket 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）

@Overridepublic 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(){@Overridepublic 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(){@Overridepublic 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@Overridepublic void handleMessage(Message msg){if(msg.what == 1){txt.setText(msg.obj.toString());}}};