udpreceiver.java

实现简单的通信功能,让自己掌握socket编程

package com.tarena.chat1;

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

public class UDPReceiver implements IReceiver {
	public MulticastSocket ms;
	public UDPReceiver(MulticastSocket ms) {
		this.ms = ms;
	}
	public IMessage receive() {
		byte[] msg = new byte[1800];
		DatagramPacket data = new DatagramPacket(
				msg, msg.length);
		try {
			ms.receive(data);
		} catch (IOException e) {
			e.printStackTrace();
		}
		IMessage message=null;
		try {
			message = Helper.deserial(data.getData());
		} catch (Exception e) {
			e.printStackTrace();
			message=new Message();
		}
		String address=data.getAddress().getHostAddress();
		message.setAddress(address);
		return message;
	}
}