Java Day12

Socket 网络编程

目的

了解什么是网络编程
网络编程：在两台不同的计算机之间传递数据
1.QQ聊天
2.打开网易app 刷新界面就有数据
3.打开浏览器网页 www.baidu.com

客户端：手机APP 浏览器桌面QQ
服务器端：存储、处理数据
URL：统一的资源定位
http://www.baidu.com/search?code=android&type=1
http/https ：传输协议 TCP/ IP
www.baidu.com：域名表示一台网络中的电脑
IPv4 IPv6 地址：唯一标识一网络中的计算机
32位：四个部分每个部分是8个字节
170.20.10.15
DNS服务器：域名解析
将www.baidu.com类型的域名解析为对应的IP地址
search 对应的后台程序文件 PHP java jsp
？表示运行这个程序需要传递的参数
code=android code是服务器端规定的字段
& 如果有多个参数使用&符号链接
IP地址找到这台电脑唯一标识一台电脑
端口号：找到这台电脑上的某一个程序唯一标识电脑上的某一个进程（程序）
数据传输：TCP/IP协议
TCP：面向链接的安全的
UDP:面向无链接的不安全但快
网络中的数据传输：Socket实现->套接字
Socket：客服端
ServerSocket：服务器端
读取数据：服务器读取客户端读取
BufferedReader -> InputStreamReader -> socket.getInputStream();
读取终端
BufferedReader -> InputStreamReader -> System.in
输出：客户端输出服务器端输出
BufferedWriter -> OutputStreamWriter -> socket.getOutputStream();

技术

1.实现客户端和服务器端传递数据
2.实现服务器端手动输入，将输入的内容发送给客户端
3.实现客户端向服务器端上传图片
4.使用多线程对聊
5.实现群聊

技术实现

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

// 模拟客户端

class Client{
    public static void main(String[] args) throws IOException {
        // 1.创建用于通信的socket
        //  指明和谁通信：IP地址  端口号
        Socket socket = new Socket("10.129.28.234",6767);
        // 接收服务器端的数据
        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//         // 向服务器端发送数据
//
//        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
//        bw.write("thank you very much");

        // 读取服务器端发来的数据
        String line = null;
        while ((line = br.readLine()) != null){
            System.out.println(line);
        }

        // 客户端向服务器端发送数据
        PrintStream ps = new PrintStream(socket.getOutputStream());
        ps.println("你好啊");
        socket.shutdownInput();
    }
}
// 模拟服务器端
class Server{
    public static void main(String[] args) throws IOException {
        // 1.创建服务器端的serverSocket
        ServerSocket ss = new ServerSocket(6767);

        // 2.获取链接的客户端的socket
        Socket clientSocket = ss.accept();

        // 3.向客户端发送数据
//        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
        PrintStream ps = new PrintStream(clientSocket.getOutputStream());
        ps.println("登录成功");
        // 输出完毕
        clientSocket.shutdownInput();

        // 读取客户端信息
//        BufferedReader br = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
//        String line = null;
//        while ((line = br.readLine()) != null) {
//            System.out.println(line);
//       }
        //4.接收客户端发来的数据
        BufferedReader br = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        String line = null;
        while ((line = br.readLine()) != null){
            System.out.println(line);
        }
    }
}

实现服务器端手动输入，将输入的内容发送给客户端
可以一直发

class MyClient{
    public static void main(String[] args) throws IOException {
        Socket socket = null;
        // 连接服务器端的socket
        try {
            socket = new Socket("10.129.28.234",8888);

            // 接收服务器端的信息
            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){
        try( ServerSocket ss = new ServerSocket(8888)) {
           // 监听客户端
            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){
                // 发送给客户端
                ps.println(line);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

实现客户端向服务器端上传图片

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

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

        // 向服务器端发送图片
        // 1.将文件写入到内存里
        String path = "C:\\Users\\Administrator\\Desktop\\Android\\firstExperience\\java\\src\\main\\java\\day8\\1.jpg";
        FileInputStream fis = new FileInputStream(path);
        // 2.创建字节流
        BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
        // 3.将文件的内容一点一点的传输到服务器
        byte[] buf = new byte[1024];
        int len = -1;
        while ((len = fis.read(buf))!= -1){
            bos.write(buf,0,len);
        }
    }
}

class Server{
    public static void main(String[] args) throws IOException {
// 创建服务器端的ServerSocket
        ServerSocket ss = new ServerSocket(1111);

        // 监听客户端连接
        // 当前有客户端来连接这个服务器 就可以得到对应的socket
        // 当没有客户端来连接 服务器一直在这里等待
        Socket socket = ss.accept();
        // 创建客户端对应的输出流 用于向这个客户端发送数据
        PrintStream  ps = new PrintStream(socket.getOutputStream());
        ps.println("连接成功 可以发数据了");

        // 接收客户端传递过来的图片
       
        // 文件对应的输出流
        BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
        String path = "C:\\Users\\Administrator\\Desktop\\Android\\firstExperience\\java\\src\\main\\java\\day12\\medio\\2.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);
        }
    }
}

使用多线程实现对聊

class Client {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("10.129.28.234",6789);

