网络编程

---恢复内容开始---

　　网络：将地理上分开的主机连接在一起就形成了网络。但是在java中的网络编程不是已物理主机区分的。而是以不同的JVM进程来区分的

　　虽然JVM帮助用户隐藏了一些网络原始信息，但是有一些的操作还是留给了用户来实现了，例如：网络的连接分为两种：TCP（可靠的数据连接），UDP（不可靠的数据连接）。

　　从网络编程的本质来讲也分为两种类型：

　　　　C/S结构（客户/服务器）：需要开发两套程序，一套是服务器端程序，另外一套是客户端程序。如果要更新，两套都要修改，开发复复杂度高，但是安全，稳定，因为可以自定义协议，自定义传输端口；

　　　　B/S结构(浏览器/服务器)：通过浏览器来访问服务器端程序，开发者只需要开发服务器端代码即可，只需要维护一套程序，由于使用的是公共的协议，公开的端口，所以安全性较差。

开发一个基本的C/S程序

　　下面编写一个服务器端代码和一个客户端代码，主要是通过客户端去连接服务器端取得一些信息，服务器端只输出一次“HelloWorld”就表示操作结束。

　　如果要开发网络程序，使用java.net程序包即可，这个包里面有两个类：ServerSocket（服务器） Socket（客户端）。

范例：编写一个服务器端程序

package cn.Tony.netdemo.hello.server;

import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class HelloServer {
    public static void main(String[] args) throws Exception {
        //1.创建一个服务器端的对象，所有的服务器一定要有一个监听端口
        ServerSocket server=new ServerSocket(9999);//此时的服务在9999端口上等待连接
        System.out.println("等客户来连接......");
        //2.需要等待客户连接，也就是说此时的程序在此处会进入到一个阻塞状态
        Socket client=server.accept();//表示等待连接，连接的是客户
        PrintWriter out=new PrintWriter(client.getOutputStream());
        out.println("Hello World！");//要有换行
        out.close();
        server.close();
    }
}

范例：编写客户端

package cn.Tony.netdemo.hello.client;

import java.net.Socket;
import java.util.Scanner;

public class HelloClient {

    public static void main(String[] args) throws Exception{
        //1.表示连接到指定的服务器端的主机名称和端口。localhost=127.0.0.1
        Socket client=new Socket("localhost",9999);
        //2.等待进行服务器端的输出，服务器端输出对客户端是输入4
        Scanner scan=new Scanner(client.getInputStream());
        scan.useDelimiter("
");
        if(scan.hasNext()) {
            System.out.println(scan.next());
        }
        client.close();
    }
}

　　这个时候的服务器只能处理一次请求操作

ECHO程序

　　网络编程有一个最为经典的程序案例：ECHO程序的核心本质在于：将用户接受到的数据前面追加一个“ECHO”的头信息进行返回。这个程序要求用户可以一直进行信息的输入，一直到用户byebye才表示操作结束。

范例：编写服务器端

package cn.Tony.netdemo.echo;

import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class EchoServer {
    public static void main(String[] args) throws Exception{
        ServerSocket server=new ServerSocket(8888);
        Socket client=server.accept();
        Scanner scan=new Scanner(client.getInputStream());
        scan.useDelimiter("
");
        PrintStream out=new PrintStream(client.getOutputStream());
        boolean flag=true;//作为循环的处理标记
        while(flag) {//相当于一直循环
            if(scan.hasNext()) {//现在客户端有数据发送
                String str=scan.next().trim();//防止有多与空格出现
                if("byebye".equalsIgnoreCase(str)) {//操作结束
                    flag=false;//此时循环退出
                    break;
                }
                out.println("ECHO:"+str);//做出回应
            }
        }
        out.close();
        scan.close();
        server.close();
    }
}

　　随后编写客户端，客户端肯定需要由用户输入数据，自己来输入数据就需要使用System.in并且结合Scanner进行操作，

范例：

package cn.Tony.netdemo.echo;

import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;


public class EchoClient {
    public static void main(String[] args)throws Exception {
        Socket client=new Socket("localhost",8888);
        Scanner keyScan=new Scanner(System.in); //用户输入
        keyScan.useDelimiter("
");
        Scanner netScan=new Scanner(client.getInputStream());
        netScan.useDelimiter("
");
        PrintStream netOut=new PrintStream(client.getOutputStream());
        boolean flag=true;
        while(flag) {
            System.out.println("请输入要发送的信息：");
            if(keyScan.hasNext()) {
                String str=keyScan.next();
                netOut.println(str);//发送给服务器端
                if(netScan.hasNext()) {//服务器端有回应
                    System.out.println(netScan.next());
                }
                if("byebye".equals(str)) {
                    flag=false;
                    break;
                }
            }
        }
        keyScan.close();
        netScan.close();
        client.close();
    }
}

　　以上完成一个基础的完成，但是程序有一个问题，本程序为单线程，因为所有的操作都在主方法里面进行的。

package cn.Tony.netdemo.echo;

import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;


public class EchoClient {
    public static void main(String[] args)throws Exception {
        Socket client=new Socket("localhost",8888);
        Scanner keyScan=new Scanner(System.in); //用户输入
        keyScan.useDelimiter("
");
        Scanner netScan=new Scanner(client.getInputStream());
        netScan.useDelimiter("
");
        PrintStream netOut=new PrintStream(client.getOutputStream());
        boolean flag=true;
        while(flag) {
            System.out.println("请输入要发送的信息：");
            String str=null;
            if(keyScan.hasNext()) {
                 str=keyScan.next().trim();
                netOut.println(str);//发送给服务器端
                if(netScan.hasNext()) {//服务器端有回应
                    System.out.println(netScan.next());
                }
            }
            if("byebye".equalsIgnoreCase(str)) {
                flag=false;
                break;
            }
        }
        keyScan.close();
        netScan.close();
        client.close();
    }
}

　　要想解决当前问题就必须进行多线程处理。把每一个连接都封装在一个线程里面，这样处理起来就可以不受到单线程局限了

package cn.Tony.netdemo.echo;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class EchoServer {
    private static class MyThread implements Runnable{
        private Socket client;
        public MyThread(Socket client) {
            this.client=client;
        }
        @Override
        public void run() {
            try {
            Scanner scan=new Scanner(client.getInputStream());
            scan.useDelimiter("
");
            PrintStream out=new PrintStream(client.getOutputStream());
            boolean flag=true;//作为循环的处理标记
            while(flag) {//相当于一直循环
                if(scan.hasNext()) {//现在客户端有数据发送
                    String str=scan.next().trim();//防止有多与空格出现
                    if("byebye".equalsIgnoreCase(str)) {//操作结束
                        out.println("BYEBYE!!!");//做出回应
                        flag=false;//此时循环退出
                        break;
                    }
                    out.println("ECHO:"+str);//做出回应
                }
            }
            out.close();
            scan.close();
            }catch(Exception e) {
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) throws Exception{
        ServerSocket server=new ServerSocket(8888);
        boolean flag=true;
        while(flag) {
            Socket client=server.accept();
            new Thread(new MyThread(client)).start();
        }
        server.close();
    }
}

　　实际上所有的服务器上，每一个用户的连接对服务器都是一个线程，线程通过指的就是对共享资源的控制

　　网络编程的时代结束了，现在也不再去搞任何编程，

　

---恢复内容结束---