java之网络通信

编程之家收集整理的这篇文章主要介绍了java之网络通信编程之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

一、网络通信简介

网络通信是指物理上位于计算机上的两个进程之间通过网络交换信息的过程。JAVA语言对网络通信提供了全面的支持
JAVA支持网络功能的四大类:

这里写图片描述

二、Java Socket应用—通信是这样练成的

1、InetAddress类

InetAddress 类用于标识网络上的硬件资源,实际上主要用来表示IP地址。它没有构造方法,无法通过new创建对象,只能通过静态方法获取对象:

// 一、获取本机的InetAdress实例
InetAddress address @H_419_19@= InetAddress.getLocalHost();@H_419_19@
// 二、根据主机名称获取InetAdress实例@H_419_19@
InetAddress address2 = InetAddress.getByName("hostName"@H_419_19@);
// 三、根据IP地址获取实例@H_419_19@
InetAddress address2 = InetAddress.getByName("ipAdress"@H_419_19@);

下面通过一个实例来熟悉InetAddress类的创建及常用方法的使用


import java.net@H_419_19@.InetAddress@H_419_19@;@H_419_19@
import java.net@H_419_19@.UnkNownHostException@H_419_19@;@H_419_19@
import java.util@H_419_19@.Arrays@H_419_19@;@H_419_19@

/*
 * InetAddress类
 */@H_419_19@
public class Test01 {

    public static void main(String[] args) throws UnkNownHostException {
        // 获取本机的InetAddress实例
        InetAddress address = InetAddress.getLocalHost@H_419_19@();@H_419_19@
        Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("计算名:"@H_419_19@ + address.getHostName@H_419_19@());@H_419_19@
        Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("IP地址:"@H_419_19@ + address.getHostAddress@H_419_19@());@H_419_19@
        byte[] bytes = address.getAddress@H_419_19@();// 获取字节数组形式的IP地址@H_419_19@
        Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("字节数组形式的IP:"@H_419_19@ + Arrays.toString@H_419_19@(bytes));@H_419_19@
        Sy@R_502_2407@.out@H_419_19@.println@H_419_19@(address);// 直接输出InetAddress对象@H_419_19@

        // 根据机器名获取InetAddress实例
        // InetAddress address2=InetAddress.getByName@H_419_19@("laurenyang"@H_419_19@);@H_419_19@
        InetAddress address2 = InetAddress.getByName@H_419_19@("1.1.1.10"@H_419_19@);@H_419_19@
        Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("计算名:"@H_419_19@ + address2.getHostName@H_419_19@());@H_419_19@
        Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("IP地址:"@H_419_19@ + address2.getHostAddress@H_419_19@());@H_419_19@
    }

}

运行结果:

这里写图片描述

2.URL类

url又称统一资源定位符,表示Internet上的某一资源的地址,由两部分组成:协议名称和资源名称,中间用冒号隔开,如http://www.baidu.com。在java.net包中,提供了URL类来表示URL。
下面也通过一个实例来熟悉URL对象的创建及常用方法的使用


import java.net@H_419_19@.MalformedURLException@H_419_19@;@H_419_19@
import java.net@H_419_19@.URL@H_419_19@;@H_419_19@

/*
 * URL常用方法
 */@H_419_19@
public class Test02 {
    public static void main(String[] args) {
        try {
            //创建一个URL实例
            URL imooc=new URL("http://www.imooc.com"@H_419_19@);@H_419_19@
            //?后面表示参数,#后面表示锚点@H_419_19@
            URL url=new URL(imooc,"/index.html?username=tom#test"@H_419_19@);@H_419_19@
            Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("协议:"@H_419_19@+url.getProtocol@H_419_19@());@H_419_19@
            Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("主机:"@H_419_19@+url.getHost@H_419_19@());@H_419_19@
            //如果未指定端口号,则使用认的端口号,此时getPort()方法返回值为-1@H_419_19@
            Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("端口:"@H_419_19@+url.getPort@H_419_19@());@H_419_19@
            Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("文件路径:"@H_419_19@+url.getPath@H_419_19@());@H_419_19@
            Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("文件名:"@H_419_19@+url.getFile@H_419_19@());@H_419_19@
            Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("相对路径:"@H_419_19@+url.getRef@H_419_19@());@H_419_19@
            Sy@R_502_2407@.out@H_419_19@.println@H_419_19@("查询字符串:"@H_419_19@+url.getQuery@H_419_19@());@H_419_19@
        } catch (MalformedURLException e) {
            e.printStackTrace@H_419_19@();@H_419_19@
        }
    }
}

