upload.java

该HttpProxy用于从Applet或Swing界面中访问Ejb和服务端的JavaBean。

package com.nari.pmos.arch.servlet;

import java.io.IOException;
import java.io.InputStream;

import javax.naming.NamingException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.nari.pmos.arch.bean.PubInfo;
import com.nari.pmos.arch.common.FormatToUnicode;
import com.nari.pmos.arch.common.UploadFile;
import com.nari.pmos.arch.multipart.FilePart;
import com.nari.pmos.arch.multipart.MultipartParser;
import com.nari.pmos.arch.multipart.ParamPart;
import com.nari.pmos.arch.multipart.Part;

public class Upload extends HttpServlet {

	private static final long serialVersionUID = 1L;

	public void doGet(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
		doPost(request, response);
	}

	public void doPost(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {

		MultipartParser parser = new MultipartParser(request);

		String participant_id = null;
		String pub_info = null;
		String topic = null;
		String participant_id_list = null;

		// http请求解析出来的参数和文件部分
		Part part;
		while ((part = parser.readNextPart()) != null) {
			// 参数部分和文件部分，在MultipartParser做了封装处理
			if (part.isParam()) {
				ParamPart paramPart = (ParamPart) part;
				String value = paramPart.getStringValue();

				System.out.println(paramPart.getName() + ": " + value);

				if ("PARTICIPANT_ID".contains(paramPart.getName())) {
					participant_id = value;
				}
				if ("PUB_INFO".contains(paramPart.getName())) {
					pub_info = FormatToUnicode.UnicodeToGB2312(value);
				}
				if ("TOPIC".contains(paramPart.getName())) {
					topic = FormatToUnicode.UnicodeToGB2312(value);
				}
				if ("PARTICIPANT_LIST".contains(paramPart.getName())) {
					participant_id_list = value;
				}
				if (value.equals("NO_ATTACHMENT")) {
					PubInfo pubInfo = new PubInfo(Integer
							.parseInt(participant_id), pub_info, topic,
							participant_id_list);
					try {
						new UploadFile().uploadInfo(pubInfo);
					} catch (NamingException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			} else if (part.isFile()) {

				FilePart filePart = (FilePart) part;
				String fileName = filePart.getFileName();
				if (fileName != null) {
					InputStream is = filePart.getInputStream();
					PubInfo pubInfo = new PubInfo(Integer
							.parseInt(participant_id), pub_info, topic,
							participant_id_list);
					try {
						new UploadFile().uploadFile(pubInfo, new String(
								fileName.getBytes("ISO-8859-1"), "GB2312"), is);
					} catch (NamingException e) {
						e.printStackTrace();
					}

				}
			}

		}
	}

}