udpreceiver.java

来自「实现简单的通信功能,让自己掌握socket编程」· Java 代码 · 共 36 行

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;
	}
}