Java网络通信

标签: Java  java  网络通信  socket

Java中和网络有关的类分为四种:InetAddress(网络信息标识)、URL(统一资源定位器,读写网络数据)、Sockets(利用TCP/IP实现网络通信)、Datagram(UDP数据报通信)

InetAddress与URL

通过InetAddress可以获取计算机名、IP地址等信息

    public static void main(String[] args) throws UnknownHostException {
        InetAddress address=InetAddress.getLocalHost();         // 通过静态方法生成InetAddress实例
        System.out.println("计算机名称:"+ address.getHostName());
        System.out.println("IP地址:"+ address.getHostAddress());
        byte[] ipBytes=address.getAddress();                // 以数组的形式获取IP
        System.out.println("IP地址数组:"+ Arrays.toString(ipBytes));
        System.out.println(address);        //打印实例,输出:主机名/IP

        InetAddress address1=InetAddress.getByName("DELL-T");     // 通过主机名获取实例
        System.out.println(address1.getHostAddress());
        InetAddress address2=InetAddress.getByName("192.168.80.1");     //通过IP字符串获取实例
        System.out.println(address2.getHostName());
    }

url用于唯一标识网络上的资源位置,由协议名和资源名两部分组成,例如https://www.baidu.com/s?wd=Java#p1,https为协议名,后面为资源名。java.net包中的URL类用于操作url相关信息,其使用如下:

        URL baidu = new URL("https://www.baidu.com");     // 通过网址创建url实例
        URL url = new URL(baidu, "s?wd=Java#p1");          // 在url对象的基础上拼接成新的url实例

        //查看url相关信息
        System.out.println("协议" + url.getProtocol());
        System.out.println("主机" + url.getHost());
        System.out.println("端口" + url.getPort());
        System.out.println("文件路径" + url.getFile());
        System.out.println("相对路径" + url.getRef());
        System.out.println("查询内容" + url.getQuery());

结果如下:

通过url的openStream()方法可以获取url对应的网络资源,打开输入流之后便可读取url内容

        InputStream inputStream = url.openStream();    //打开网络资源输入流   
        BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));   //缓冲读取内容
        String line = br.readLine();
        while (line != null) {
            System.out.println(line);
            line = br.readLine();
        }
        br.close();
        inputStream.close();

Socket通信

Sockets是指TCP协议的基础上实现的面向连接、可靠、有序、面向字节流的网络通信类,主要包括两个类,在服务器端的ServerSocket类和在客户端的Socket类,其通信流程如下所示

如下所示为客户端向服务器发送登录请求,服务器返回相应的Socket通信示例过程:

