groupworks.java

一个采用Java Socket编程实现的QQ软件

package client;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;

public class Groupworks implements Runnable{
    InetAddress address;
    int port;
    MulticastSocket multsocket = null;
    GrouptalkGUI grouptalk = null;
    String localname;
    public Groupworks(InetAddress address,int port,String localname) {
        this.address = address;     
        this.port = port;
        this.localname = localname;
        try {
            multsocket=new MulticastSocket(port);
            multsocket.setTimeToLive(1);  
            multsocket.joinGroup(address);  
        } catch (IOException ex) {
            ex.printStackTrace();
        }                          
    }
    
    public void sentGroupdata(String message){
        DatagramPacket packet=null;
        byte data[]=message.getBytes(); 
        packet=new DatagramPacket(data,data.length,address,port);
        try {
            multsocket.send(packet);  
        } catch (IOException ex) {
            ex.printStackTrace();
        } 
    }
    public void run() {
        while(true)   
        {byte data[]=new byte[8192];
         DatagramPacket packet=null;
         packet=new DatagramPacket(data,data.length,address,port);  //待接收的数据包。
         try { multsocket.receive(packet);
         String message=new String(packet.getData(),0,packet.getLength());
         System.out.println("message:"+message);
         String[] messages = message.split(":");        
         if(grouptalk == null){  
             String[] online = {"1111","22222"};
             String[] downline = {"3333","3333"};
             grouptalk = new GrouptalkGUI(online,this,localname);
         }
         grouptalk.displaymessage( messages[0],messages[1]);
         System.out.println("message:"+message);
         }
         catch(Exception e) {}
        }
    }
    
}