simplebroadcastclient.java

来自「这是一个以JAVA编写的程序,本人还没有试过,是一个简单的温度控制系统」· Java 代码 · 共 67 行

package net.sf.dz.pnp.custom;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.DatagramSocket;

import org.freehold.jukebox.logger.LogChannel;
import org.freehold.jukebox.service.ServiceUnavailableException;
import net.sf.dz.pnp.MulticastClient;
import net.sf.dz.pnp.MulticastEvent;

/**
 * @author Copyright &copy; <a href="mailto:[e-mail]">Vadim Tkachenko</a> 2004
 * @version $Id: SimpleBroadcastClient.java,v 1.2 2004/06/28 20:35:49 vtt Exp $
 */
public class SimpleBroadcastClient extends DatagramClient {

    public static final LogChannel CH_SMC = new LogChannel("SimpleBroadcastClient");
    
    private int port = 5001;
    
    private DatagramSocket socket;
    
    public SimpleBroadcastClient() {
    
        super();
    }

    public SimpleBroadcastClient(int port) {
    
        super();
        
        this.port = port;
    }

    protected void startup() throws Throwable {
    
        try {
        
            socket = new DatagramSocket(port, null);
            socket.setBroadcast(true);
            
            complain(LOG_INFO, CH_SMC, "Listening on port " + port);
            
        } catch ( Throwable t ) {
        
            throw new ServiceUnavailableException("Can't listen on port " + port, t);
        }
    }

    protected void receive(DatagramPacket packet) throws IOException {
    
        socket.receive(packet);
    }
    
    protected void shutdown(Throwable cause) throws Throwable {
    
        socket.close();
    }
    
    public String toString() {
    
        return "SimpleBroadcastClient[" + port + "]";
    }
}