JAVA实现简单聊天室（一）–服务器的实现-永久免费的源码丞旭猿

public class ChatServer {
/**
*  在指定端口上启动一个服务器
* @param port: 服务器所以的端口
*/
public void setUpServer(int port){
try{
// 建立绑定在指定端口上的服务器对象
ServerSocket server=new ServerSocket(port);
System.out.println(" 服务器创建成功！ "+port);
// 让服务器进入等待状态 : 阻塞状态
Socket client=server.accept();
// 从连结对象上得到输入输出流对象
OutputStream out=client.getOutputStream();
InputStream ins=client.getInputStream();
String s=" 你好 , 欢迎来 javaKe.com\r\n";
byte[] data=s.getBytes();// 取得组成这个字符串的字节
out.write(data); // 用输出对象发送数据！
out.flush();// 强制输出
client.close();// 半闭与客户机的连结
}catch(Exception ef){
ef.printStackTrace();
}
}
// 主函数
public static void main(String[] args) {
ChatServer cs=new ChatServer();
cs.setUpServer(9090);
}
}

// 客户机与服务器连接的方法
	public void processChat(java.net.Socket client) {
		// 根据客户机实例化输入输出流
		try {
			OutputStream os = client.getOutputStream();
			InputStream is = client.getInputStream();
			String s = "你好，欢迎来到服务器！*";
			// 输入输出是根据字节 ，将字符串转换为字节
			byte[] b = s.getBytes();
			os.write(b);
			os.flush();// 强制输出
			// 用读取字符串的方法，从输入流中读取一个字符串
			String inputS = readString(is);
			while (!inputS.equals("bye")) {
				
				b = s.getBytes();// 取得组成这个字符串的字节
				os.write(b);// 用输出对象发送
				os.flush();// 强制输出
				inputS = readString(is);// 读取客户机的下一个句子

			}
			s = "您好，欢迎再来！\r\n";
			b = s.getBytes();
			os.write(b);
			os.flush();
			client.close();// 关闭与客户机的连接

		} catch (Exception ef) {
			ef.printStackTrace();
		}

	}

	/**
	 * 读取字符串的方法 从输入流对象中读取字节，拼成一个字符串返回 如果读到的一个字节值为13，则认为以前的是一个字符串
	 * 
	 * @param ins
	 *            输入流对象
	 * @return 从流上（客户机发来的）读到的字符串
	 * 
	 * 
	 */
	public String readString(InputStream is) throws Exception {
		// 创建一个字符串缓冲区
		StringBuffer sb = new StringBuffer();
		char c = (char)is.read();
		while (c != *) {
			// 遇到一个换行，就是一句话
			sb.append(c);
			int i = is.read();// 读取客户机发来的一个字节
			c = (char) i;// 将输入的字节转换为一个char
			

		}
		// 将读到的字节转换为字符串，并调用trim去掉尾部的空格，系统会默认添加的一定要加上trim方法
		
		String inputS = sb.toString().trim();
		System.out.println("inputS "+inputS );
		return inputS;
	}

实例化BufferedReader对象
BufferedReader br = new BufferedReader(new InputStreamReader(
					socket.getInputStream()));
String msg = br.readLine();
while (!msg.equals("bye")) {
				
				
msg = br.readLine();
//读取下一句
 }