运行结果:

这里写图片描述

下面的这个实例展示了如何使用URL读取网页内容


import@H_419_19@ java.io.BufferedReader;@H_419_19@
import@H_419_19@ java.io.IOException;@H_419_19@
import@H_419_19@ java.io.InputStream;@H_419_19@
import@H_419_19@ java.io.InputStreamReader;@H_419_19@
import@H_419_19@ java.net.MalformedURLException;@H_419_19@
import@H_419_19@ java.net.URL;@H_419_19@

/*
 * 使用URL读取网页内容
 */@H_419_19@
public@H_419_19@ class@H_419_19@ Test03@H_419_19@ {@H_419_19@
    public@H_419_19@ static@H_419_19@ void@H_419_19@ main(String[] args) {
        try@H_419_19@ {
            //创建一个URL实例@H_419_19@
            URL url = new@H_419_19@ URL("http://www.baidu.com"@H_419_19@);
            //通过URL的openStream方法获取URL对象所表示的资源的字节输入流@H_419_19@
            InputStream is@H_419_19@ = url.openStream();
            //将字节输入流转换为字符输入流@H_419_19@
            InputStreamReader isr = new@H_419_19@ InputStreamReader(is@H_419_19@,"utf-8"@H_419_19@);
            //为字符输入流添加缓冲@H_419_19@
            BufferedReader br = new@H_419_19@ BufferedReader(isr);
            String data = br.readLine();//读取数据@H_419_19@
            while@H_419_19@ (data != null@H_419_19@) {//循环读取数据@H_419_19@
                Sy@R_502_2407@.out.println(data);//输出数据@H_419_19@
                data = br.readLine();
            }
            br.close();
            isr.close();
            is@H_419_19@.close();
        } catch@H_419_19@ (MalformedURLException e) {
            e.printStackTrace();
        } catch@H_419_19@ (IOException e) {
            e.printStackTrace();
        }
    }
}

运行结果:

这里写图片描述

读取出来的是百度首页的源代码,我将其复制到一个文档中,这样看更加清楚,如下所示:

这里写图片描述

3.socket类

相关知识概述:
1、Socket通信是网络上运行的程序之间双向通信链路的终结点(IP地址和端口号组成了Socket),它是TCP和UDP的基础。
2、端口号的范围为0~65525,其中1024以下(0~1023)为系统保留,如果要自定义端口号要用1024以上的。
3、常见的应用层协议有下面几种:
HTTP 超文本传输协议
ftp 文件传输协议
smtp 简单邮件传输协议
telnet 远程登陆服务

Socket通信实现步骤
1.创建ServerSocket(服务器端)和Socket(客户端)
2.打开链接到Socket的输入/输出
3.按照协议对Socket进行读/写操作
4.关闭输入输出流、关闭Socket
模型图示如下:

这里写图片描述

通过Socket实现TCP编程

服务器端操作:

这里写图片描述

客户端操作:

这里写图片描述


首先,要把模拟服务器的程序(Server.java)启动起来,等待客户端的连接,再运行客户端程序(Client.java),与服务器建立连接后会得到服务器的响应,控制台会输入“服务器欢迎您”字样,同时客户端也将用户名和密码发送给了服务器,此时再切换到服务器控制台下面会显示用户名和密码。
控制台效果如下:

这里写图片描述

这里写图片描述

这里写图片描述

Server.java


