server.java

简单功能的聊天室。用object流实现的。只能公聊。上线人命列表

package server;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.*;
import java.util.ArrayList;
import java.util.Vector;

import client.client;

import com.sun.java_cup.internal.production;

import vo.clientObjectVO;

public class server extends Thread {

	private ServerSocket serversocket = null;

	// private Socket soc = null;
	private Thread acceptSoc;
	String test="";
public static	Vector<String> userList = new Vector();
	

	// 存放所有登陆的用户

	ArrayList clients = new ArrayList();;

	/**
	 * @param args
	 */
	// 创建服务器
	private void createServer() {
		try {
			serversocket = new ServerSocket(8153);
			// 创建存放所有用户的列表
			System.out.println("server: start..");
			runServer();

		} catch (Exception e) {
			System.out.println(e.toString());
		}
	}

	private void runServer() {
		try {

			clientLess ls = new clientLess();

			ls.start();

		} catch (Exception e) {
			System.out.println(e.toString());
		}

	}

	// 客户监听线程
	protected class clientLess extends Thread {
		public void run() {
			try {
				while (true) {

					Socket us = serversocket.accept();
					System.out.println("server:已连接");
					String str = us.getInetAddress().getHostName();
					ChatHandler t = new ChatHandler(us, str);

					clients.add(t);
					t.start();
					
				}
			} catch (Exception e) {
				System.out.println("class clientLess:" + e.toString());
			}
		}
	}

	private boolean sendClient(String note) {
		return true;

	}

	// 发送给所有客户端列出所有登陆的用户

	// 验证用户登陆
	private boolean userCheck(String name) {
		return true;
	}

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		server s1 = new server();
		s1.createServer();
		
	}

	protected class ChatHandler extends Thread {
		Socket clientSock;

		ObjectOutputStream out; // 与服务器通信的对象流

		ObjectInputStream in;// 与服务器通信的对象流

		String cname;

		vo.serverObjectVO voServer;

		String cluser = "";
		

		public ChatHandler(Socket sock, String cname) throws IOException {

			this.cname = cname;
			clientSock = sock;
			
		}


		public void run() {
			try {
				out = new ObjectOutputStream(new BufferedOutputStream(clientSock
						.getOutputStream()));
				in = new ObjectInputStream(new BufferedInputStream(clientSock
						.getInputStream()));

				while (true) {
					
					vo.clientObjectVO voClient = (vo.clientObjectVO) in
							.readObject();
					// userList.add(voClient.getUserName());

					if (voClient.getMake().equals("chat")) {

						vo.serverObjectVO svo = new vo.serverObjectVO();
						svo.setMake("chat");
						svo.setChatNote(voClient.getChatNote());
						svo.setClienName(cluser);

						toAllClient(svo);
					} else {
						if (voClient.getMake().equals("login")) {
							cluser = voClient.getUserName();
							userList.add(cluser);
						
							vo.serverObjectVO svo = new vo.serverObjectVO();
							svo.setMake("login");
							svo.setClienName(cluser);
						//	svo.setOnlyName(userList);
							svo.setOnlyName(userList);
							test+= cluser+'\n';
							svo.setTeststr(test);
							toAllClient(svo);
					
						//	updateOnly(userList);
						
							
						}

					}

				}
			} catch (Exception e) {
				System.out.println("ChatHandler" + e.toString());

			}

		}




		public void sendAll(vo.serverObjectVO svo) {
		

			try {
				
				out.writeObject(svo);

				out.flush();
			} catch (Exception e) {
				System.out.println("sendAll()" + e.toString());
			}

		}
		private void toAllClient(vo.serverObjectVO svo) {
			for (int i = 0; i < clients.size(); i++) {
				ChatHandler c = (ChatHandler) clients.get(i);
				try {
					// c.svaeInfo();c.
					c.sendAll(svo);
				} catch (Exception e) {
					System.out.println(e.toString());
				}

				// c.sendAll();
			}

	}

			
		}

		
	


	}