Java| Socket（套接字）网络编程

一、目的

学习Socket（套接字）网络编程。

二、知识点

1.基本知识

2.IP地址和端口号

3.Socket

4.实现服务器端和客户端传输数据：注意端口号必须相同先运行Server 再运行Client

//模拟客户端
class MyClient{
    //要运行起来
    public static void main(String[] args) {
        //创建用于通信的socket  即指明和谁通信：IP地址 端口号
        Socket socket = null;
        try {
            socket = new Socket("10.129.2.205",8989);

            //接收服务器端的信息
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String line = null;
            while((line = br.readLine()) !=null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络出错 请重新登录");
        }finally{
            //关闭链接
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
}
//模拟服务器端
class MyServer{
    public static void main(String[] args){
        //1.创建服务器端的serversocket
        try(ServerSocket ss = new ServerSocket(8989)) {//错了直接关闭括号里的，就不用finally
            //监听客户端
            Socket socket = ss.accept();

            //从终端接收数据
            BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
            //向客户端输出数据输出流
            PrintStream ps = new PrintStream(socket.getOutputStream());
            String line = null;
            while((line = keyin.readLine())!= null){
                //发送给客户端
               // System.out.println(line);
                ps.println(line);
            }

        } catch (IOException e) {
            e.printStackTrace();
        }
}

5.客户端向服务器端发送图片
准备一张图片的保存路径作为原路径，以及当前代码的保存路径作为传输后的保存路径（这个可自己挑选，只需要运行完毕后查看该路径下是否出现传输的图片）

class Client{
    public static void main(String[] args) throws IOException {
        //链接服务器端 获取socket
        Socket socket = new Socket("10.129.2.205",8000);

        //创建服务器端的输入流 用于接收服务器端发来的数据
        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        System.out.println(br.readLine());

        //向服务器端发送图片
        //第一步  将文件写入内存
        String path = "F:/烟炊集/jjl.jpg";
        FileInputStream fis = new FileInputStream(path);
        //第二步  将文件输出到服务器端
        BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
       //第三步  将文件的内容一点点的传输给服务器
        byte[] buf = new byte[1024];//用的是字节流   //可以用字符流
        int len = -1;
        while((len = fis.read(buf))!=-1 )   {
            bos.write(buf,0,len);
        }
        socket.shutdownOutput();
    }
}
class Server{
    public static void main(String[] args) throws IOException {
        //创建服务器端的serversocket
        ServerSocket ss = new ServerSocket(8000);
        //监听客户端链接
        //当有客户端来连接这个服务器 就可以得到对应的socket
        //当没有客户端来链接 服务器一直在这里等待
        Socket socket = ss.accept();

        //创建客户端对应的输出流 用于向这个客户端发送数据
        PrintStream ps = new PrintStream(socket.getOutputStream());
        ps.println("链接成功，可以发送数据");

        //接收客户端传输来的文件
        BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());

        //文件对应的输出流
        String path = "F:/Androidstudio/java2/src/main/java/day12/media/LL.jpg";
        FileOutputStream fos = new FileOutputStream(path);

        byte[] buf = new byte[1024];//用的是字节流   //可以用字符流
        int len = -1;
        while((len = bis.read(buf))!=-1 )   {
            fos.write(buf,0,len);
        }
        socket.shutdownOutput();
    }
}

运行效果：

三、实际应用

1.对聊:实现效果如下

/**
 * 服务器端和客户端都可以随意的发送对话内容
 * 从终端输入
 *
 * 客户端：
 *       主线程：接收终端输入 将终端的输入发送给服务器端
 *       子线程：接收服务器端发来的数据
 * 服务器端：
 *         主线程：接收终端输入 将终端的输入发送给客户端
 *  *      子线程：接收客户端发来的数据
 */

代码
客户端：

class Client{
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("10.129.2.205",8000);
        //子线程 处理服务端数据
        new Thread(new ClientThread(socket)).start();

        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        //客户端的输出流对象
        PrintStream printStream = new PrintStream(socket.getOutputStream());
        String line = null;
        while ((line = keyin.readLine())!= null){
            printStream.println(line);
        }
    }
}

服务器端

class Server{
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8000);

        Socket socket = serverSocket.accept();

        new ServerThread(socket).start();

        //终端输入流对象
        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        //客户端的输出流对象
        PrintStream printStream = new PrintStream(socket.getOutputStream());
        //读取终端的输入 输出给客户端
        String line = null;
        while ((line = keyin.readLine())!= null){
            printStream.println(line);
        }
    }
}

