multicastserverthread.java

来自「高等院校计算机应用技术硕士研究生课程,高级计算机网络程序设计实例子代码,mult」· Java 代码 · 共 55 行

import java.io.*;
import java.net.*;
import java.util.*;

public class MulticastServerThread extends Thread
{

    private long FIVE_SECONDS = 5000;
    private boolean moreQuotes = true;
    DatagramSocket socket = null;
    private static BufferedReader in;

    public MulticastServerThread(DatagramSocket socket) throws IOException 
    {
        super();
        this.socket=socket;
    }


    public void run() 
    {
        while (moreQuotes) 
        {
            try 
            {
                byte[] buf = new byte[256];

                String dString = null;
                if (in == null)
                    dString = new Date().toString();
                else
                    dString = getNextQuote();
                buf = dString.getBytes();

                InetAddress group = InetAddress.getByName("230.0.0.1");
                DatagramPacket packet = new DatagramPacket(buf, buf.length, group, 1111);
                socket.send(packet);


		try 
		{
		    sleep((long)(Math.random() * FIVE_SECONDS));
		} catch (InterruptedException e) { }
            } 
            catch (IOException e) 
            {
                e.printStackTrace();
		moreQuotes = false;
            }
        }
	socket.close();
    }
    
}