import@H_419_19@ java.io.BufferedReader;@H_419_19@
import@H_419_19@ java.io.IOException;@H_419_19@
import@H_419_19@ java.io.InputStream;@H_419_19@
import@H_419_19@ java.io.InputStreamReader;@H_419_19@
import@H_419_19@ java.io.OutputStream;@H_419_19@
import@H_419_19@ java.io.PrintWriter;@H_419_19@
import@H_419_19@ java.net.InetAddress;@H_419_19@
import@H_419_19@ java.net.ServerSocket;@H_419_19@
import@H_419_19@ java.net.socket;@H_419_19@

/*
 * 基于TCP协议的Socket通信,实现用户登陆
 * 服务器端
 */@H_419_19@
public@H_419_19@ class@H_419_19@ Server@H_419_19@ {@H_419_19@
    public@H_419_19@ static@H_419_19@ void@H_419_19@ main(String[] args) {
        try@H_419_19@ {
            //1.创建一个服务器端Socket,即ServerSocket,指定绑定的端口,并监听此端口@H_419_19@
            ServerSocket serverSocket=new@H_419_19@ ServerSocket(8888@H_419_19@);

            //2.调用accept()方法开始监听,等待客户端的连接@H_419_19@
            Sy@R_502_2407@.out.println("***服务器即将启动,等待客户端的连接***"@H_419_19@);
            Socket socket=serverSocket.accept();//阻塞状态,侦听请求@H_419_19@

            //3.获取输入流,并读取客户端信息@H_419_19@
            InputStream is@H_419_19@ = socket.getInputStream();//字节输入流@H_419_19@
            InputStreamReader isr = new@H_419_19@ InputStreamReader(is@H_419_19@);//将字节流转换为字符流@H_419_19@
            BufferedReader br = new@H_419_19@ BufferedReader(isr);//为输入流添加缓冲@H_419_19@
            String info = null@H_419_19@;
            while@H_419_19@((info=br.readLine())!= null@H_419_19@){
                Sy@R_502_2407@.out.println("我是服务器,客户端说:"@H_419_19@+info);
            }
            socket.shutdowninput();//关闭输入流@H_419_19@

            //4.获取输出流,响应客户端的请求@H_419_19@
            OutputStream os = socket.getOutputStream();
            PrintWriter pw = new@H_419_19@ PrintWriter(os);//包装为打印流           @H_419_19@
            pw.write("欢迎您"@H_419_19@);
            pw.flush();//调用flush()方法将缓冲输出@H_419_19@

            //5.关闭资源@H_419_19@
            os.close();
            pw.close();
            br.close();
            isr.close();
            is@H_419_19@.close();
            socket.close();
            serverSocket.close();

        } catch@H_419_19@ (IOException e) {
            e.printStackTrace();
        }
    }
}

Client.java


import@H_419_19@ java.io.BufferedReader;@H_419_19@
import@H_419_19@ java.io.IOException;@H_419_19@
import@H_419_19@ java.io.InputStream;@H_419_19@
import@H_419_19@ java.io.InputStreamReader;@H_419_19@
import@H_419_19@ java.io.OutputStream;@H_419_19@
import@H_419_19@ java.io.PrintWriter;@H_419_19@
import@H_419_19@ java.net.socket;@H_419_19@
import@H_419_19@ java.net.UnkNownHostException;@H_419_19@

/*
 * 客户端
 */@H_419_19@
public@H_419_19@ class@H_419_19@ Client@H_419_19@ {@H_419_19@
    public@H_419_19@ static@H_419_19@ void@H_419_19@ main(String[] args) {
        try@H_419_19@ {
            //1.创建客户端Socket,指定服务器地址和端口@H_419_19@
            Socket socket=new@H_419_19@ Socket("localhost"@H_419_19@,8888@H_419_19@);

            //2.获取输出流,向服务器端发送信息@H_419_19@
            OutputStream os=socket.getOutputStream();//字节输出流@H_419_19@
            PrintWriter pw=new@H_419_19@ PrintWriter(os);//将输出流包装为打印流@H_419_19@
            pw.write("用户名:alice;密码:789"@H_419_19@);
            pw.flush();
            socket.shutdownOutput();//关闭输出流@H_419_19@

            //3.获取输入流,并读取服务器端的响应信息@H_419_19@
            InputStream is@H_419_19@=socket.getInputStream();
            BufferedReader br=new@H_419_19@ BufferedReader(new@H_419_19@ InputStreamReader(is@H_419_19@));
            String info=null@H_419_19@;
            while@H_419_19@((info=br.readLine())!=null@H_419_19@){
                Sy@R_502_2407@.out.println("我是客户端,服务器说:"@H_419_19@+info);
            }
            //4.关闭资源@H_419_19@
            br.close();
            is@H_419_19@.close();
            pw.close();
            os.close();
            socket.close();

        } catch@H_419_19@ (UnkNownHostException e) {
            e.printStackTrace();
        } catch@H_419_19@ (IOException e) {
            e.printStackTrace();
        }
    }
}

使用多线程实现多客户端的通信

应用多线程来实现服务器与多客户端之间的通信基本步骤:
1、服务器端创建ServerSocket,循环调用accept()等待客户端连接
2、客户端创建一个socket并请求和服务器端连接。
3、服务器端接受客户端请求,创建socket与该客户建立专线连接。
4、建立连接的两个socket在一个单独的线程上对话。
5、服务器端继续等待新的连接。

首先,创建一个ServerThread.java类来实现多线程,然后将上面的例子稍加修改一下
ServerThread.java


import@H_419_19@ java.io.BufferedReader;
import@H_419_19@ java.io.IOException;
import@H_419_19@ java.io.InputStream;
import@H_419_19@ java.io.InputStreamReader;
import@H_419_19@ java.io.OutputStream;
import@H_419_19@ java.io.PrintWriter;
import@H_419_19@ java.net.socket;

/*
 * 服务器线程处理类
 */@H_419_19@
public@H_419_19@ class@H_419_19@ ServerThread@H_419_19@ extends@H_419_19@ Thread@H_419_19@ {@H_419_19@
    // 和本线程相关的Socket@H_419_19@
    Socket socket = null@H_419_19@;

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

    //线程执行的操作,响应客户端的请求@H_419_19@
    public@H_419_19@ void@H_419_19@ run@H_419_19@(){
        InputStream is=null@H_419_19@;
        InputStreamReader isr=null@H_419_19@;
        BufferedReader br=null@H_419_19@;
        OutputStream os=null@H_419_19@;
        PrintWriter pw=null@H_419_19@;
        try@H_419_19@ {
            //获取输入流,并读取客户端信息@H_419_19@
            is = socket.getInputStream();
            isr = new@H_419_19@ InputStreamReader(is);
            br = new@H_419_19@ BufferedReader(isr);
            String info=null@H_419_19@;
            while@H_419_19@((info=br.readLine())!=null@H_419_19@){//循环读取客户端的信息@H_419_19@
                Sy@R_502_2407@.out.println("我是服务器,客户端说:"@H_419_19@+info);
            }
            socket.shutdowninput();//关闭输入流@H_419_19@
            //获取输出流,响应客户端的请求@H_419_19@
            os = socket.getOutputStream();
            pw = new@H_419_19@ PrintWriter(os);
            pw.write("欢迎您!"@H_419_19@);
            pw.flush();//调用flush()方法将缓冲输出@H_419_19@
        } catch@H_419_19@ (IOException e) {
            // TODO Auto-generated catch block@H_419_19@
            e.printStackTrace();
        }finally@H_419_19@{
            //关闭资源@H_419_19@
            try@H_419_19@ {
                if@H_419_19@(pw!=null@H_419_19@)
                    pw.close();
                if@H_419_19@(os!=null@H_419_19@)
                    os.close();
                if@H_419_19@(br!=null@H_419_19@)
                    br.close();
                if@H_419_19@(isr!=null@H_419_19@)
                    isr.close();
                if@H_419_19@(is!=null@H_419_19@)
                    is.close();
                if@H_419_19@(socket!=null@H_419_19@)
                    socket.close();
            } catch@H_419_19@ (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

Server.java


import@H_419_19@ java.io.BufferedReader;@H_419_19@
import@H_419_19@ java.io.IOException;@H_419_19@
import@H_419_19@ java.io.InputStream;@H_419_19@
import@H_419_19@ java.io.InputStreamReader;@H_419_19@
import@H_419_19@ java.io.OutputStream;@H_419_19@
import@H_419_19@ java.io.PrintWriter;@H_419_19@
import@H_419_19@ java.net.InetAddress;@H_419_19@
import@H_419_19@ java.net.ServerSocket;@H_419_19@
import@H_419_19@ java.net.socket;@H_419_19@

/*
 * 基于TCP协议的Socket通信,实现用户登陆
 * 服务器端
 */@H_419_19@
public@H_419_19@ class@H_419_19@ Server@H_419_19@ {@H_419_19@
    public@H_419_19@ static@H_419_19@ void@H_419_19@ main(String[] args) {
        try@H_419_19@ {
            //1.创建一个服务器端Socket,即ServerSocket,指定绑定的端口,并监听此端口@H_419_19@
            ServerSocket serverSocket=new@H_419_19@ ServerSocket(8888@H_419_19@);
            Socket socket=null@H_419_19@;
            //记录客户端的数量@H_419_19@
            int count=0@H_419_19@;
            Sy@R_502_2407@.out.println("***服务器即将启动,等待客户端的连接***"@H_419_19@);
            //循环监听等待客户端的连接@H_419_19@
            while@H_419_19@(true@H_419_19@){
                //调用accept()方法开始监听,等待客户端的连接@H_419_19@
                socket=serverSocket.accept();
                //创建一个新的线程@H_419_19@
                ServerThread serverThread=new@H_419_19@ ServerThread(socket);
                //启动线程@H_419_19@
                serverThread.start();

                count++;//统计客户端的数量@H_419_19@
                Sy@R_502_2407@.out.println("客户端的数量:"@H_419_19@+count);
                InetAddress address=socket.getInetAddress();
                Sy@R_502_2407@.out.println("当前客户端的IP:"@H_419_19@+address.getHostAddress());
            }
        } catch@H_419_19@ (IOException e) {
            e.printStackTrace();
        }
    }
}

控制台显示

这里写图片描述

Client.java


import@H_419_19@ java.io.BufferedReader;@H_419_19@
import@H_419_19@ java.io.IOException;@H_419_19@
import@H_419_19@ java.io.InputStream;@H_419_19@
import@H_419_19@ java.io.InputStreamReader;@H_419_19@
import@H_419_19@ java.io.OutputStream;@H_419_19@
import@H_419_19@ java.io.PrintWriter;@H_419_19@
import@H_419_19@ java.net.socket;@H_419_19@
import@H_419_19@ java.net.UnkNownHostException;@H_419_19@

/*
 * 客户端
 */@H_419_19@
public@H_419_19@ class@H_419_19@ Client@H_419_19@ {@H_419_19@
    public@H_419_19@ static@H_419_19@ void@H_419_19@ main(String[] args) {
        try@H_419_19@ {
            //1.创建客户端Socket,指定服务器地址和端口@H_419_19@
            Socket socket=new@H_419_19@ Socket("localhost"@H_419_19@,8888@H_419_19@);
            //2.获取输出流,向服务器端发送信息@H_419_19@
            OutputStream os=socket.getOutputStream();//字节输出流@H_419_19@
            PrintWriter pw=new@H_419_19@ PrintWriter(os);//将输出流包装为打印流@H_419_19@
            pw.write("用户名:alice;密码:789"@H_419_19@);
            pw.flush();
            pw.close();//不能关闭输出流,会导致socket也被关闭,在下面直接关闭socket就行,这样就会关闭输出流@H_419_19@
            socket.shutdownOutput();//关闭输出流@H_419_19@
            //3.获取输入流,并读取服务器端的响应信息@H_419_19@
            InputStream is@H_419_19@=socket.getInputStream();
            BufferedReader br=new@H_419_19@ BufferedReader(new@H_419_19@ InputStreamReader(is@H_419_19@));
            String info=null@H_419_19@;
            while@H_419_19@((info=br.readLine())!=null@H_419_19@){
                Sy@R_502_2407@.out.println("我是客户端,服务器说:"@H_419_19@+info);
            }
            //4.关闭资源@H_419_19@
            br.close();
            is@H_419_19@.close();
            pw.close();
            os.close();
            socket.close();
        } catch@H_419_19@ (UnkNownHostException e) {
            e.printStackTrace();
        } catch@H_419_19@ (IOException e) {
            e.printStackTrace();
        }
    }
}

控制台显示

这里写图片描述

客户端与服务器建立连接后,服务器会收到客户端发送过去的信息,如下:

这里写图片描述

为了模拟多用户同时连接服务器,将客户端程序的用户名和密码修改一下:

这里写图片描述

再次运行Client.java,切换到服务器控制台下:

这里写图片描述

因为是同一台主机,所以此处客户端IP地址是一样的,而实际生活中是不同的,要注意一下。

注意:

  1. 对于同一个socket,如果关闭输出流,则与该输出流关联的socket也会被关闭,所以一般不用关闭流,直接关闭socket即可。
  2. 进行TCP通信时,客户端向服务器传输数据,我们演示的以字符串的形式传输,而实际应用中一般都是以对象的形式进行传输的。如下图所示:

    这里写图片描述


    3.当用socket传输文件时,可以用输入输出流读取文件,再进行传输。

通过Socket实现UDP编程

一、UDP编程
UDP协议(用户数据报协议)是无连接的、不可靠的、无序的。
UDP协议以数据报作为数据传输载体。进行数据传输时,首先将要传输的数据定义成数据报(Datagram),在数据报中指明数据所要达到的Socket(主机地址和端口号),然后再将数据报发送出去。

二、相关操作类
DatagramPacket:表示数据报包
DatagramSocket:进行端到端通信的类

服务器端实现步骤:
1、创建DatagramSocket,指定端口号
2、创建DatagramPacket
3、接收客户端发送的数据信息
4、读取数据

客户端:
1、定义发送信息
2、创建DatagramPacket:包含将要发送信息
3、创建DatagramSocket
4、发送数据

下面通过实例进行演示:
UDPServer.java


import@H_419_19@ java.io.IOException;
import@H_419_19@ java.net.DatagramPacket;
import@H_419_19@ java.net.DatagramSocket;
import@H_419_19@ java.net.InetAddress;

/*
 * 服务器端,实现基于UDP的用户登陆
 */@H_419_19@
public@H_419_19@ class@H_419_19@ UDPServer@H_419_19@ {@H_419_19@
    public@H_419_19@ static@H_419_19@ void@H_419_19@ main@H_419_19@(String[] args) throws@H_419_19@ IOException {
        /*
         * 接收客户端发送的数据
         */@H_419_19@
        //1.创建服务器端DatagramSocket,指定端口@H_419_19@
        DatagramSocket socket=new@H_419_19@ DatagramSocket(8800@H_419_19@);
        //2.创建数据报,用于接收客户端发送的数据@H_419_19@
        byte@H_419_19@[] data =new@H_419_19@ byte@H_419_19@[1024@H_419_19@];//创建字节数组,指定接收的数据包的大小@H_419_19@
        DatagramPacket packet=new@H_419_19@ DatagramPacket(data,data.length);
        //3.接收客户端发送的数据@H_419_19@
        Sy@R_502_2407@.out.println("****服务器端已经启动,等待客户端发送数据****"@H_419_19@);
        socket.receive(packet);//此方法在接收到数据报之前会一直阻塞@H_419_19@
        //4.读取数据@H_419_19@
        String info=new@H_419_19@ String(data,0@H_419_19@,packet.getLength());
        Sy@R_502_2407@.out.println("我是服务器,客户端说:"@H_419_19@+info);

        /*
         * 向客户端响应数据
         */@H_419_19@
        //1.定义客户端的地址、端口号、数据@H_419_19@
        InetAddress address=packet.getAddress();
        int@H_419_19@ port=packet.getPort();
        byte@H_419_19@[] data2="欢迎您!"@H_419_19@.getBytes();
        //2.创建数据报,包含响应的数据信息@H_419_19@
        DatagramPacket packet2=new@H_419_19@ DatagramPacket(data2,data2.length,address,port);
        //3.响应客户端@H_419_19@
        socket.send(packet2);
        //4.关闭资源@H_419_19@
        socket.close();
    }
}

运行后控制台显示

这里写图片描述


UDPClient.java


import@H_419_19@ java.io.IOException;
import@H_419_19@ java.net.DatagramPacket;
import@H_419_19@ java.net.DatagramSocket;
import@H_419_19@ java.net.InetAddress;
import@H_419_19@ java.net.socketException;
import@H_419_19@ java.net.UnkNownHostException;

/*
 * 客户端
 */@H_419_19@
public@H_419_19@ class@H_419_19@ UDPClient@H_419_19@ {@H_419_19@
    public@H_419_19@ static@H_419_19@ void@H_419_19@ main@H_419_19@(String[] args) throws@H_419_19@ IOException {
        /*
         * 向服务器端发送数据
         */@H_419_19@
        //1.定义服务器的地址、端口号、数据@H_419_19@
        InetAddress address=InetAddress.getByName("localhost"@H_419_19@);
        int@H_419_19@ port=8800@H_419_19@;
        byte@H_419_19@[] data="用户名:admin;密码:123"@H_419_19@.getBytes();
        //2.创建数据报,包含发送的数据信息@H_419_19@
        DatagramPacket packet=new@H_419_19@ DatagramPacket(data,data.length,port);
        //3.创建DatagramSocket对象@H_419_19@
        DatagramSocket socket=new@H_419_19@ DatagramSocket();
        //4.向服务器端发送数据报@H_419_19@
        socket.send(packet);

        /*
         * 接收服务器端响应的数据
         */@H_419_19@
        //1.创建数据报,用于接收服务器端响应的数据@H_419_19@
        byte@H_419_19@[] data2=new@H_419_19@ byte@H_419_19@[1024@H_419_19@];
        DatagramPacket packet2=new@H_419_19@ DatagramPacket(data2,data2.length);
        //2.接收服务器响应的数据@H_419_19@
        socket.receive(packet2);
        //3.读取数据@H_419_19@
        String reply=new@H_419_19@ String(data2,packet2.getLength());
        Sy@R_502_2407@.out.println("我是客户端,服务器说:"@H_419_19@+reply);
        //4.关闭资源@H_419_19@
        socket.close();
    }
}

控制台显示

这里写图片描述

可见,客户端收到了服务器的响应,再切换到服务器控制台查看:

这里写图片描述

服务器也接收到了来自客户端的信息。
这里只是模拟了单个用户与服务器进行交互,其实基于UDP的Socket通信也可以像基于TCP那样,通过多线程实现多客户端同时访问服务器,在这里就不再演示了。

三、远程方法调用

远程方法调用(RMI,Remote Method Invocation),是允许运行在一个Java虚拟机的对象调用运行在另一个Java虚拟机上的对象的方法。 这两个虚拟机可以是运行在相同计算机上的不同进程中,也可以是运行在网络上的不同计算机中。
目前还未真正接触到这个,日后再深入研究。

总结

以上是编程之家为你收集整理的java之网络通信全部内容,希望文章能够帮你解决java之网络通信所遇到的程序开发问题。

如果觉得编程之家网站内容还不错,欢迎将编程之家网站推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您喜欢寻找一群志同道合、互帮互助的学习伙伴,可以点击下方链接加入:
编程之家官方1群
编程之家官方2群
编程之家官方3群
编程之家官方4群

相关文章

猜你在找的Java相关文章

java环境的配置及安装(图文)
Java如何实现二进制搜索?
如何在Java中交换对象数据?(代码实例)
Windows系统下使用Java代码操作Linux的方法介绍
java开发入门基础教程的分享
如何在SpringBoot中集成JWT鉴权(附代码)
Java向上转型和向下转型的使用介绍(附代码)
怎么使用JVM捕获Java异常?(附示例)
微信公众号搜索 “ 程序精选 ” ,选择关注!
微信公众号搜 "程序精选"关注