本文讲解如何用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中的数据——打印——双方断开连接。