//服务器端,先启动
public class ServerSocketDemo {
    public static void main(String[] args) {
        try {
            //1、创建服务器端ServerSocket对象,绑定监听的端口号6666
            ServerSocket serverSocket = new ServerSocket(6666);
            //2、调用accept()方法监听开始,等待客户端连接
            System.out.println("服务器端等待客户端连接。。。");
            Socket socket = serverSocket.accept();
            //3、通过输入流读取客户端传来的信息
            InputStream inputStream = socket.getInputStream();        //获取字节输入流
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));//包装为缓冲字符流
            String info;
            while ((info = bufferedReader.readLine()) != null)
                System.out.println("收到客户端信息:" + info);
            InetAddress address = socket.getInetAddress();    // 获取客户端的InetAddress信息
            System.out.println("当前客户端的IP:" + address.getHostAddress());
            socket.shutdownInput();                                 //关闭socket输入流
            //4、通过输出流向客户端返回相应信息
            OutputStream outputStream = socket.getOutputStream();     //获取输出流
            PrintWriter printWriter = new PrintWriter(outputStream);  //将输出流包装为打印流
            printWriter.write("欢迎登录!");
            printWriter.flush();
            socket.shutdownOutput();                                //关闭socket输出流
            //5、关闭资源流
            printWriter.close();
            outputStream.close();
            bufferedReader.close();
            inputStream.close();
            socket.close();
            serverSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
//客户端
public class ClientSocketDemo {
    public static void main(String[] args) {
        try {
            //1、创建客户端Socket对象,指定要连接的服务器和端口
            Socket socket = new Socket("localhost", 6666);
            //2、通过输出流向服务器发送信息
            OutputStream outputStream = socket.getOutputStream();     //获取输出流
            PrintWriter printWriter = new PrintWriter(outputStream);  //将输出流包装为打印流
            printWriter.write("用户名:小明;密码:1234");
            printWriter.flush();
            socket.shutdownOutput();
            //3、通过输入流接收服务器的返回信息
            InputStream inputStream = socket.getInputStream();        //获取字节输入流
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));//包装为缓冲字符流
            String info;
            while ((info = bufferedReader.readLine()) != null)
                System.out.println("收到服务器端相应:" + info);
            socket.shutdownInput();
            //4、关闭流资源
            bufferedReader.close();
            inputStream.close();
            printWriter.close();
            outputStream.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

UDP通信

UDP是无连接、不可靠、无序的传输协议,但其传输速度较快,因此常用于对速度敏感、不要求太高准去率的传输过程。在传输时,首先将要传输的数据封装成数据报(Datagram),在数据报中定义数据要目的主机和端口号(Socket),然后再将数据发送出去。Java中的DatagramPacket类表示数据包,DatagramSocket类表示端到端的UDP通信。如下所示为服务器端和客户端通过UDP通信的过程:

//服务器端
public class UDPServer {
    public static void main(String[] args) throws IOException {
        //服务器端接收客户端信息
        //1、创建非服务器端的UDPsocket对象并指定端口
        DatagramSocket socket = new DatagramSocket(6666);
        //2、创建用于接受客户端数据的数据报
        byte[] data = new byte[1024];            //用于接收数据的字节数组
        DatagramPacket packet = new DatagramPacket(data, data.length);
        //3、接收客户端的数据
        System.out.println("等待客户端数据中。。。");
        socket.receive(packet);
        //4、读取接收在data中的字节数组转化为字符串
        String s = new String(data, 0, packet.getLength());
        System.out.println("服务器端收到的数据:" + s);

        //服务器向客户端发送响应信息
        //1、定义响应信息与客户端的地址和端口
        byte[] response = "欢迎您!".getBytes();
        InetAddress clientAddress = packet.getAddress();  //从客户端发来的数据报中得到其IP地址
        int port = packet.getPort();
        //2、创建响应数据报
        DatagramPacket responsePacket = new DatagramPacket(response, response.length, clientAddress, port);
        //3、发送数据报
        socket.send(responsePacket);
        //4、关闭资源
        socket.close();
    }
}
//客户端
public class UDPClient {
    public static void main(String[] args) throws IOException {
        //客户端向服务器发送数据报
        //1、创建数据报,包含要发送的数据、目标服务器地址、端口号
        byte[] data = "用户名:小明;密码:1234".getBytes();
        InetAddress address = InetAddress.getByName("localhost");
        DatagramPacket packet = new DatagramPacket(data, data.length, address, 6666);
        //2、创建DatagramSocket对象
        DatagramSocket socket = new DatagramSocket();
        //3、发送数据包
        socket.send(packet);

        //客户端接收服务器响应数据报
        //1、创建接收数据报的packet
        byte[] resData = new byte[1024];
        DatagramPacket resPacket = new DatagramPacket(resData, resData.length);
        //2、接收响应数据
        socket.receive(resPacket);
        //3、读取响应数据
        String res = new String(resData, 0, resPacket.getLength());
        System.out.println("客户端收到响应:" + res);
        //4、关闭资源
        socket.close();
    }
}

 

版权声明:本文为theVicTory原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/theVicTory/article/details/104189552

智能推荐

AtCoder Beginner Contest 174 E.Logs

AtCoder Beginner Contest 174 E.Logs 题目链接 到最后才发现是二分,菜菜的我/(ㄒoㄒ)/~~ 我们直接二分 [1,max{a[i]}][1,max\lbrace a[i]\rbrace][1,max{a[i]}] 即可,对每一个 midmidmid,每个数 a[i]a[i]a[i] 只需要切 a[i]−1mid\frac{a[i]-1}{mid}mi...

小程序基础与实战案例

小程序开发工具与基础 小程序开发准备: 申请小程序账号( appid ) 下载并安装微信开发者工具 具体步骤如下: 先进入 微信公众平台 ,下拉页面,把鼠标悬浮在小程序图标上 然后点击 小程序开发文档 照着里面给的步骤,就可以申请到小程序账号了。 然后就可以下载 开发者工具 了 下载完打开后的界面就是这个样子 下面让我们来新建一个小程序开发项目: 在AppID输入自己刚刚注册的AppID就可以,或...

VMware centOS7 下通过minikube部署Kubernetes

1、环境准备: VMware CentOS-7-x86_64 CPU:2*2core 内存:8G 宿主机和虚拟机需网络互通,虚拟机外网访问正常 Centos发行版版本查看:cat /etc/centos-release root用户操作 2、禁用swap分区 Kubernetes 1.8开始要求关闭系统的Swap,可暂时关闭或永久禁用, 使用 $ free -m 确认swap是否为开启状态 $ s...

逻辑回归与scikit-learn

欢迎关注本人的微信公众号AI_Engine LogisticRegression 算法原理 一句话概括:逻辑回归假设数据服从伯努利分布,通过极大化似然函数(损失函数)的方法,运用梯度下降或其他优化算法来求解参数,来达到将数据二分类的目的。 定义:逻辑回归(Logistic Regression)是一种用于解决二分类(0 or 1)问题的机器学习方法,用于估计某种事物的可能性(不是概率)。比如某用户...

指针OR数组?用他们来表达字符串又有何不同?

cocowy的编程之旅 在学习C语言的过程中我们经常可以看到或者听到这样一句话:数组其实等价于指针,例如: 在这里可以轻松的看出输出后他们的值相等,其实在计算机内存里面,p为本地变量,有着他自己的作用域。而指针变量q保存着这个数组的首地址,通过*号指向这个地址保存的变量值。 然而我们再看一个例子: 这个时候计算机报错,这是为什么呢? 其实原因很简单,指针说指向的这个字符串的地址是位于计算机代码段地...

猜你喜欢

广度搜索

广度搜索的基本使用方法 广度搜索不同于深度搜索,是一种一步一步进行的过程,每一个点只记录一遍。需要用到队列记录每一步可以走到的位置,找到目标位置输出步数即可。 用到的知识:结构体、队列 如图 首先我们需要定义一个结构体来存储每个遍历到的点和步数 广搜不会用到递归,所以可以直接在主函数里写,这里需要定义一个结构体队列 初始化队列并将起始点入列 遍历 完整代码...

NIO Socket 编程实现tcp通信入门(二)

1、NIO简介 NIO面向通道和缓冲区进行工作,数据总是从通道读取到缓冲区中,或者从缓冲区写入到通道中。可以双向传输数据,是同步非阻塞式IO。NIO还引入了选择器机制,从而实现了一个选择器监听多个底层通道,减少了线程并发数。用NIO实现socket的Tcp通信需要掌握下面三个知识点: Buffer 缓冲区 Channel 通道 Selector 选择器   2、java.nio.Buff...

[字节码系列]ObjectWeb ASM构建Method Monitor

      在前面的篇章中,我们看到Java Instrutment的强大能力,本篇,我们将介绍如何使用ObjectWeb ASM的字节码增强能力构建Method Monitor       1.什么是ObjectWeb ASM      ObjectWeb ...

Core Location 电子围栏:入门

原文:Geofencing with Core Location: Getting Started 作者:Andy Pereira 译者:kmyhy 更新说明:Andy Pereira 将本教程升级至 Xcode 9.3 和 Swift 4.1。 Geofencing 会在设备进入/离开指定的电子围栏时通知应用程序。它可以让你写出一些很酷的应用程序,当你从家里出来时触发通知,或者在附近出现最爱的商...

Android 圆角边框RoundRect原理

绘制圆角矩形的方法 该方法来自Canvas类,rect代表矩形,rx和ry分别代表形成圆角所需要的椭圆的x和y轴半径,那么rx和ry究竟如何形成圆角呢? 形成圆角的原理 矩形的四个圆角是分别生成的,以左上角的圆角为例: 首先通过rect绘制出矩形,然后以矩形的左上角定点为起点,分别向x和y轴平移rx和ry, 得到的点为中心,以rx和ry为x和y轴的半径绘制椭圆,椭圆的坐上半部分圆弧就是圆角了。如下...