multidispatcher.java

一个仿qq的程序源码 一个用纯java开发的

package qianqian.p2pchat.control;

import java.net.MulticastSocket;
import java.net.InetAddress;
import java.net.DatagramPacket;

import qianqian.p2pchat.constant.Const;

public class MultiDispatcher extends Dispatcher {
	private MulticastSocket multiSocket = null;
	private InetAddress inetAddress = null;
	private RecvThread recvThread = null;

	public void dispatchToServer(byte[] iBuf, int iSize, String iAddr)
			throws Exception {
	}

	private class RecvThread extends Thread {
		private MulticastSocket multiSocket = null;
		private Dispatcher dispatcher = null;

		public RecvThread(Dispatcher iDispatcher, MulticastSocket iSock) {
			multiSocket = iSock;
			dispatcher = iDispatcher;
		}

		public void run() {
			byte inBuf[] = new byte[Const.RecvBufSize];
			DatagramPacket recvPack = new DatagramPacket(inBuf,
					Const.RecvBufSize);
			try {
				while (!isInterrupted()) {
					multiSocket.receive(recvPack);
					dispatcher.dataReceived(recvPack.getData(), recvPack
							.getLength(), recvPack.getAddress()
							.getHostAddress());
				}
			} catch (Exception ex) {
			}
			closeDispatcher();
		}
	}

	// 广播数据
	protected void dispatchToAll(byte iBuf[], int iSize) throws Exception {
		DatagramPacket disptchPack = new DatagramPacket(iBuf, iSize,
				inetAddress, Const.MultiPort);
		multiSocket.send(disptchPack);
	}

	public MultiDispatcher() throws Exception {
		inetAddress = InetAddress.getByName(Const.MultiIp);
		multiSocket = new MulticastSocket(Const.MultiPort);
		multiSocket.joinGroup(InetAddress.getByName(Const.MultiIp));
		recvThread = new RecvThread(this, multiSocket);
		recvThread.start();
	}
	
	public void closeDispatcher() {
		if(recvThread != null) {
			recvThread.interrupt();
			recvThread = null;
		}
		if(multiSocket != null && !multiSocket.isClosed()) {
			multiSocket.close();
			multiSocket = null;
		}
	}
}