Java的Socket编程

问题：编写两个Java类，分别实现Scoket Client 和Scoket server 功能，有client传递一个串行化的值对象（如UserInfo）到Server端，服务器端将传递过来的对象属性打印输出到控制台。

 

UserInfo实现序列化：

package com.socket;

import java.io.Serializable;

public class UserInfo implements Serializable {

	private static final long serialVersionUID = 1L;

	private String username;
	private String password;

	public UserInfo() {
	}

	public UserInfo(String username, String password) {
		this.username = username;
		this.password = password;
	}

	public String getUsername() {
		return username;
	}

	public void setUsername(String username) {
		this.username = username;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}

}
package com.socket;

import java.io.*;
import java.net.*;

//客户端

public class Client {
	public static void main(String[] args) throws IOException {

		Socket echoSocket = null; // 客户端对服务器应用程序建立Socket连接

		OutputStream out = null;

		ObjectOutputStream writer = null; // 写对象

		// UserInfo对象
		UserInfo user = new UserInfo("song", "123");

		try {

			echoSocket = new Socket("127.0.0.1", 477);// 客户端得知道IP地址与端口号

			// 客户端写
			out = echoSocket.getOutputStream();// 如果为 true，则 println、printf 或
												// format 方法将刷新输出缓冲区

			// 写对象流
			writer = new ObjectOutputStream(out);

			// 写对象
			writer.writeObject(user);

		} catch (UnknownHostException e) {

			System.err.println("找不到地址: 127.0.0.1");
			System.exit(1);

		} catch (IOException e) {

			System.err.println("找不到127.0.0.1的链接");
			System.exit(1);

		} finally {
			// 关闭打开的流

			if (writer != null) {
				writer.close();
			}
			
			if (out != null) {
				out.close();
			}

			if (echoSocket != null) {
				echoSocket.close();
			}
		}
	}
}

 

package com.socket;

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;

//服务端
public class Server {

	public static void main(String[] args) throws IOException {

		InputStream in = null;

		ObjectInputStream read = null; // 读对象

		// 服务器应用程序对特定端口创建出ServerSocket
		ServerSocket serverSocket = null;

		try {

			serverSocket = new ServerSocket(477);// 创建绑定到特定端口的服务器套接字

		} catch (IOException e) {

			System.err.println("找不到端口： 400");
			System.exit(1);

		}

		Socket clientSocket = null;
		try {
			// 服务器创建出与客户端通信的新Socket
			// 服务器得到一个客户端
			clientSocket = serverSocket.accept();// 侦听并接受到此套接字的连接。此方法在进行连接之前一直阻塞。

			// 客户端读
			in = clientSocket.getInputStream();

			//读对象流
			read = new ObjectInputStream(in);

			// 读对象
			UserInfo user = (UserInfo) read.readObject();

			// 打印到控制台
			System.out.println("姓名" + "\t" + "密码");
			System.out.println(user.getUsername() + "\t" + user.getPassword());

		} catch (Exception e) {

			System.err.println("接收失败！");
			System.exit(1);

		} finally {

			// 关闭流要规范
			if (null != read) {
				read.close();
			}

			if (null != in) {
				in.close();
			}

			if (null != clientSocket) {
				clientSocket.close();
			}

			if (null != serverSocket) {
				serverSocket.close();
			}
		}
	}
}