package com.lanber.socket;import java.io.DataInputStream;　　import java.io.DataOutputStream;　　import java.io.IOException;　　import java.net.ServerSocket;　　import java.net.Socket;public class ServerDemo {/**　　* 注意：Socket的发送与接收是需要同步进行的，即客户端发送一条信息，服务器必需先接收这条信息，　　* 而后才可以向客户端发送信息，否则将会有运行时出错。　　* @param args　　*/　public static void main(String[] args) {　　    ServerSocket ss = null;　　    try {　　        ss = new ServerSocket(8888);　　    //服务器接收到客户端的数据后，创建与此客户端对话的Socket　　    Socket socket = ss.accept();　　        //用于向客户端发送数据的输出流　　        DataOutputStream dos = new  DataOutputStream(socket.getOutputStream());　　        //用于接收客户端发来的数据的输入流　　        DataInputStream dis = new DataInputStream(socket.getInputStream());　　        System.out.println("服务器接收到客户端的连接请求：" + dis.readUTF());　　        //服务器向客户端发送连接成功确认信息　　        dos.writeUTF("接受连接请求，连接成功!");　　        //不需要继续使用此连接时，关闭连接　　        socket.close();　　        ss.close();　　    } catch (IOException e) {　　    　　e.printStackTrace();　　    }　　  }}  

package com.lanber.socket;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.IOException;import java.io.OutputStream;import java.net.Socket;import java.net.UnknownHostException;public class ClientDemo {/**　　* @param args　　*/　　public static void main(String[] args) {　　Socket socket = null;　　try {　　socket = new Socket("localhost",8888);　　//获取输出流，用于客户端向服务器端发送数据　　DataOutputStream dos = new DataOutputStream(socket.getOutputStream());　　//获取输入流，用于接收服务器端发送来的数据　　DataInputStream dis = new DataInputStream(socket.getInputStream());　　//客户端向服务器端发送数据　　dos.writeUTF("我是客户端，请求连接!");　　//打印出从服务器端接收到的数据　　System.out.println(dis.readUTF());　　//不需要继续使用此连接时，记得关闭哦　　socket.close();　　} catch (UnknownHostException e) {　　　　e.printStackTrace();　　} catch (IOException e) {　　　　e.printStackTrace();　　}　}
}