本文讲解如何用java实现网络通信,是一个非常简单的例子,我比较喜欢能够立马看到结果,所以先上代码再讲解具体细节。

服务端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    // 搭建服务器端
    public static void main(String[] args) throws IOException {
        Server server = new Server();
        //创建一个服务器,即Server
        server.oneServer();
    }

    public void oneServer() {
        try {
            ServerSocket server = null;
            server = new ServerSocket(5209);
            System.out.println("服务器启动成功");
            System.out.println("等待客户端连接");
            // 指定绑定的端口,并监听此端口。
            
            Socket socket = server.accept();
            System.out.println("监听到客户端的连接");
            System.out.println("连接成功");
            //调用accept()方法开始监听端口,等待客户端的连接
            
            
            String line;
            //存储对方传过来的数据
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            // 从socket对象中取出对方传过来的数据

             PrintWriter writer=new PrintWriter(socket.getOutputStream());
            // 向socket总写如要传给对方的数据

            while ((line = in.readLine()) != null) {
                 writer.println(line+" deal by servet");
                // 向客户端输出该字符串
                 writer.flush();
                // 刷新输出流,使Client马上收到该字符串
                System.out.println("Client:" + line);
                // 从Client读入一字符串,并打印到标准输出上
            } // 继续循环

            // 关闭资源
            writer.close(); //关闭Socket输出流
            in.close(); // 关闭Socket输入流
            socket.close(); // 关闭Socket
            server.close(); // 关闭server
        } catch (Exception e) {// 出错,打印出错信息
            System.out.println("Error." + e);
        }
    }
}

客户端

import java.net.Socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.URL;

public class Client {
    // 搭建客户端
    public static void main(String[] args) throws IOException {
        try {
            // 创建客户端Socket,指定服务器地址和端口
            // Socket socket=new Socket("127.0.0.1",5200);
            System.out.println("客户端启动成功");
            Socket socket = new Socket("192.168.69.183", 5209);
            System.out.println("向服务端5209端口请求成功");
            
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            // 由系统标准输入设备读入数据,该数据通过writer写到对方的socket中
            
            PrintWriter write = new PrintWriter(socket.getOutputStream());
            // 向socket总写入要传给对方的数据
            
           BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            // 从socket对象中取出对方传过来的数据
            
            String readline;
            readline = br.readLine(); // 从系统标准输入读入一字符串
            while (!readline.equals("end")) {
                // 若从标准输入读入的字符串为 "end"则停止循环
                write.println(readline);
                // 将从系统标准输入读入的字符串输出到对方的socket中
                write.flush();
                
                //打印出对方传过来的数据
                System.out.println("Server:" + in.readLine());
                // 从Server读入一字符串,并打印到标准输出上
                readline = br.readLine(); // 从系统标准输入读入一字符串
            } // 继续循环
            //关闭资源 
            write.close(); // 关闭Socket输出流
           // in.close(); // 关闭Socket输入流
            socket.close(); // 关闭Socket
            br.close();
        } catch (Exception e) {
            System.out.println("can not listen to:" + e);// 出错,打印出错信息
        }
    }

}

  这里我们要实现的功能是客户端从键盘输入一个字符串,发送给服务端,服务端处理(原字符串后加上“deal by servet”)完成后返回给客户端。我用的是eclipse,最好开两个eclipse一个跑客户端一个跑服务端。先开服务端,再开客户端(顺序不能错),客户端输入hello,服务端返回hello deal by server:

  

  看到成果了那么可以分析一下整个通信过程。

  先放一个socket通信模型:

  

  

  三部分:建立连接,开始通信,断开连接

  建立连接:我们稍微思考一下就可以知道建立连接的过程要先存在服务端server,然后客户端client才能找,所以要先启动服务端。可能我们认为服务端或者说服务器是一个很神秘的东西,其实不是,看我们这个例子中服务端的代码:

  

 

  new一个服务器,但是这个服务器new出来之后什么都没做,我们需要调用他里面的方法让这个服务器可以运行。所以写了一个oneServer方法,服务器对象调用这个方法开始运行。

  那么服务器运行的时候都干了什么呢?看上面的模型,服务器运行做三件事:连接,传送数据,断开。

  看oneServer中的代码,先是创建了一个ServerSocket的对象,这个对象有一个参数5209:

  

  ServerSocket是专门用来创建服务器对象的,其中的参数5209表示这个服务器可以通过5209端口被客户端连接,即5209端口与创建的这个ServerSocket对象绑定了。但是这个绑定只是在服务器与端口之间建立了一个通道,我们还要能够让服务器知道有数据从外面到了这个端口,并且因为端口不能存放数据所以需要一个socket来暂时存放数据。所以有了下面的监听:

  

 

  

   到这里,服务器已经启动并运行了,客户端可以连接了。

  这时候启动客户端,客户端通过socket连接到服务端,指定ip和端口号:

  

  客户端运行到这里表示与服务端的连接已经完成

  

  

  连接成功之后就是传送数据,客户端创建三个对象:

  

 

  br从键盘读入要传送的数据,write向socket写入要传给服务端的数据,in从socket对象中取出服务端返回的数据。

  服务端创建两个对象:

  

 

  write向socket写入要传回给客户端的数据,in从socket对象中取出客户端传来的数据。

   到这里数据传输的准备工作完成,接下来就是数据传输。

  客户端从键盘读入一个字符串(hello),通过br读入:

  

  

  

  

  然后客户端判断是否为end,不是end就继续。通过客户端的write,将readline中的内容写到对方(服务端)的socket中,同时使用write的flush方法通知服务端,让服务端立马知道有数据了:

  

 

  服务端监听到端口有数据之后,通过in接收客户端发过来的数据,并转成字符串,然后处理这个字符串(加上deal by server)并写到客户端的socket中,同时也调用writer的flush方法通知客户端

  

  运行到这里,服务端已经处理并返回了客户端发过来的数据,在客户端的控制台中可以看到返回的数据:

  

 

  服务端在自己的控制台中打印出客户端发过来的数据:

  

  

  整个传送流程结束,如果输入的字符串是end,那么就会跳出while循环,客户端服务端各自关闭资源:

  

  

  到这里,整个过程结束。

  再文字说明一下整个流程,服务器启动——服务器创建socket并监听——客户端启动——客户端创建socket连接服务端——连接完成——客户端输入数据并写到服务端的socket传送给服务端——服务端接收到客户端传来的数据——对数据进行处理——处理完毕放到客户端的socket中——客户端拿取自己socket中的数据——打印——双方断开连接。

 

 

 

  

 

  

版权声明:本文为GoForMyDream原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/GoForMyDream/p/8710162.html