timreceiver.java

java实现的一个简单组播通信聊天工具

package jgroup;

import org.jgroups.tests.perf.Receiver;
import org.jgroups.tests.perf.Transport;
import org.jgroups.util.Util;

public class TimReceiver implements Receiver {
	private TimTransport transport = null;

	public static void main(String[] args) {
		TimReceiver t = new TimReceiver();
		try {
			int sendMsgCount = 5000;
			int msgSize = 1000;
			t.start();
			t.sendMessages(sendMsgCount, msgSize);
			System.out.println(t.transport.dumpStats());
			System.out.println("########## Begin to recv...");
			Thread.currentThread().join();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (t != null) {
				t.stop();
			}
		}
	}

	public void start() throws Exception {
		transport = new TimTransport();
		transport.create(null);
		transport.setReceiver(this);
		transport.start();
	}

	public void stop() {
		if (transport != null) {
			transport.stop();
			transport.destroy();
		}
	}

	private int count = 0;

	public void receive(Object sender, byte[] data) {
		System.out.print(".");
		//System.out.println(new String(data));
		if (++count == 5000) {
			System.out.println("\r\nRECV DONE.");
			
			System.exit(0);
		}
		
	}

	private void sendMessages(int count, int msgSize) throws Exception {
		byte[] buf = new byte[msgSize];
		for (int k = 0; k < msgSize; k++)
			buf[k] = 'T';
		System.out.println("-- sending " + count + " "
				+ Util.printBytes(msgSize) + " messages");
		for (int i = 0; i < count; i++) {
			transport.send(null, buf);
		}
		System.out.println("######### send complete");
	}
}