javaSocket简单的实例

实例原处&＃xff1a;http://www.cnblogs.com/zhoudi/p/6025552.html

一、搭建服务器端

a)、创建ServerSocket对象绑定监听端口。

b)、通过accept()方法监听客户端的请求。

c)、建立连接后&＃xff0c;通过输入输出流读取客户端发送的请求信息。

d)、通过输出流向客户端发送请求信息。

e)、关闭相关资源。

package socket;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 SocketService {//搭建服务器端public static void main(String[] args) throws IOException{SocketService socketService &＃61; new SocketService();//1、a)创建一个服务器端Socket&＃xff0c;即SocketService socketService.oneServer();}public void oneServer(){try{ServerSocket server&＃61;null;try{server&＃61;new ServerSocket(5209);//b)指定绑定的端口&＃xff0c;并监听此端口。System.out.println("服务器启动成功");//创建一个ServerSocket在端口5209监听客户请求}catch(Exception e) {System.out.println("没有启动监听&＃xff1a;"&＃43;e);//出错&＃xff0c;打印出错信息}Socket socket&＃61;null;try{socket&＃61;server.accept();//2、调用accept()方法开始监听&＃xff0c;等待客户端的连接 //使用accept()阻塞等待客户请求&＃xff0c;有客户//请求到来则产生一个Socket对象&＃xff0c;并继续执行}catch(Exception e) {System.out.println("Error."&＃43;e);//出错&＃xff0c;打印出错信息}//3、获取输入流&＃xff0c;并读取客户端信息 String line;BufferedReader in&＃61;new BufferedReader(new InputStreamReader(socket.getInputStream()));//由Socket对象得到输入流&＃xff0c;并构造相应的BufferedReader对象PrintWriter writer&＃61;new PrintWriter(socket.getOutputStream());//由Socket对象得到输出流&＃xff0c;并构造PrintWriter对象BufferedReader br&＃61;new BufferedReader(new InputStreamReader(System.in));//由系统标准输入设备构造BufferedReader对象System.out.println("Client:"&＃43;in.readLine());//在标准输出上打印从客户端读入的字符串line&＃61;br.readLine();//从标准输入读入一字符串//4、获取输出流&＃xff0c;响应客户端的请求 while(!line.equals("end")){//如果该字符串为 "bye"&＃xff0c;则停止循环writer.println(line);//向客户端输出该字符串writer.flush();//刷新输出流&＃xff0c;使Client马上收到该字符串System.out.println("Server:"&＃43;line);//在系统标准输出上打印读入的字符串System.out.println("Client:"&＃43;in.readLine());//从Client读入一字符串&＃xff0c;并打印到标准输出上line&＃61;br.readLine();//从系统标准输入读入一字符串} //继续循环//5、关闭资源 writer.close(); //关闭Socket输出流in.close(); //关闭Socket输入流socket.close(); //关闭Socketserver.close(); //关闭ServerSocket}catch(Exception e) {//出错&＃xff0c;打印出错信息System.out.println("Error."&＃43;e);}}
}

二、搭建客户器端

a)、创建Socket对象&＃xff0c;指明需要连接的服务器的地址和端口。

b)、建立连接后&＃xff0c;通过输出流向服务器发送请求信息。

c)、通过输入流获取服务器的响应信息。

d)、关闭响应资源

package 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 SocketClient {// 搭建客户端public static void main(String[] args) throws IOException {try {// 1、创建客户端Socket&＃xff0c;指定服务器地址和端口// Socket socket&＃61;new Socket("127.0.0.1",5200);Socket socket &＃61; new Socket("192.168.1.115", 5209);System.out.println("客户端启动成功");// 2、获取输出流&＃xff0c;向服务器端发送信息// 向本机的52000端口发出客户请求BufferedReader br &＃61; new BufferedReader(new InputStreamReader(System.in));// 由系统标准输入设备构造BufferedReader对象PrintWriter write &＃61; new PrintWriter(socket.getOutputStream());// 由Socket对象得到输出流&＃xff0c;并构造PrintWriter对象//3、获取输入流&＃xff0c;并读取服务器端的响应信息 BufferedReader in &＃61; new BufferedReader(new InputStreamReader(socket.getInputStream()));// 由Socket对象得到输入流&＃xff0c;并构造相应的BufferedReader对象String readline;readline &＃61; br.readLine(); // 从系统标准输入读入一字符串while (!readline.equals("end")) {// 若从标准输入读入的字符串为 "end"则停止循环write.println(readline);// 将从系统标准输入读入的字符串输出到Serverwrite.flush();// 刷新输出流&＃xff0c;使Server马上收到该字符串System.out.println("Client:" &＃43; readline);// 在系统标准输出上打印读入的字符串System.out.println("Server:" &＃43; in.readLine());// 从Server读入一字符串&＃xff0c;并打印到标准输出上readline &＃61; br.readLine(); // 从系统标准输入读入一字符串} // 继续循环//4、关闭资源 write.close(); // 关闭Socket输出流in.close(); // 关闭Socket输入流socket.close(); // 关闭Socket} catch (Exception e) {System.out.println("can not listen to:" &＃43; e);// 出错&＃xff0c;打印出错信息}}
}

先启动服务器端&＃xff0c;再启动客户端&＃xff08;顺序不能乱&＃xff09;&＃xff0c;ip地址换成自己的ip地址