JAVA实现C/S结构小程序

程序功能:

客户端向服务器发送一个本地磁盘中的文件, 服务器程序接受后保存在其他位置.

客户端实现步骤:

1. 创建一个客户端对象Socket,构造方法中绑定服务器的IP地址 和 端口号
2. 使用Socket对象中的方法 getOutputSteam()获取网络字节输出流OutputStream对象
3. 使用字节输出流OutputStream对象中的write()方法,给服务器发送数据
4. 使用Socket对象中的getInputStream()获取网络字节输入流InputStream()对象　　
5. 使用网络字节输入流InputStream对象中的read()方法,读取服务器回写的数据.
6. 释放Socket资源.

import java.io.*;
import java.net.Socket;

public class TCPClient {
    public static void main(String[] args) throws IOException {
            //1.创建一个客户端对线Socket,构造方法中绑定服务器的IP地址和端口号
             Socket socket = new Socket("127.0.0.1",8888);
           // Socket socket = new Socket("192.168.15.132",8888);
            //2.使用Socket对象中的方法getOutputStream(0获取网络字节输出流OutputSteam对象
            //这个流是个网络流,指向了服务器
            OutputStream os = socket.getOutputStream();
            File f = new  File("E:\图片\桌面图片\宋民国\222.jpg");
            FileInputStream fis = new FileInputStream(f);
            byte[] bs = new byte[1024];
            int len;
            while((len=fis.read(bs))!=-1)
            {
                //3.使用字节输出流OutputSteam对象中的方法write,给服务器发送数据
                os.write(bs,0,len);
            }
            //告诉服务器关闭输出
            socket.shutdownOutput();
            fis.close();

           //4.使用Socket对象中的方法getInputSteam()获取网络字节输入流InputSteam()对象
            InputStream is = socket.getInputStream();
            //5.使用网络字节输入流InputSteam对象中的方法read,读取服务器回写的数据
            byte[] list = new byte[1024];
            int len1 = is.read(list);
            String str1 = new String(list,0,len1);
            //6.释放资源(Socket)
            System.out.println(str1);
            socket.close();//只用关socket就行了


    }
}

服务器端实现步骤:

1. 创建一个服务器对ServerSocket对象和指定的端口号一致.
2. 使用ServerSocket对象中的accept方法,获取请求的客户端对象Socket
3. 使用Socket对象中的getInputSream()方法
4. 使用网络字节输入流InputStream对象中的read()方法
5. 使用Socket对象中的getoutputStream()方法
6. 使用网络字节输出流OutputSteam对象中的write()方法
7. 释放资源.

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Random;

public class TCPServer {
    public static void main(String[] args) throws IOException {

        //method01();
        method02();

    }
    public static void method02() throws IOException{
       //  1.创建一个服务器对ServerSocket对象和指定的端口号要一致.
        ServerSocket serverSocket = new ServerSocket(8888);
        while(true) {
            //2.使用ServerSocket对象中的的方法accept,获取到请求的客户端对象Scoket
            // 创建多线程,提高可以同时与多个客户端进行数据的传输,提高效率
            Socket socket = serverSocket.accept();//阻塞(如果没有客户端连接,程序会停止在这个地方)
            new Thread(() -> {
                try {
                    //获得客户端Socket对象
                    //给保存的文件设置随机名,避免覆盖
                    long time = System.currentTimeMillis();
                    //3.使用Socket对象中的方法getInputSteam() 获得输入流
                    InputStream is = socket.getInputStream();
                    FileOutputStream fos = new FileOutputStream(new File("C:\123\123", time + ".jpg"));
                    byte[] list = new byte[1024];
                    int len;
                    //4.使用网络字节输入流InputStream对象中的read()方法
                    while ((len = is.read(list)) != -1) {
                        fos.write(list, 0, len);
                    }
                    fos.close();
                    //5. 使用Socket对象中的getoutputStream()方法获得输出流
                    OutputStream os = socket.getOutputStream();
                    //6.使用网络字节输出流OutputSteam对象中的write()方法
                    os.write("你好,图片传输完毕".getBytes());

                    //7. 释放资源
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }).start();

        }
    }
    public static void method01() throws IOException {

        //1.创建一个服务器对ServerSocket对象和系统指定的端口号要一致.
        ServerSocket server = new ServerSocket(8888);
        /*让服务器一直处于监听状态(死循环accept方法)
         * 有一个客户端上传文件,就保存一个文件.
         * */
        while (true){
            /* 在步骤1 与 步骤2 之间会卡主, 等待客户端连接,连接了才会进行下一步*/

            //2.使用ServerSocket对象中的的方法accept,获取到请求的客户端对象Scoket
            Socket socket = server.accept();


            //3.使用Socket对象中的方法getInputSteam()
            // 得到一个输入流,该输入流就可以调用read()方法
            InputStream is = socket.getInputStream();
            // 4.使用网络字节输入流InptuSteam对象中的read

            //文件夹 在是定文件夹下创建文件
            File dir = new File("C:\123\123");
            /*     //自动生成一个时间戳,自动生成文件名,利用毫秒值当做文件名
             *      用System.currentTimeMilis()方法获取当前系统的毫秒值,
             *      再加上一个随机数. 保证文件名是不重复的.
             * */
            long time = System.currentTimeMillis();
            String filename =time+new Random().nextInt(1000)+"";
            /*如果该文件夹不存在,则生成这个文件夹*/
            if(!dir.exists()){
                dir.mkdirs();
            }
            /**/
            FileOutputStream fos = new FileOutputStream(new File(dir,filename+".jpg"));

            //  FileOutputStream fos = new FileOutputStream(destination);
            byte[] bs = new byte[1024];
            int len;
            while((len=is.read(bs))!=-1)
            {
                fos.write(bs,0,len);
            }
            //告诉
            fos.close();


            //5.使用Socket对象中的方法 getoutputSteam 回写 收到了就谢谢.
            //利用网络指向客户端.往客户端回写数据.
            OutputStream os = socket.getOutputStream();
            //都是字节流,转换为字节再写回去.
            os.write("收到谢谢".getBytes());
            /*socket.close();

            server.close();*/

        }



    }
}

运行结果: