实验十六 Socket通信

一、实验预热
1、请简单解释网络三要素都是什么，分别有什么作用。
IP地址：唯一标识网络上的每一台计算机
端口号：设备与外界通讯交流的出入口
协议：通信计算机双方必须共同遵从的一组约定

2、请描述Socket通信的一般流程。
首先Socket是网络驱动层提供给应用程序的接口，即通过Socket把数据从应用层封装到数据链路层，反之通过Socket可以解封我们的数据

3、请说明TCP和UDP传输的区别。
TCP：面向连接、传输可靠（保证数据正确性、保证数据顺序）、用于传输大量数据（流模式）、速度慢、建立连接需要开销较多（时间、系统资源）
UDP：面向非连接、传输不可靠、用于传输少量数据（数据包模式）、速度快

二、实验内容
1、使用Socket编程实现基于TCP的多客户端用户登录。
代码：
服务器端：

package leif.tests.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) {
        // 创建一个服务器端Socket，即ServerSocket
        ServerSocket serverSocket = null;

        try {
            // 指定绑定的端口，并监听此端口
            serverSocket = new ServerSocket(8888);
            Socket socket = null;
            // 记录客户端的数量
            int count = 0;
            System.out.println("服务器即将启动，等待客户端连接");

            // 循环监听等待客户端连接
            while (true) {
                // 调用accept()方法开始监听，等待客户端连接
                socket = serverSocket.accept();
                // 创建一个新的线程
                ServerThread serverThread = new ServerThread(socket);
                // 启动线程
                serverThread.start();
                // 统计客户端的数量
                count++;
                System.out.println("客户端数量：" + count);
                InetAddress inetAddress = socket.getInetAddress();
                System.out.println("当前客户端IP：" + inetAddress.getHostAddress());
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (serverSocket != null) {
                    serverSocket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

class ServerThread extends Thread {
    // 和本线程相关的Socket
    private Socket socket;

    public ServerThread(Socket socket) {
        this.socket = socket;
    }

    // 线程执行的操作，响应客户端的请求
    @Override
    public void run() {
        InputStream inputStream = null;
        InputStreamReader inputStreamReader = null;
        BufferedReader bufferedReader = null;
        OutputStream outputStream = null;
        PrintWriter printWriter = null;

        try {
            // 获取一个输入流，并读取客户端的信息
            inputStream = socket.getInputStream();
            // 将字节流转化为字符流
            inputStreamReader = new InputStreamReader(inputStream);
            // 添加缓冲
            bufferedReader = new BufferedReader(inputStreamReader);
            String info = null;

            // 循环读取数据
            while ((info = bufferedReader.readLine()) != null) {
                System.out.println("我是服务器，客户端说：" + info);
            }

            // 关闭输入流
            socket.shutdownInput();
            // 获取输出流，响应客户端的请求
            outputStream = socket.getOutputStream();
            // 将输出流包装为打印流
            printWriter = new PrintWriter(outputStream);
            printWriter.write("欢迎你");
            // 将缓存输出
            printWriter.flush();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (printWriter != null) {
                    printWriter.close();
                }

                if (outputStream != null) {
                    outputStream.close();
                }

                if (bufferedReader != null) {
                    bufferedReader.close();
                }

                if (inputStreamReader != null) {
                    inputStreamReader.close();
                }

                if (inputStream != null) {
                    inputStream.close();
                }

                if (socket != null) {
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

客户端1：

package leif.tests.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class Client1 {
    public static void main(String[] args) {
        Socket socket = null;
        PrintWriter printWriter = null;
        OutputStream outputStream = null;
        InputStream inputStream = null;
        InputStreamReader inputStreamReader = null;
        BufferedReader bufferedReader = null;

        try {
            // 创建客户端Socket，指定服务器端口号和地址
            socket = new Socket("localhost", 8888);
            // 获取输出流，向服务器发送信息
            outputStream = socket.getOutputStream();
            // 将输出流包装为打印流
            printWriter = new PrintWriter(outputStream);
            printWriter.write("用户名：lbc，密码：123");
            printWriter.flush();
            socket.shutdownOutput();
            inputStream = socket.getInputStream();
            inputStreamReader = new InputStreamReader(inputStream);
            bufferedReader = new BufferedReader(inputStreamReader);
            String info = null;

            // 循环读取
            while ((info = bufferedReader.readLine()) != null) {
                System.out.println("我是客户端1，服务器说：" + info);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (bufferedReader != null) {
                    bufferedReader.close();
                }

                if (inputStreamReader != null) {
                    inputStreamReader.close();
                }

                if (inputStream != null) {
                    inputStream.close();
                }

                if (printWriter != null) {
                    printWriter.close();
                }

                if (outputStream != null) {
                    outputStream.close();
                }

                if (socket != null) {
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

客户端2：

package leif.tests.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class Client2 {
    public static void main(String[] args) {
        Socket socket = null;
        PrintWriter printWriter = null;
        OutputStream outputStream = null;
        InputStream inputStream = null;
        InputStreamReader inputStreamReader = null;
        BufferedReader bufferedReader = null;

        try {
            // 创建客户端Socket，指定服务器端口号和地址
            socket = new Socket("localhost", 8888);
            // 获取输出流，向服务器发送信息
            outputStream = socket.getOutputStream();
            // 将输出流包装为打印流
            printWriter = new PrintWriter(outputStream);
            printWriter.write("用户名：gll，密码：123");
            printWriter.flush();
            socket.shutdownOutput();
            inputStream = socket.getInputStream();
            inputStreamReader = new InputStreamReader(inputStream);
            bufferedReader = new BufferedReader(inputStreamReader);
            String info = null;

            // 循环读取
            while ((info = bufferedReader.readLine()) != null) {
                System.out.println("我是客户端2，服务器说：" + info);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (bufferedReader != null) {
                    bufferedReader.close();
                }

                if (inputStreamReader != null) {
                    inputStreamReader.close();
                }

                if (inputStream != null) {
                    inputStream.close();
                }

                if (printWriter != null) {
                    printWriter.close();
                }

                if (outputStream != null) {
                    outputStream.close();
                }

                if (socket != null) {
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

结果截图：

image.png

2、使用Socket实现基于UDP传输的客户咨询功能，要求接收方显示内容如下格式。

image.png

代码：
服务器端：

package leif.tests.socket;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
import java.util.Scanner;

public class Server {
    public static void main(String[] args) {
        DatagramSocket datagramSocket = null;
        Scanner scanner = null;

        try {
            // 接收数据
            datagramSocket = new DatagramSocket(8648);
            byte receiveData[] = new byte[4 * 1024];
            // 两个参数：byte数组、数组长度
            DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
            datagramSocket.receive(receivePacket);
            // 三个参数：包、包的起始位置、包的大小
            String result = new String(receivePacket.getData(), receivePacket.getOffset(), receivePacket.getLength());
            System.out.println("客户端（" + receivePacket.getAddress().toString() + "）：" + result);
            // 发送数据
            scanner = new Scanner(System.in);
            System.out.print("我说：");
            String string = scanner.next();
            byte sendData[] = string.getBytes();
            // 四个参数：byte数组、数组长度、发送的地址、发送的端口号
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, receivePacket.getAddress(), receivePacket.getPort());
            datagramSocket.send(sendPacket);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (scanner != null) {
                scanner.close();
            }

            if (datagramSocket != null) {
                datagramSocket.close();
            }
        }
    }
}

客户端：

package leif.tests.socket;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Scanner;

public class Client {
    public static void main(String[] args) {
        DatagramSocket datagramSocket = null;
        Scanner scanner = null;
        try {
            datagramSocket = new DatagramSocket(5548);
            InetAddress inetAddress = InetAddress.getLocalHost();
            scanner = new Scanner(System.in);
            System.out.print("我说：");
            String string = scanner.next();
            byte[] sendData = string.getBytes();
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, inetAddress, 8648);
            datagramSocket.send(sendPacket);
            byte receiveData[] = new byte[4 * 1024];
            DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
            datagramSocket.receive(receivePacket);
            String result = new String(receivePacket.getData(), receivePacket.getOffset(), receivePacket.getLength());
            System.out.println("服务器说：" + result);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (scanner != null) {
                scanner.close();
            }

            if (datagramSocket != null) {
                datagramSocket.close();
            }
        }
    }
}

结果截图：

image.png

最后编辑于：2019.03.13 16:27:08

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

实验十六 Socket通信

推荐阅读更多精彩内容