        // 主线程处理终端输入 发送给服务器端
        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        PrintStream ps = new PrintStream(socket.getOutputStream());

        // 用一个子线程处理服务器端数据
        new Thread(new ClientThread(socket)).start();

        String line  = null;
        while ((line = keyin.readLine())!=null){
            ps.println(line);
        }

    }
}

/**
 * 创建一个子线程处理客户端接收服务器端的数据
 */
class ClientThread implements Runnable{
    private Socket socket;

    // 保存socket对象
    public ClientThread(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        BufferedReader br = null;
        try {
            // 获取服务器端的输入流对象
            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("网络出错 请重新登录");
            System.exit(-1);
        }finally {
            if(br != null){
                try {
                    br.close();
                    if (socket != null){
                        socket.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(6789);
        Socket socket = ss.accept();

        // 创建子线程 处理客户端输入信息
        new ServerThread(socket).start();
        // 终端输入流对象
        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));

        // 客户端的输出流
        PrintStream ps = new PrintStream(socket.getOutputStream());

        // 读取终端的输入 将输入输出给客户端
        String line = null;
        while ((line = keyin.readLine()) != null){
            ps.println(line);
        }
    }
}
/**
 * 创建一个子线程处理服务器端接收客户端的数据
 */
class ServerThread extends Thread{
    private Socket socket;

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

    @Override
    public void run() {
        BufferedReader br = null;
        try {
            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("网络异常 请重新登录");
            System.exit(-1);
        }finally {
            try {
                if (br != null){
                    br.close();
                }
                if (socket != null){
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

实现群聊

class Client {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("10.129.28.234",7657);

        // 主线程处理终端输入 发送给服务器端
        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        PrintStream ps = new PrintStream(socket.getOutputStream());

        // 用一个子线程处理服务器端数据
        new Thread(new ClientThread(socket)).start();

        String line  = null;
        while ((line = keyin.readLine())!=null){
            ps.println(line);
        }

    }
}
class Client1 {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("10.129.28.234",7657);

        // 主线程处理终端输入 发送给服务器端
        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        PrintStream ps = new PrintStream(socket.getOutputStream());

        // 用一个子线程处理服务器端数据
        new Thread(new ClientThread(socket)).start();

        String line  = null;
        while ((line = keyin.readLine())!=null){
            ps.println(line);
        }

    }
}
class Server{
    // 保存每一个连接过来的socket对象
    public static ArrayList<Socket> sockets = new ArrayList<>();

    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(7657);

        // 不停地等待客户端来连接
        while (true){
            Socket socket = ss.accept();
            // 当有客户端连接过来了 就保存

            sockets.add(socket);

            // 开启一个线程处理每个客户端的输入
            new ServerThread(socket).start();
        }
    }
}
class ClientThread implements Runnable{
    private Socket socket;

    // 保存socket对象
    public ClientThread(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        BufferedReader br = null;
        try {
            // 获取服务器端的输入流对象
            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("网络出错 请重新登录");
            System.exit(-1);
        }finally {
            if(br != null){
                try {
                    br.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 br = null;
        try {
            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String line = null;
            while ((line = br.readLine())!= null){
                // 群发消息
                // 遍历Server维护的数组
                for(Socket s:Server.sockets){
                    // 向socket对应的客户端发送消息
                    PrintStream ps = new PrintStream(s.getOutputStream());
                    ps.println(line);
                }
            }
        } catch (IOException e) {
            System.out.println("网络异常 请重新登录");
            System.exit(-1);
        }finally {
            try {
                if (br != null){
                    br.close();
                }
                if (socket != null){
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

心得

今天学习网络，其实在上课期间我特别懵，就是一直在跟着敲，但是却没有搞懂。感觉挺难的，不过当晚上看视频的时候，很多地方都明白了，感觉也不是那么难。这样我就能更好学习明天的知识了。

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

Java Day12

Socket 网络编程

目的

技术

技术实现

心得

推荐阅读更多精彩内容