chipchat.java

ChipChat1.0——源代码以及程序用到的资源（程序入口主文件为ChipChat.java）（Eclipse3.1.2设计） UML建模图——为Rose建模图

import java.io.*;
import java.net.*;
import java.util.Vector;
import java.awt.event.*;

import javax.swing.*;

import java.awt.*;

public class ChipChat extends JFrame
{
	JPanel contentPane;
	JTextField txtInput = new JTextField();
	JButton btnSend = new JButton();
	JButton TCPconnect = new JButton();
	List lstMsg = new List();
	List lstFriend = new List();
	JLabel name = new JLabel();
	JLabel Top = new JLabel();
	JLabel version = new JLabel();
	
	UserInfo [] userinfo = new UserInfo[90];//新建UserInfo数组类保存用户信息
	
	ServerSocket listen_socket;

	
	public final static int DEFAULT_PORT = 8321;
	public final static int CATCH_PORT = 7321;
	public final static int TCP_PORT = 6321;
	
	
	DatagramSocket socket = null;
	InetAddress group; 
	InetAddress groupC; 
	DatagramPacket packet;     
	

	DatagramSocket s = null;
	MulticastSocket socketr;
	MulticastSocket socketC;
	Socket Csocket;
	
	
	CCListener cclisten;
	
	String nickname = new String("11111111111");
	
	
	
	public ChipChat()//构造函数
	{
		while(nickname.length()>9||nickname.length()==0)
		{
			nickname  = JOptionPane.showInputDialog(null,"请输入昵称","登陆",3);
			if(nickname.length()>9)
				JOptionPane.showMessageDialog(null,"昵称长度需要小于10","非法昵称",JOptionPane.ERROR_MESSAGE);
			if(nickname.length()==0)
				JOptionPane.showMessageDialog(null,"昵称长度需要等于0","非法昵称",JOptionPane.ERROR_MESSAGE);
		}
		
		enableEvents(AWTEvent.WINDOW_EVENT_MASK);
		
		ChipChat_JoinGroup();//首先初始化端口,并向已经在线的CC程序发送本机IP以及请求回应.并对相应的组播组端口进行监听
		
		try
		{
			jbInit();//初始化FRAME窗口,并对相应的控件添加事件响应
		}catch(Exception e)
		{
			e.printStackTrace();
		}
		
		this.setLocation(300,200);
		
		ChipChat_Listener();//对组内公共聊天的组播组端口进行监听
		
		TCP_Listener();//对点对点TCP协议端口进行监听

	}
	
	
	
	protected void processWindowEvent(WindowEvent e)
	{
		super.processWindowEvent(e);
		if(e.getID()==WindowEvent.WINDOW_CLOSING)
		{
			
			try
			{
				//退出时发送退出登陆的信息的组播数据包,其包的内容的起始位为判断位,"D"表示该包为告知下线的信息包
				byte [] notice = new String("D"+nickname+InetAddress.getLocalHost().getHostAddress()+nickname.length()).getBytes();
				packet = new DatagramPacket(notice,notice.length,groupC,CATCH_PORT);
				socket.send(packet);
			}catch(IOException ee)
			{
				ee.printStackTrace();
			}
			socket.close();
			System.exit(0);
		}
	}

	
	public void jbInit()//初始化应用程序窗口
	{
		version.setText("V1.2");
		version.setBounds(new Rectangle(420,5,50,30));
		txtInput.setText("");
		txtInput.setBounds(new Rectangle(80,140,140,30));
		txtInput.addKeyListener(new KeyAdapter (){//添加事件按键事件监听,当文本框中按下"回车"时则发送文本框消息
			public void keyPressed(KeyEvent ek){
				if(ek.getKeyChar() == '\n')
					try {
						byte[] dataS = (nickname+":"+txtInput.getText()).getBytes();
						packet = new DatagramPacket(dataS,dataS.length, group, DEFAULT_PORT); 
						socket.send(packet);        
						txtInput.setText("");
						}
						catch(Exception e1) 
						{
						System.out.println("Error: " + e1);                 
						}
            }

		});
		

		contentPane = (JPanel)this.getContentPane();
		contentPane.setLayout(null);
		name = new JLabel(nickname+":");
		name.setBounds(new Rectangle(20,140,50,30));
		this.setSize(480,210);
		this.setTitle("ChipChat");
		
		
		Icon sentIcon = new ImageIcon("image\\BTSend.gif");
		Icon BG = new ImageIcon("image\\BackGround1.gif");
		Icon TCPIcon = new ImageIcon("image\\BTConnect.gif");
		
		Top.setIcon(BG);
		Top.setBounds(0,0,480,183);
		
		
		btnSend.setIcon(sentIcon);
		btnSend.setBounds(230,141,89,32);
		btnSend.setBackground(Color.WHITE);
		btnSend.addActionListener(new java.awt.event.ActionListener()
				{
					public void actionPerformed(ActionEvent e)
					{
						btnSend_actionPerformed(e);
					}
				});
		TCPconnect.setIcon(TCPIcon);
		TCPconnect.setBounds(new Rectangle(355,140,89,32));
		TCPconnect.addActionListener(new ActionListener()
				{
					public void actionPerformed(ActionEvent e)
					{
						TCPconnect_actionPerformed(e);
					}
				});
		lstMsg.setBounds(new Rectangle(20,35,300,100));
		lstFriend.setBounds(new Rectangle(340,35,120,100));
		lstFriend.addActionListener(new ActionListener()
				{
					public void actionPerformed(ActionEvent e)
					{
						lstFriend_actionPerformed(e);
					}
				});
		contentPane.add(txtInput,null);
		contentPane.add(btnSend,null);
		contentPane.add(lstMsg,null);
		contentPane.add(name,null);
		contentPane.add(version,null);
		contentPane.add(lstFriend,null);
		contentPane.add(TCPconnect,null);
		contentPane.setBackground(Color.WHITE);
		contentPane.add(Top,null);
		this.setResizable(false);
	}
	
	
	public static void main(String [] arg)//主函数,程序入口
	{
		ChipChat cc = new ChipChat();
		cc.setVisible(true);
	}
	
	
	public void processMsg(String str)//该方法为将字符串str显示到对话列表框中
	{
		this.lstMsg.add(str);
		this.lstMsg.select(lstMsg.getItemCount()-1);
	}
	
	
	
