Java-网络（一）

网络编程分为服务端和客户端。服务端就相当于我们平时说的服务器，有固定的IP地址，随时等待服务器连接并做出响应；而客户端相当于各种端系统，找到服务端进行连接获取服务。
IP地址：唯一标识某一台电脑
端口号：唯一表示一台电脑上的某一个进程
网络通信都是使用Socket来实现
创建一个客户端的Socket服务，在该对象建立时就可去连接指定主机，因为TCP是面向连接的，所以在建立Socket服务时，就要有服务端存在，并连接成功，形成通路后，再通过该通道进行数据的传输。

下面写几个简单的Demo

一.实现客户端向服务端传递数据功能

我们先写客户端

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

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

        //客户端向服务器端发送数据
        PrintStream ps = new PrintStream(socket.getOutputStream());
        ps.println("你好啊");
        socket.shutdownOutput();
    }
}

这里再简单提一下：
（1）字节操作流：OutputStream、InputStream；
（2）字符操作流：Writer、Reader。

BufferedReader 由Reader类扩展而来，提供通用的缓冲方式文本读取，readLine读取一个文本行，
从字符输入流中读取文本，缓冲各个字符，从而提供字符、数组和行的高效读取。

BufferedWriter 由Writer 类扩展而来，提供通用的缓冲方式文本写入， newLine使用平台自己的行分隔符，将文本写入字符输出流，缓冲各个字符，从而提供单个字符、数组和字符串的高效写入。

OutputStreamWriter：是Writer的子类，将输出的字符流变为字节流，即将一个字符流的输出对象变为字节流输出对象。

InputStreamReader：是Reader的子类，将输入的字节流变为字符流，即将一个字节流的输入对象变为字符流的输入对象。

以文件操作为例，内存中的字符数据需要通过OutputStreamWriter变为字节流才能保存在文件中，读取时需要将读入的字节流通过InputStreamReader变为字符流

然后再写服务器

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

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

        //3.向客户端发送数据
        //BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));

        PrintStream ps = new PrintStream(clientSocket.getOutputStream());
        ps.println("登陆成功");

        //输出完毕
        clientSocket.shutdownOutput();

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

接下来我们再看一下运行结果：
注意：先运行服务器，再运行客户端

08221.png

客户端显示了登录成功
然后我们再看一下服务器


08222.png

上面这个Demo是很基础的，所以在这个基础上再加一丢丢难度，也就是

二.实现服务器给客户端发任意消息

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

            //接收服务器端信息
            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){
        //创建ServerSocket
        try(ServerSocket ss = new ServerSocket(8080)) {
            //监听客户端的连接
            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();
        }
    }
}

这时候我们运行一下看结果

运行一开始 两边
[图片上传中...(08224.png-3be875-1566472778836-0)]
08224.png

我们会看到两边都是空的 然后这时候我们在服务器输入想发送的内容

08225.png

输入完内容后记得要敲一下回车键
然后再看客户端
08226.png

ok内容收到，功能实现。

我们做到了实现发消息，这时候会想怎么做一个能够发图片的，所以接下来我们再做一个实现给

二.服务器端发送图片

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

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

        //向服务器端发送文件（图片）
        //1.将文件写入到内存里
        String path = "C:\\Users\\hp\\Desktop\\1.JPG";
        FileInputStream fis = new FileInputStream(path);

        //2.创建字节流 OutputStream
        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(8080);

        //监听客户端连接
        //当有客户端来连接这个服务器 就可以得到对应的socket
        //当没有客户端来连接 服务器一直在这里等待
        Socket socket = ss.accept();

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

        //接收客户端传递过来的图片
        BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
        //文件对应的输出流
        String path = "E:\\Java89\\app\\src\\main\\java\\java08212\\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);
        }
    }
}

接下来开始运行程序：
当客户端连接到服务器时，客户端会收到一段提示：


然后服务器指定的位置会收到一张图片：


08228.png

图片也发送成功了
最后我们再实现一个，两人之间简单的聊天功能，上面我们做的都是单向的，客户端向服务器发送消息、图片，所以我们要再实现

四.两人之间互发消息

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

        //用一个子线程处理服务器端数据
         new Thread(new ClientThread(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 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 {
            try {
                if(br != null){
                    br.close();
                }
                if (socket != null){
                    socket.close();
                }
            }catch (IOException ex){

            }
        }
    }
}
class Server{
    public static void main(String[] args) throws IOException{
        ServerSocket ss = new ServerSocket(8080);
        //获取客户端的socket
        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 {
            //关闭输入输出流
            //关闭对应的socket连接
            try {
                if (br != null){
                    br.close();
                }
                if (socket != null){
                    socket.close();
                }
            }catch (IOException e){

            }
        }
    }
}

运行结果：


08229.png

082210.png

两个人之间的简单的聊天功能已经实现
那么，如何实现群聊功能呢？请看下回分解.....

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

推荐阅读更多精彩内容

  • java网络编程
    计算机网络概述 网络编程的实质就是两个(或多个)设备(例如计算机)之间的数据传输。 按照计算机网络的定义，通过一定...
    蛋炒饭_By阅读 1,215评论 0赞 10
  • 电子商务网站开发与建设
    概要 64学时 3.5学分 章节安排 电子商务网站概况 HTML5+CSS3 JavaScript Node 电子...
    阿啊阿吖丁阅读 9,146评论 0赞 3
  • Java知识点总结
    Java知识点1、==和equals的区别基本类型比较==比较内容 equals比较地址值引用类型比较==比较地址...
    压抑的内心阅读 588评论 0赞 0
  • 面试题
    Swift1> Swift和OC的区别1.1> Swift没有地址/指针的概念1.2> 泛型1.3> 类型严谨 对...
    cosWriter阅读 11,093评论 1赞 32
  • 6.8
    语言表达能力太差，直接导致别人想骑到我头上拉屎，这怪我，草泥马，你欺软怕硬更无耻
    可儿可儿阅读 69评论 0赞 0