合并代码

src/com/bjsxt/test02/Server.java

@@ -11,7 +11,7 @@ import java.net.Socket;
 public class Server {	// 服务器
 
 	public static void main(String[] args) throws IOException {
-		System.out.println("服务器启动...");
+		System.out.println("服务器已启动...");
 		/* 利用套接字, 指定服务器的端口号 */
 		ServerSocket ss = new ServerSocket(8888);
 		/* 服务器这面, 应是一个接收的动作, accept() 阻塞方法 */

src/com/bjsxt/test05/Client.java

@@ -15,37 +15,36 @@ public class Client {	//
 	public static void main(String[] args) {
 		System.out.println("客户端启动...");
 		/* 创建套接字 */
-		Socket s = null;
-		Scanner sc = null;
-		String name = null;
-		OutputStream os = null;
-		ObjectOutputStream oos = null;
-		InputStream is = null;
-		DataInputStream dis = null;
+		Socket socket = null;
+		Scanner scanner = null;
+		OutputStream outputStream = null;
+		ObjectOutputStream objectOutputStream = null;
+		InputStream inputStream = null;
+		DataInputStream dataInputStream = null;
 		try {
-			s = new Socket(InetAddress.getByName("192.168.3.3"), 8888);
+			socket = new Socket(InetAddress.getByName("192.168.3.3"), 8888);
 			/* 1.键盘录入账号和密码 */
-			sc = new Scanner(System.in);
+			scanner = new Scanner(System.in);
 			System.out.println("账号:");
-			name = sc.next();
+			String name = scanner.next();
 			System.out.println("密码:");
-			String password = sc.next();
+			String password = scanner.next();
 			
 			/* 2.将上面的账号密码封装成一个对象 */
 			User user = new User(name, password);
 			
 			/* 3.将这个对象发送给服务器端 
 			 * 我们感受到的应用层向外传送数据是:输出流 */
-			os = s.getOutputStream();
-			oos = new ObjectOutputStream(os);
+			outputStream = socket.getOutputStream();
+			objectOutputStream = new ObjectOutputStream(outputStream);
 			
-			oos.writeObject(user);
+			objectOutputStream.writeObject(user);
 			
 			/* 客户端要接收服务器的反馈信息 */
-			s.shutdownOutput();
-			is = s.getInputStream();
-			dis = new DataInputStream(is);
-			boolean flag = dis.readBoolean();
+			socket.shutdownOutput();
+			inputStream = socket.getInputStream();
+			dataInputStream = new DataInputStream(inputStream);
+			boolean flag = dataInputStream.readBoolean();
 			if(flag) {
 				System.out.println("登陆成功!");
 			} else {
@@ -58,32 +57,32 @@ public class Client {	//
 		} finally {
 			/* 关闭流, 关闭Socket资源 */
 			try {
-				dis.close();
+				dataInputStream.close();
 			} catch (IOException e) {
 				e.printStackTrace();
 			}
 			try {
-				is.close();
+				inputStream.close();
 			} catch (IOException e) {
 				e.printStackTrace();
 			}
 			try {
-				oos.close();
+				objectOutputStream.close();
 			} catch (IOException e) {
 				e.printStackTrace();
 			}
 			try {
-				os.close();
+				outputStream.close();
 			} catch (IOException e) {
 				e.printStackTrace();
 			}
 			try {
-				sc.close();
+				scanner.close();
 			} catch (Exception e) {
 				e.printStackTrace();
 			}
 			try {
-				s.close();
+				socket.close();
 			} catch (IOException e) {
 				e.printStackTrace();
 			}

src/com/txp/SocketTest01/Client.java

 package com.txp.SocketTest01;
 
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
+
 public class Client {
-	public void sendMsg(int i){
+	
+	public static Socket socket ;
+	public InetAddress ia;
+	
+	public static void main(String[] args) throws UnknownHostException  {
+		int i = 0;
+		while(true){
+			i ++ ;
+			sendMsg(i);
+			try {
+				Thread.sleep(1000);
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+			}
+		}
+	}
+	
+	public static void sendMsg(int i){
 		try{
-			System.out.println("发送第"+i+"次");
-			MySocketConnection.getSocket().getOutputStream().write(("发送第"+i+"次").getBytes("gbk"));
+			getSocket().getOutputStream().write(("发送第"+i+"次").getBytes("gbk"));
+			System.out.println("已连接服务器, 心跳第"+i+"次");
 		}catch(Exception e){
-			System.out.println("服务器已断开, 正在重连...");
-			MySocketConnection.socket = null;
+			System.out.println("服务器连接已断开, 正在重连...");
+			socket = null;
 			sendMsg(i);
 			}
 		}
+	
+	public static Socket getSocket(){
+		try {
+			if(socket == null){
+				return new Socket(InetAddress.getByName("192.168.3.3"),8888);
+				}else{
+					return socket;
+				}
+			} catch (UnknownHostException e) {
+			} catch (IOException e) {
+		}
+		return null;
 	}
+}

src/com/txp/SocketTest01/Main.java

-package com.txp.SocketTest01;
-
-import java.net.UnknownHostException;
-
-public class Main {
-	public static void main(String[] args) throws UnknownHostException  {
-		Client c = new Client();
-		int i = 0;
-		while(true){
-			i ++ ;
-			c.sendMsg(i);
-			try {
-				Thread.sleep(1000);
-			} catch (InterruptedException e) {
-				e.printStackTrace();
-			}
-		}
-	}
-}

src/com/txp/SocketTest01/MySocketConnection.java

-package com.txp.SocketTest01;
-
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.Socket;
-import java.net.UnknownHostException;
-
-public class MySocketConnection {
-
-	public static Socket socket ;
-	public InetAddress ia;
-	
-	public static Socket getSocket(){
-		try {
-			if(socket == null){
-				return new Socket(InetAddress.getByName("192.168.3.3"),8888);
-				}else{
-					return socket;
-				}
-			} catch (UnknownHostException e) {
-			} catch (IOException e) {
-		}
-		return null;
-	}
-}

src/com/txp/SocketTest01/Server.java

+package com.txp.SocketTest01;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class Server {	// 服务器 
+
+	public static void main(String[] args) {
+		System.out.println("服务器启动...");
+		/* 利用套接字, 指定服务器的端口号 */
+		ServerSocket ss = null;
+		Socket s = null;
+		try {
+			ss = new ServerSocket(8888);
+			/* 服务器这面, 应是一个接收的动作, accept() 阻塞方法 */
+			while(true) {
+				s = ss.accept();
+				new ServerThread(s).start();
+				if(null == s.getInetAddress()) {
+					System.out.println("客户端已断开");
+				}
+				System.out.println("客户端已连接, IP地址是:"+s.getInetAddress());
+			}
+		} catch (IOException e) {
+			e.printStackTrace();
+		} finally {
+			/* 关闭流 */
+			try {
+				ss.close();
+			} catch (IOException e) {
+				e.printStackTrace();
+			}
+			try {
+				s.close();
+			} catch (IOException e) {
+				e.printStackTrace();
+			}
+		}
+	}
+}

src/com/txp/SocketTest01/ServerThread.java

+package com.txp.SocketTest01;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.Socket;
+
+
+public class ServerThread extends Thread {
+	
+	Socket s = null;
+	public ServerThread(Socket s) {
+		this.s=s;
+	}
+	
+	InputStream is = null;
+	DataInputStream dis = null;
+	OutputStream os = null;
+	DataOutputStream dos = null;
+	
+	@Override
+	public void run() {
+		try {
+			/* 应用层还是用输入的IO流接收数据 
+			 * 接收客户端过来的对象 */
+			is = s.getInputStream();
+			dis = new DataInputStream(is);
+			
+			/* 服务器端像客户端反馈结果 */
+			s.shutdownInput();
+			os = s.getOutputStream();
+			dos = new DataOutputStream(os);
+		} catch (IOException e) {
+			e.printStackTrace();
+		} catch (Exception e) {
+			System.out.println("客户端未连接");
+			e.printStackTrace();
+		} finally {
+			/* 关闭流 */
+			try {
+				dos.close();
+			} catch (IOException e) {
+				e.printStackTrace();
+			}
+			try {
+				os.close();
+			} catch (IOException e) {
+				e.printStackTrace();
+			}
+			try {
+				dis.close();
+			} catch (IOException e) {
+				e.printStackTrace();
+			}
+			try {
+				is.close();
+			} catch (IOException e) {
+				e.printStackTrace();
+			}
+		} 
+	}
+}