	public void processFriend(String str)//该方法为将字符串str显示到登陆信息列表框中
	{
		this.lstFriend.add(str);
	}
	
	

	
	
	
	public void ChipChat_JoinGroup()//初始化UDP协议端口信息          
	{
	try {                         
	        group = InetAddress.getByName("238.0.0.0"); //初始化广播聊天信息组播组
	        groupC = InetAddress.getByName("239.0.0.0");//初始化登陆信息组播组  
	        socket = new DatagramSocket(); 
	        byte [] notify = new byte[100];
	        byte [] nametag = new byte[10];
	        nametag = nickname.getBytes();
	        //发送一个登陆信息给已经登陆的用户,通知他们本程序上线.包的数据结构为:判断位+用户名+IP地址+用户名长度
	        notify =new String("C"+nickname+InetAddress.getLocalHost().getHostAddress()+nickname.length()).getBytes();
	        //int dd = InetAddress.getLocalHost().getHostAddress().length();
	        packet = new DatagramPacket(notify,notify.length,groupC,CATCH_PORT);
	        socket.send(packet);
	        socketC = new MulticastSocket(CATCH_PORT);
	        socketC.joinGroup(groupC);
	        CATCHER catcher = new CATCHER(socketC,this,nickname,userinfo);
	        Check_in LOGIN = new Check_in(this,userinfo);
	}
	    catch (Exception e1) {
			System.out.println("Error: " + e1);              
	    }
	}
	
	
	void lstFriend_actionPerformed(ActionEvent e)//双击登陆列表框内容时触发的事件为连通列表框中的IP,建立TCP通信
	{
		Socket socket;
		int s = this.lstFriend.getSelectedIndex();
		String address = userinfo[s].getIP();//用address记录对方IP地址
		try
		{
			socket = new Socket(address,TCP_PORT);//建立连接
			TCP_Frame TT = new TCP_Frame(socket,userinfo[s].getName());//打开TCP会话程序
			TT.setVisible(true);
		}catch(IOException elf)
		{
			elf.printStackTrace();
		}
	}
	
	
	void TCPconnect_actionPerformed(ActionEvent e)//连接按钮事件监听
	{
		Socket socketT;
		String NN = null;
		int s = this.lstFriend.getSelectedIndex();
		try
		{
			NN = userinfo[s].getName();
		}catch(Exception nu)
		{
			JOptionPane.showMessageDialog(null,"请从按钮上方选择想要连接的地址","空目标地址",JOptionPane.ERROR_MESSAGE);
		}
		try
		{
			//对所选择的登陆信息列表框中的内容建立TCP连接

			String address = userinfo[s].getIP();//this.lstFriend.getSelectedItem().substring(2);
			socketT = new Socket(address,TCP_PORT);
			
			TCP_Frame TT = new TCP_Frame(socketT,userinfo[s].getName());
			TT.setVisible(true);

		}catch(IOException es)
		{
			
			JOptionPane.showMessageDialog(null,"该用户已不在线","用户下线",JOptionPane.ERROR_MESSAGE);
			try
			{
				byte [] notice = new String("D"+NN+InetAddress.getLocalHost().getHostAddress()+NN.length()).getBytes();
				packet = new DatagramPacket(notice,notice.length,groupC,CATCH_PORT);
				socket.send(packet);
			}catch(IOException ee)
			{
				ee.printStackTrace();
			}
			es.printStackTrace();
		}
	}
	
	
	
	
	void btnSend_actionPerformed(ActionEvent e)//群聊发送按钮触发
	{
		try {
			//发送一个数据包到组波组,数据包数据结构为:用户名+文本框中的内容
			byte[] dataS = (nickname+":"+txtInput.getText()).getBytes();
			packet = new DatagramPacket(dataS,dataS.length, group, DEFAULT_PORT); 
			socket.send(packet);        
			txtInput.setText("");//重设文本框的内容为空,方便下一次输入
			}
			catch(Exception e1) 
			{
			System.out.println("Error: " + e1);                 
			}
	}
	

	
	public void ChipChat_Listener()//群聊端口监听
	{
		
		try
		{

			socketr = new MulticastSocket(DEFAULT_PORT);

			socketr.joinGroup(group);
			 
		}catch(IOException e)
		{
			e.printStackTrace();
		}
		cclisten = new CCListener(socketr,this);
	}
	
	
	public void TCP_Listener()//对点对点TCP端口进行监听,一旦接到连接请求则马上打开一个TCP连接会话程序
	{
		TCPConnect tcp = new TCPConnect(TCP_PORT,this,nickname);
	}
}