创建一个子线程给服务器端用于处理、接收客户端的数据

class ServerThread extends Thread{
    private Socket socket;
    public ServerThread(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        BufferedReader bufferedReader = null;
        try {
            bufferedReader= new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String line = null;
            while ((line = bufferedReader.readLine())!=null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络异常 请重新登录");
        }finally {
            try{
                if(bufferedReader != null){
                    bufferedReader.close();
                }
                if (socket!= null){
                    socket.close();
                }

            }catch (IOException e){
                e.printStackTrace();
            }
        }
    }
}

创建一个子线程给客户端用于处理、接收服务器端的数据

class ClientThread implements Runnable{
    private Socket socket;
    //保存操作的socket 对象
    public ClientThread(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        BufferedReader bufferedReader = null;
        try {
            //获取输入
            bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //读取
            String line = null;
            while ((line=bufferedReader.readLine()) != null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络出错  请重新登录");
            System.exit(-1);
        }finally {
            try {
                if (bufferedReader != null) {
                    bufferedReader.close();
                }
                if (socket != null) {
                    socket.close();
                }
            }catch (IOException e) {
                e.printStackTrace();
            }

        }
    }
}

2.群聊
和对聊只是Server类的区别需要一个数组来保存所有客户端发消息的时候是群发用遍历来实现

class Server{
    public static ArrayList<Socket> sockets = new ArrayList<>();
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8000);

        while (true){
            Socket socket = serverSocket.accept();
            //当客户连接过来就保存
            sockets.add(socket);

            new ServerThread(socket).start();
        }
    }
}
class Client{
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("10.129.2.205",8000);
        //子线程 处理服务端数据
        new Thread(new ClientThread(socket)).start();

        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        //客户端的输出流对象
        PrintStream printStream = new PrintStream(socket.getOutputStream());
        String line = null;
        while ((line = keyin.readLine())!= null){
            printStream.println(line);
        }
    }
}
class ClientThread implements Runnable{
    private Socket socket;
    //保存操作的socket 对象
    public ClientThread(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        BufferedReader bufferedReader = null;
        try {
            //获取输入
            bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //读取
            String line = null;
            while ((line=bufferedReader.readLine()) != null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络出错  请重新登录");
            System.exit(-1);
        }finally {
            try {
                if (bufferedReader != null) {
                    bufferedReader.close();
                }
                if (socket != null) {
                    socket.close();
                }
            }catch (IOException e) {
                e.printStackTrace();
            }

        }
    }
}
class ServerThread extends Thread{
    private Socket socket;
    public ServerThread(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        BufferedReader bufferedReader = null;
        try {
            bufferedReader= new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String line = null;
            while ((line = bufferedReader.readLine())!=null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络异常 请重新登录");
        }finally {
            try{
                if(bufferedReader != null){
                    bufferedReader.close();
                }
                if (socket!= null){
                    socket.close();
                }

            }catch (IOException e){
                e.printStackTrace();
            }
        }
    }
}

四、心得

前面学的I/O流的内容感觉又忘了，今天学这个网络的时候也一起复习了。学的东西变多的时候，就要考虑怎么样才能记住前面的了。焦虑是没有用的，现在的焦虑多半是自己付出了，但看不到收获，产生的自我怀疑现象。当你正在为做不成某件事而抱怨苦恼的时候，静下心来想一想，你真正投入的时间和精力有多少，也许你就会知道现在为什么自己是现在这样了。

最后编辑于：2019.08.21 23:52:23

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 218,525评论 6赞 507
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 93,203评论 3赞 395
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 164,862评论 0赞 354
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 58,728评论 1赞 294
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 67,743评论 6赞 392
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 51,590评论 1赞 305
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 40,330评论 3赞 418
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 39,244评论 0赞 276
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 45,693评论 1赞 314
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,885评论 3赞 336
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 40,001评论 1赞 348
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 35,723评论 5赞 346
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 41,343评论 3赞 330
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,919评论 0赞 22
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 33,042评论 1赞 270
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 48,191评论 3赞 370
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,955评论 2赞 355

Java| Socket（套接字）网络编程

一、目的

二、知识点

三、实际应用

四、心得

推荐阅读更多精彩内容