patchuserinfothread.java

基于JSP的网络聊天室系统,功能明了易懂

package chat;

import java.net.*;
import java.lang.*;
import java.io.*;
import java.awt.*;

public class PatchUserInfoThread extends Thread{
  DatagramSocket sendsocket;
  DatagramPacket sendpacket;

  public PatchUserInfoThread() {
  }
  public void patchUserInfo()
  {
    for(int i=0;i<WholeChatRoomInfo.rooms.size();i++)
    {
      RoomInfo rInfo = new RoomInfo();
      rInfo = (RoomInfo) WholeChatRoomInfo.rooms.elementAt(i);
      String pac = rInfo.ToUserListNetpac();
      //ChatFrame.textArea1.append(pac);
      UserTempInfo usertemp=new UserTempInfo();  //要发送的人的信息
      for(int j=0;j<rInfo.user.size();j++)
      {
        usertemp=(UserTempInfo)rInfo.user.elementAt(j);
        try {
          byte Array[] = new byte[255];
          Array = pac.getBytes();
          //ChatFrame.textArea1.append(pac);
          sendsocket = new DatagramSocket(); //初始化
          sendpacket = new DatagramPacket(Array, Array.length, //InetAddress.getByName("127.0.0.1"),3550);
                                          usertemp.IP, usertemp.port);
          //receivepacket.getAddress(),receivepacket.getPort());
          sendsocket.send(sendpacket);
        }
        catch (Exception e) {

        }
      }
    }
     }
     public void run()
     {
       while(true)
       {
         patchUserInfo();
         try{
           this.sleep(WholeChatRoomInfo.refreshtime*10000);
         }catch(Exception e)
         {
         }
       }
     }

}