chatclientsystem.java

基于java的图ou形化的聊天器

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * 客户端功能实现类
 * @author ij
 *
 */
public class ChatClientSystem {

	ObjectOutputStream oos;
	/**
	 * 客户端初始化
	 * @param serverip
	 * @param port
	 */
	public void initCCS(byte[] serverip,int port){
		
		InetAddress netadds;
		CCReceiveThread ccr;
		ChatMessage cm = null;		
			try {
				netadds = InetAddress.getByAddress(serverip);
				Socket s = new Socket(netadds, port);
				oos = new ObjectOutputStream(s.getOutputStream());
				ccr = new CCReceiveThread(s);
				ccr.start();
//				ccr.join();
			} catch (UnknownHostException e) {
				
				e.printStackTrace();
			} catch (IOException e) {
				CCSInterface.jtavision.setText("无法连接到客户端，请确认客户端后，重新运行本程序");
				e.printStackTrace();
			} 			
	}
	
	/**
	 * 发送信息
	 * @param current
	 * @param cliname
	 * @param ip
	 * @param content
	 */
	public void send(String current,String cliname,byte[] ip,String content) {
		InetAddress netadds;
		try {
			netadds = InetAddress.getByAddress(ip);
			ChatMessage cm = null;
			cm = new ChatMessage();
			cm.setCurrent(current);
			cm.setCliname(cliname);
			cm.setNetadds(netadds);
			cm.setContent(content);
			
			oos.write(1);
			oos.writeObject(cm);
			oos.flush();
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}		
	}
}