Java学习之网络编程（TCP协议实例）

传输控制协议（TCP，Transmission Control Protocol）：字面意思传输那就会有源和目的地，TCP中的源和目的地就是客户端和服务端

两个核心类型

1、Socket：客户端套接字

2、ServerSocket:服务端套接字

一、创建客户端思路

　　1、创建tcp客户端socket服务，通过Socket对象
　　　　建议一创建就就明确目的地，要连接主机
　　2、如果连接建立成功，说明数据传输通道已建立。
　　　　可以通过getOutputStream()和getInputStream()来获取两个字节流
　　3、使用输出流，将数据写出

　　4、关闭资源

public class ClientDeo {
    public static void main(String[] args) throws UnknownHostException, IOException {
    //创建客户端socket服务
    Socket socket=new Socket("",10002);
    //获取socket流中的输出流
    
    OutputStream out=socket.getOutputStream();
    out.write("tcp演示".getBytes());
    
    socket.close();
    }
}

二、创建服务端思路

　　1、创建服务的socket服务，通过ServerSocket对象
　　2、服务端必须对我提供一个端口，否则客户端无法连接
　　3、获取连接过来的客户端对象
　　4、通过客户端对象获取socket流读取客户端发送的数据
　　5、关闭资源（关闭客户端和服务端）

public class ServerDemo {
    public static void main(String[] args) throws IOException {
    //创建服务端对象
    ServerSocket ss=new ServerSocket(10002);
    //获取连接过来的客户端对象
    Socket s=ss.accept();
    //通过客户端对象获取输入流，要读取客户端发送的数据
    InputStream in=s.getInputStream();
    BufferedReader br=new BufferedReader(new InputStreamReader(in));
    
    String line=null;
    while((line=br.readLine())!=null) {
        System.out.println(s.getInetAddress().getHostAddress()+":"+line);
    }
    
    s.close();
    ss.close();
    }
}

结果：

 分析：

代码展示：

服务端代码

public class ServerDemo2 {
    public static void main(String[] args) throws IOException {
    //创建服务端对象
    ServerSocket ss=new ServerSocket(10003);
    //获取连接过来的客户端对象
    Socket s=ss.accept();
    
    //通过客户端对象获取输入流，要读取客户端发送的数据
    InputStream in=s.getInputStream();
    byte[] buf=new byte[1024];
    int len = in.read(buf);
    System.out.println(new String(buf,0,len));
    OutputStream out=s.getOutputStream();
    out.write("Response...".getBytes());
    s.close();
    ss.close();
    }

}

客户端代码：

public class ClientDemo2 {

    /**
     * @param args
     * @throws IOException 
     * @throws UnknownHostException 
     */
    public static void main(String[] args) throws UnknownHostException, IOException {
    //创建客户端socket服务
    Socket socket=new Socket("172.28.188.168",10003);
    //获取socket流中的输出流
    
    OutputStream out=socket.getOutputStream();
    out.write("tcp演示,request...".getBytes());
    out.flush();
    InputStream in=socket.getInputStream();
    byte[] buf=new byte[1024];
    int len = in.read(buf);

    String text=new String(buf,0,len);
    System.out.println(text);
    socket.close();
    }

}

同时上传图片（使用多线线程）

定义线程任务类（实现Runnable接口的类）

public class UploadTask implements Runnable {

    private Socket s;

    public UploadTask(Socket s) {
    this.s = s;
    }

    @Override
    public void run() {
    int count = 0;
    String ip = s.getInetAddress().getHostAddress();
    try {
        // 读取客户端发送来的数据
        InputStream in = s.getInputStream();

        // 将读取到数据存储到一个文件中
        File dir = new File("pic");
        if (!dir.exists()) {
        dir.mkdirs();
        }
        File file = new File(dir, ip + ".png");

        //判断文件是否存在
        if (file.exists()) {
        file = new File(dir, ip + "(" + (++count) + ").png");
        }

        FileOutputStream fos = new FileOutputStream(file);
        byte[] buf = new byte[1024];
        int len = 0;
        while ((len = in.read(buf)) != -1) {
        fos.write(buf, 0, len);
        }

        OutputStream out = s.getOutputStream();
        out.write("Upload Finish...".getBytes());
        fos.close();
        s.close();
    } catch (Exception e) {
        // TODO: handle exception
    }
    }
}

客户端

public class UploadPicClient {

    /**
     * @param args
     * @throws IOException 
     * @throws UnknownHostException 
     */
    public static void main(String[] args) throws UnknownHostException, IOException {
    // 1、创建客户端socket
    Socket socket = new Socket("172.28.188.168", 10005);
    // 2、读取客户端要上传的图片文件
    FileInputStream fis=new FileInputStream("0.png");
    // 3、获取socket输出流，将图片数据发送给服务器
    OutputStream out=socket.getOutputStream();
    // 4、循环写入数据到socket输出流
    byte[] buf=new byte[1024];
    int len = 0;
    while((len=fis.read(buf))!=-1) {
        out.write(buf,0,len);
    }
    // 5、告诉服务器，数据发送完毕，服务器停止读取
    socket.shutdownOutput();

    // 读取服务端返回的内容
    InputStream in=socket.getInputStream();
    byte[] bufin=new byte[1024];
    int lenin=in.read(bufin);
    System.out.println(new String(bufin,0,lenin));
    // 关闭资源
    fis.close();
    socket.close();
    }
}

服务端

public class UploadPicServer {

    /**
     * @param args
     * @throws IOException
     * @throws UnknownHostException
     */
    public static void main(String[] args) throws UnknownHostException, IOException {
    // 创建tcp的socket服务端
    ServerSocket ss = new ServerSocket(10005);

    while (true) {
        // 获取客户端
        Socket s = ss.accept();
        new Thread(new UploadTask(s)).start();
    }
//    ss.close();
    }

}