Java 原生网络编程.-低调大师

Java 原生网络编程.

2018-06-04 502

一、概念

Java 语言从其诞生开始，就和网络紧密联系在一起。在 1995 年的 Sun World 大会上，当时占浏览器市场份额绝对领先的网景公司宣布在浏览器中支持Java，从而引起一系列的公司产品对Java的支持，使得Java很快成为一种流行的语言。

Java 提供的网络功能的相关类主要有三个，它们分别是URL、Socket、Daragram。

二、URL 和 URLConnection

URL类代表一个统一资源定位符号，它是指向互联网资源的指针。是这三个类中层次级别最高或者说封装最多的类，通过URL可以直接发送或者读取网络上的数据。

    public static void uRLTest(){
        try {
            //URL：统一资源定位符（网址）
            URL url = new URL("http://www.baidu.com");
            InputStream inputStream = url.openStream();
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "UTF-8");
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            String line;
            while ((line = bufferedReader.readLine())!=null){
                System.out.println(line);
            }
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

前面介绍的 URL 类代表的是一个网络资源的位置，而URLConnection 代表的是一个连接，此类的实例可用于读取或者写入对应URL引用的资源。

public static void uRLConnectionTest(){
    try {
        URL url = new URL("http://restapi.amap.com/v3/config/district?key=2c95fdacd3f72bdbfec55bd7eac7b5c0");
        //1、创建连接对象
        URLConnection urlConnection = url.openConnection();
        HttpURLConnection httpURLConnection = (HttpURLConnection) urlConnection;
        //2、设置参数和一般请求属性
        //应用程序要将参数写入URL连接
        httpURLConnection.setDoOutput(true);
        //应用程序要向URL连接读取数据
        httpURLConnection.setDoInput(true);
        //不使用缓存
        httpURLConnection.setUseCaches(false);
        //设置请求参数
        httpURLConnection.setRequestProperty("Content-type","application/json");
        //设置请求方法
        httpURLConnection.setRequestMethod("POST");
        //3、使用connect方法建立到远程对象的实际链接
        httpURLConnection.connect();
        //4、远程对象变为输入输出流，根据需求进一步操作
        InputStream inputStream = httpURLConnection.getInputStream();
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream,"utf-8"));
        BufferedWriter bufferedWriter = new BufferedWriter(new FileWriter("E:\\data.json"));
        String line;
        while ((line = bufferedReader.readLine()) != null){
            bufferedWriter.write(line);
            bufferedWriter.newLine();
            bufferedWriter.flush();
        }
    } catch (MalformedURLException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

三、基于TCP的Socket编程

Socket也称为套接字，应用程序通常通过套接字向网络发出请求或者应答网络的请求。.Java 语言中的 Socket 编程常用到 Socket 和 ServerSocket 这两个类。

ServerSocket 用于服务端，而 Socket 是建立网络连接时使用的，在连接成功时，应用程序两端都会产生一个 Socket 实例，操作这个实例完成所需的会话。对于一个网络连接来说，套接字是平等的，不因为在服务端或者客户端而产生不同级别，不管是Socket还是ServerSocket，它们的工作都是通过SocketImpl类及其子类完成的。

TCP 的 Socket 编程示意图：

服务端程序：

public static void main(String[] args) {
    try {
        System.out.println("启动服务器......");
        //创建一个新的ServerSocket，用来监听指定端口上的连接请求
        ServerSocket serverSocket = new ServerSocket(8989);
        Socket socket = null;
        while (true) {
            try {
                //对accept()方法的调用将被阻塞，直到一个连接创建
                //该socket用于客户端和服务器之间的通信
                //流对象都派生于该套接字的流对象
                socket = serverSocket.accept();
                InputStream inputStream = socket.getInputStream();
                BufferedReader in = new BufferedReader(new InputStreamReader(inputStream));
                PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
                String request, response;
                while ((request = in.readLine()) != null) {
                    //如果客户端发送了exit，则退出循环
                    if ("exit".equals(request)) {
                        break;
                    }
                    System.out.println("接收到客户端请求：" + request);
                    //服务端处理方法
                    response ="客户端：" + socket.getInetAddress().getHostAddress() + " 请求，" + processRequest(request);
                    //响应给客户端
                    out.println(response);
                }
            } catch (Exception e) {
                System.out.println("Error");
            } finally {
                socket.close();
            }
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}

客户端程序：

public static void main(String[] args) {
    Socket socket = null;
    try {
        socket = new Socket("192.168.1.22", 8989);
        //向服务器发送数据
        //printWriter（字符流）/printStream（字节流）
        PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);
        //接收服务器的反馈
        InputStream inputStream = socket.getInputStream();
        BufferedReader in = new BufferedReader(new InputStreamReader(inputStream));
        //模拟交互
        BufferedReader bf = new BufferedReader(new InputStreamReader(System.in));
        String request, responese;
        while ((request = bf.readLine()) != null) {
            printWriter.println(request);
            responese = in.readLine();
            System.out.println(responese);
        }
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        try {
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

四、基于UDP的Socket编程

UDP 是用户数据报协议，它提供的是无连接、不可靠信息传送服务。Java 主要提供两个类来实现基于 UDP 的 Socket 编程：

DatagramSocket：此类表示用来发送和接收数据报包的套接字，数据报套接字是包投递服务的发送或接收点，每个在数据报套接字上发送或接收的包都是单独编址和路由的。在DatagramSocket上总是启用UDP广播发送。

DatagramPacket：此类表示数据报包。数据报包用来实现无连接包投递服务，每条报文仅根据该包中的信息从一台机器路由到另一台机器。

UDP 的 Socket 编程示例图：

服务端（接收端）程序：

public static void main(String[] args) {
    DatagramSocket server = null;
    try {
        server = new DatagramSocket(8088);
        byte[] datas = new byte[1024];
        //用一个字节数组接收UDP包，字节数组在传递给构造函数时是空的
        DatagramPacket datagramPacket = new DatagramPacket(datas, datas.length);
        server.receive(datagramPacket);
        System.out.println(new String(datas));
    } catch (SocketException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }finally {
        server.close();
    }
}

客户端（发送端）程序：

public static void main(String[] args) {
    DatagramSocket client = null;
    try {
        client = new DatagramSocket();
        //创建数据报
        byte[] buffer = "hello,world".getBytes();
        InetAddress byName = InetAddress.getByName("192.168.1.22");
        //建立将要传输的UDP包，并指定ip地址和端口号
        DatagramPacket datagramPacket = new DatagramPacket(buffer, buffer.length, byName, 8088);
        client.send(datagramPacket);
    } catch (SocketException e) {
        e.printStackTrace();
    } catch (UnknownHostException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        client.close();
    }
}

微信关注我们

原文链接：https://yq.aliyun.com/articles/616419

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

HiSDP —— 高效的C++软件开发平台

目前阿里集团每天有近1000PB的数据是通过LogAgent采集的，为了让LogAgent做到资源占用节省和高效采集，背后是基于HiSDP去构建的。缘由当决定采用C++编程语言去开发一个软件时，紧接着所面临的问题是软件库、平台与框架的选择。当然，选择的范围估计很大程度来自开源软件。进一步地，无外乎两种思路：根据所开发软件的需要选择各种合适的开源软件，然后将这些开源软件组合到一起去完成软件开发工作。这种方式所带来的问题在于，将各个开源软件拼凑到一起需要耗费一定的精力。此外，可能因为踩各开源软件中的坑而导致最终软件产品的稳定期拉得更长，后期的维护成本也更高。采用市面上成熟的大型开源软件项目，对之进行裁剪去满足项目开发的需要。这一方式虽说在裁剪上需要消耗一定的精力（这是一次性的工作内容），但由于大型项目的成熟确保了其所选择的各个开源子项

2018-06-05

709

如果没遇到过OME错误，都不好意思说自己是做Java开发的。 JVM 最近更新文章的速度很慢，懒，另外我对时间的分配不太擅长，事情一旦多起来，就很容易焦头烂额，效率也变低，看起来一天忙忙碌碌，最后发现处理的事情并不多。但是在不多的事情中，每天其实在程序开发上都会遇到一些值得分享的事情，如果一直没有动笔记录，很多事情都慢慢的忘记了。所以不管怎么忙，我想还是把工作中遇到技术上的问题，拿出来分享给大家，帮大家少踩坑。也是自己工作的一次记录。 OME的发生 OutOfMemoryError异常可以说是一个比较棘手的问题，Java中所有的对象都存储在堆中，通常如果JVM无法再分配新的内存，内存耗尽，垃圾回收无法及时回收内存，就会抛出OutOfMemoryError。我这次遇到的OME错误如图： image.png 报错误的原因是因为: 执行垃圾收集的时间比例太大, 有效的运算量太小. 默认情况下, 如果GC花费的时间超过 98%, 并且GC回收的内存少于 2%, JVM就会抛出这个错误。解决方案都是自己写的程序，报这个错误，自己心里能没有点数吗，我里面写了一个大对象，实例化之后会不断的加载...

2018-06-05

658

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。