简单Socket编程

服务器端:

package com.wuonghu.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 Service { public static void main(String[] args) { ServerSocket server = null; try { server = new ServerSocket(8888); } catch (Exception e) { System.out.println("不能监听:" + e.toString()); } Socket socket = null; try { socket = server.accept(); BufferedReader br = new BufferedReader(new InputStreamReader( socket.getInputStream())); PrintWriter pw = new PrintWriter(socket.getOutputStream()); pw.println("服务器端发来的信息"); pw.flush(); pw.close(); br.close(); } catch (IOException e) { System.out.println("出错:" + e.toString()); } finally { try { if (socket != null) { socket.close(); server.close(); } } catch (IOException e) { e.printStackTrace(); } } } }

客户端:

package com.wuonghu.socket; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; public class User { public static void main(String[] args) { Socket socket = null; try { socket = new Socket("127.0.0.1", 8888); BufferedReader pw = new BufferedReader(new InputStreamReader( socket.getInputStream())); System.out.println(pw.readLine()); pw.close(); } catch (Exception e) { e.printStackTrace(); } finally { try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }