TCP(Socket基础编程)

1、TCP特点：

　　面向连接、可靠安全、传输量大、速度较慢

2、socket编程主要依靠两个类：socket 、serversocket

　　example1:客户端可以不停输入字符串，服务端返回字符串的大写

客户端代码：

public static void main(String[] args) throws Exception{
            //建立socket连接 连接一旦建立成功 就可以获得 输入流 和 写出流
            Socket s = new Socket(InetAddress.getLocalHost(),10001);
            //客户端从键盘输入字符
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            //从服务端获取的输入流，可以获取从服务端返回的信息
            BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
            //写出流  方式一 把信息发送到服务端
            PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
            //写出流 方式二
            //BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            
            String line = null;
            while((line=br.readLine())!=null){
                //写到服务端 方式一
                pw.println(line);
                //写到服务端 方式二
                /*
                    bw.write(line);
                    bw.newLine();
                    bw.flush();
                */
                //读取服务端返回信息(这是一个阻塞方法)
                String result = in.readLine();
                
                System.out.println(result);
            }
            s.close();
            br.close();
   }

服务端代码：

　　

public static void main(String[] args) throws Exception {
        ServerSocket ss = new ServerSocket(10001);
        while(true){
            //此方法是阻塞式方法
            Socket s = ss.accept();
            //服务端这儿需要使用线程 每次接受一个客户端就为其开启一个线程，防止多个客户端访问出现阻塞情况
            new Thread(new ServerThread(s)).start();
        }
  }

class ServerThread implements Runnable{
    
    private Socket socket;
    
    public ServerThread(Socket socket) {
        this.socket = socket;
    }
    
    @Override
    public void run() {
        try {
            System.out.println(socket.getInetAddress().getHostAddress()+"is connecting");
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            PrintWriter pw = new PrintWriter(socket.getOutputStream(),true);
            String line =null;
            while((line = br.readLine())!=null){
                //如果接收到结束标志 则结束
                if("over".equals(line)){
                    break;
                }
                System.out.println(line);
                pw.println(line.toUpperCase());
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
}

Example2：上传文件——客户端将文件内容写到服务端，服务端 将内容保存到其他位置，实现从服务端上传文件的功能

　　客户端代码：

public static void main(String[] args) throws Exception {
            Socket s = new Socket(InetAddress.getLocalHost(),10001);
            BufferedReader br = new BufferedReader(new FileReader(new File("D:/baichuanyu/HelloWorld/src/com/action/Hello.java")));
            BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
            PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
            String line = null;
            while((line=br.readLine())!=null){
                pw.println(line);
            }
            //文件内容写到服务器完成后，服务端没有接受到结束标志，会继续readline()下去
            //通过shutdownOutput()方法 可以向服务器写-1结束标志 从而结束服务端的readline()方法
            s.shutdownOutput();
            String result = in.readLine();
            System.out.println(result);
            s.close();
            br.close();
        }

　　服务端代码:

　　

class UploadThread implements Runnable{

    private Socket socket;
    
    public UploadThread(Socket socket) {
        this.socket = socket;
    }
    
    @Override
    public void run() {
        try {
            System.out.println(socket.getInetAddress().getHostAddress()+" is connecting....");
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            PrintWriter pw = new PrintWriter(new FileWriter(new File("E:\Hello.txt")),true);
            PrintWriter os = new PrintWriter(socket.getOutputStream(),true);
            String line =null;
            while((line = br.readLine())!=null){
                pw.println(line);
            }
            os.println("over");
            pw.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
}

public static void main(String[] args) throws Exception {
        ServerSocket ss = new ServerSocket(10001);
        while(true){
            //此方法是阻塞式方法
            Socket s = ss.accept();
            //服务端这儿需要使用线程 每次接受一个客户端就为其开启一个线程，防止多个客户端访问出现阻塞情况
            new Thread(new UploadThread(s)).start();
        }
     }