server.java

java实现的Socket通信程序

/**
 * 
 */
package component;
import java.io.*;
import java.net.*;
/**
 * @author Administrator
 *
 */
public class Server 
{
	private int port;   //构造方法
	public Server(int port)
	{
		this.port=port;
		start();
	}
	private String process(String line)
	{
		return line.toUpperCase();
	}
	private void start() //启动服务
	{
		try
		{
			ServerSocket mySocket=new ServerSocket(port); //创建套接字
			//显示连接信息
			System.out.println("服务器启动完成，监听端口在"+port+". ");
			System.out.println("正在等待客户端连接...");
			//挂起等待客户端连接请求
			Socket connection=mySocket.accept();
			//获取曲度客户端内容的数据流
			BufferedReader in =new BufferedReader(new InputStreamReader(connection.getInputStream()));
			PrintWriter out = new PrintWriter(connection.getOutputStream(),true);
			out.println("您好，服务器连接成功1");
			out.println("输入BYE断开服务器连接");
			boolean done = false;
			while(!done)
			{
				//读取客户端内容
				String line = in.readLine();
				if(line==null)
					done = true;
				else
				{
					//在服务器端显示从客户端接受的信息
					System.out.println("从客户端来的内容:"+line);
					//信息处理
					String message=process(line);
					//向客户端发送信息
					out.println("从服务器端口8000发出的内容:"+message);
					if(line.trim().equals("BYE"))
						done=true;
				}
				
			}
			connection.close();//关闭通信通道
		}
		catch (Exception e)
		{
			System.out.println(e);
		}
		
	}
}