java学习之路——基于TCP的Socket网络通信实例

第一部分：

 1.什么是socket

　　 所谓socket通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。
 2.重要的Socket API：

　　 java.net.Socket继承于java.lang.Object，有八个构造器，其方法并不多，下面介绍使用最频繁的三个方法，其它方法大家可以见JDK-1.3文档。

　　 . Accept方法用于产生"阻塞"，直到接受到一个连接，并且返回一个客户端的Socket对象实例。"阻塞"是一个术语，它使程序运行暂时"停留"在这个地方，直到一个会话产生，然后程序继续；通常"阻塞"是由循环产生的。

　　 . getInputStream方法获得网络连接输入，同时返回一个IutputStream对象实例，。

　　 . getOutputStream方法连接的另一端将得到输入，同时返回一个OutputStream对象实例。

　　 注意：其中getInputStream和getOutputStream方法均会产生一个IOException，它必须被捕获，因为它们返回的流对象，通常都会被另一个流对象使用。

第二部分：

如何开发一个Server-Client模型的程序

　　 开发原理：

　　 服务器，使用ServerSocket监听指定的端口，端口可以随意指定（由于1024以下的端口通常属于保留端口，在一些操作系统中不可以随意使用，所以建议使用大于1024的端口），等待客户连接请求，客户连接后，会话产生；在完成会话后，关闭连接。

　　 客户端，使用Socket对网络上某一个服务器的某一个端口发出连接请求，一旦连接成功，打开会话；会话完成后，关闭Socket。客户端不需要指定打开的端口，通常临时的、动态的分配一个1024以上的端口。

代码示例：

1：建立主服务器类

package com.lcq.network; /** * * 类名：MainServer * 功能：建立主服务器类，接受客户端的信息并显示，与客户端进行交互 * 时间： * 作者：lcq * 版本： * */ import java.net.ServerSocket; import java.net.Socket; public class MainServer { /** * @param args * @throws Exception */ public static void main(String[] args) throws Exception { ServerSocket serverSocket = new ServerSocket(4000); //调用socket的accept()方法侦听并接受到此套接字的连接，此方法在连接传入之前一直阻塞。 while(true){ Socket socket = serverSocket.accept(); new ServerInputThread(socket).start(); new SeverOutputThread(socket).start(); } } }

2：建立主服务器的两个线程类（包括向客户端输出和输入的线程）

package com.lcq.network; /** * * 类名：ServerInputThread * 功能：建立主服务器的输入线程类，接收客户端的信息后打印出来 * 时间： * 作者：lcq * 版本： * */ import java.io.IOException; import java.io.InputStream; import java.net.Socket; public class ServerInputThread extends Thread{ private Socket socket; public ServerInputThread(Socket socket){ this.socket = socket; } @Override public void run() { while(true){ try { //建立输入流 InputStream is = socket.getInputStream(); byte[] by = new byte[1024]; //将输入流里的字节读到字节数组里，并返回读的字节数 int length = is.read(by); //将字节数组里的length个字节转换为字符串 String str = new String(by,0,length); //打印出字符串 System.out.println(str); } catch (IOException e) { e.printStackTrace(); } } } }

 

package com.lcq.network; /** * * 类名：SeverOutputThread * 功能：建立主服务器的输出线程类， 向客户端传送信息 * 时间： * 作者：lcq * 版本： * */ import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.Socket; public class SeverOutputThread extends Thread{ Socket socket = new Socket(); public SeverOutputThread(Socket socket){ this.socket = socket; } @Override public void run() { while(true){ try { //从socket中得到输出流对象 OutputStream os = socket.getOutputStream(); BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); String line = br.readLine(); os.write(line.getBytes()); } catch (IOException e) { e.printStackTrace(); } } } }

3：建立主客户端类

package com.lcq.network; /** * * 类名：MainClient * 功能：建立主客户端类，接受服务器端的信息并显示，与服务器端进行交互 * 时间： * 作者：lcq * 版本： * */ import java.net.Socket; public class MainClient { /** * @param args * @throws Exception */ public static void main(String[] args) throws Exception { Socket socket = new Socket("127.0.0.1", 4000); new ClientInputThread(socket).start(); new ClientOutputThread(socket).start(); } }

4:建立主客户端的两个线程（包括向服务器端输入和输出）

package com.lcq.network; /** * * 类名：ClientInputThread * 功能：建立主客户端的输入线程类，接收服务器端的信息后打印出来 * 时间： * 作者：lcq * 版本： * */ import java.io.IOException; import java.io.InputStream; import java.net.Socket; public class ClientInputThread extends Thread{ private Socket socket; public ClientInputThread(Socket socket){ this.socket = socket; } @Override public void run() { while(true){ try { //建立输入流 InputStream is = socket.getInputStream(); byte[] by = new byte[1024]; //将输入流里的字节读到字节数组里，并返回读的字节数 int length = is.read(by); //将字节数组里的length个字节转换为字符串 String str = new String(by,0,length); //打印出字符串 System.out.println(str); } catch (IOException e) { e.printStackTrace(); } } } }

 

package com.lcq.network; /** * * 类名：ClientOutputThread * 功能：建立主客户端的输出线程类， 向服务器端传送信息 * 时间： * 作者：lcq * 版本： * */ import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.Socket; public class ClientOutputThread extends Thread{ Socket socket = new Socket(); public ClientOutputThread(Socket socket){ this.socket = socket; } @Override public void run() { while(true){ try { OutputStream os = socket.getOutputStream(); BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); String line = br.readLine(); os.write(line.getBytes()); } catch (IOException e) { e.printStackTrace(); } } } }

程序运行的效果是：像聊天器一样可以在主客户端和主服务器端相互通信。