serverreceive.java

基于UDP的可靠邮件系统

package org.hwmhere.email.server;

import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.ObjectInputStream;


import org.hwmhere.email.impl.Email;
import org.hwmhere.udp.receive.*;

class ServerReceive {

	ServerReceive() {

	};

	public static void main(String args[]) throws Exception {

		final String receivePath = "D:/test/receive/";

		File dFile = new File(receivePath);
		if (!dFile.exists()) {
			dFile.mkdirs();
		}

		while (true) {

			//接收数据
			RUDPReceiver receiver = new RUDPReceiver(6790);

			receiver.reveive();

			byte[] receivedData = receiver.getReceiveData();

			
			//读出对象
			ByteArrayInputStream arrayInputStream = new ByteArrayInputStream(
					receivedData);

			ObjectInputStream inputStream = new ObjectInputStream(
					arrayInputStream);

			Email email = (Email) inputStream.readObject();

			 System.out.println("to:"+email.getMessage());
			 
			//保存邮件
			String name = email.getName();			
			
			String userPath = receivePath +email.getRecipients().iterator().next()+ "/";
			
			File uFile = new File(userPath);
			if (!uFile.exists()) {
				uFile.mkdirs();
			}
			
			File receivedMailFile = new File(userPath+email.getSender().toString()+email.hashCode() + ".email");
			FileOutputStream fileOutputStream = new FileOutputStream(
					receivedMailFile);
			fileOutputStream.write(receivedData);
			fileOutputStream.flush();
			fileOutputStream.close();
			

			System.out.println("接收到数据长度:" + receivedData.length);

		}

	}
}