Android 获取并解析网络XML与数据上传

最近比较忙，没什么时间写博客，现在以后多补补吧，这次写的是安卓客户端上传和下载网络数据

原理很简单，使用JDBC读取数据库数据，并在网页输出XML文件；安卓客户端获取XML文件进行解析（这里使用的是PULL方式）

先看下后台和Android客户端代码的结构：

Web后台代码：

1、Model

package com.homework.schoolnews;

public class Schoolnews {
	private int id;  
	private String title;
	private String content;    //内容
	private String shareDate;    //分享时间
	private String pictureuri; //图片路径
	private String shareperson;//分享人
	
	public Schoolnews(int id, String title,String content, String shareDate,
			String pictureuri, String shareperson) {
		super();
		this.id = id;

		this.title = title;
		this.content = content;
		this.shareDate = shareDate;
		this.pictureuri = pictureuri;
		this.shareperson = shareperson;
	}
	public Schoolnews() {
		// TODO Auto-generated constructor stub
	}
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	public String getContent() {
		return content;
	}
	public void setContent(String content) {
		this.content = content;
	}
	public String getShareDate() {
		return shareDate;
	}
	public void setShareDate(String shareDate) {
		this.shareDate = shareDate;
	}
	public String getPictureuri() {
		return pictureuri;
	}
	public void setPictureuri(String pictureuri) {
		this.pictureuri = pictureuri;
	}
	public String getShareperson() {
		return shareperson;
	}
	public void setShareperson(String shareperson) {
		this.shareperson = shareperson;
	}
	
	

}

2、JDBC

package myservice;

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class JDBCService {
	

	private java.sql.Connection connection=null;
	private java.sql.Statement statement=null;
	private PreparedStatement preparedStatement=null;
	private ResultSet resultSet=null;
	private String className="com.mysql.jdbc.Driver";
	
	//MySQL数据库链接
	private String url="jdbc:mysql://localhost:3306/schoolnews?user=root&password=123456";
	
	//取得数据库连接
	public java.sql.Connection getConnection(){
		try {
			Class.forName(className).newInstance();
			connection=DriverManager.getConnection(url);
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		return connection;
	}
	
	//关闭数据库
	public void close(){
		try {
			//注意关闭顺序
			if (resultSet!=null) resultSet.close();
			if (statement!=null) statement.close();
			if (preparedStatement!=null) preparedStatement.close();
			if (connection!=null) connection.close();
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
	//查询并返回结果集
	public ResultSet query(String sql){
		try {
			connection=getConnection();
			statement=connection.createStatement();
			resultSet=statement.executeQuery(sql);
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		return resultSet;
	}
	
	public void add(String sql){
		try {
			connection=getConnection();
			statement=connection.createStatement();
			statement.execute(sql);
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}	
	}

}

3、获取数据库数据

package myservice;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import model.Schoolnews;

public class SchoolNewsXML {

	public List<Schoolnews> getSchoolNews() throws SQLException {
		JDBCService jDBCService = new JDBCService();
		List<Schoolnews> snews = new ArrayList<Schoolnews>();
		Schoolnews schoolnews = null;
		ResultSet resultSet = jDBCService.query("select * from t_snews");
		while (resultSet.next()) {
			schoolnews = new Schoolnews();
			schoolnews.setTitle(resultSet.getString(2));
			schoolnews.setContent(resultSet.getString(3));
			schoolnews.setShareDate(resultSet.getString(4));
			schoolnews.setShareperson(resultSet.getString(5));
			schoolnews.setPictureuri(resultSet.getString(6));
			snews.add(schoolnews);
		}
		return snews;
	}

}

4、ServletForXML

package snewsservlet;

import java.io.IOException;
import java.sql.SQLException;
import java.util.List;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;



import model.Schoolnews;
import myservice.SchoolNewsXML;

public class ServletForXML extends HttpServlet {

	
	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	private  SchoolNewsXML  schoolNewsXML=new  SchoolNewsXML();

	public ServletForXML() {
		super();
	}

	public void destroy() {
		super.destroy(); // Just puts "destroy" string in log
		// Put your code here
	}


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


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

		List<Schoolnews> snews = null;
		try {
			snews = schoolNewsXML.getSchoolNews();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		request.setAttribute("snews", snews);
		
		String path="/index.jsp";
		request.getRequestDispatcher(path);
		ServletContext application =this.getServletContext();
		RequestDispatcher rd=application.getRequestDispatcher(path);
			
		//跳转
		rd.forward(request,response);
		
	
	}

	public void init() throws ServletException {
		// Put your code here
	}

}

5、网页输出XML

<%@ page language="java" contentType="text/xml;charset=UTF-8"pageEncoding="UTF-8"%><%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c"%><?xml version="1.0" encoding="UTF-8"?>
<Schoolnewses><c:forEach items="${snews}"var="Schoolnews">
<Schoolnews id="${Schoolnews.id}">
<title>${Schoolnews. title}</title>
<content>${Schoolnews.content}</content>
<sharedate>${Schoolnews.shareDate}</sharedate>
<shareperson>${Schoolnews.shareperson}</shareperson>
<pictureuri>${Schoolnews.pictureuri}</pictureuri>
</Schoolnews>
</c:forEach> 
</Schoolnewses>

6、Servlet配置文件：

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="3.0" xmlns="http://java.sun.com/xml/ns/javaee"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
	http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd">
	<display-name></display-name>
	<servlet>

		<servlet-name>ServletForXML</servlet-name>
		<servlet-class>snewsservlet.ServletForXML</servlet-class>
	</servlet>
	<servlet>
		<description>This is the description of my J2EE component</description>
		<display-name>This is the display name of my J2EE component</display-name>
		<servlet-name>AddsnewsServlet</servlet-name>
		<servlet-class>snewsservlet.AddsnewsServlet</servlet-class>
	</servlet>


	<servlet-mapping>
		<servlet-name>ServletForXML</servlet-name>
		<url-pattern>/servlet/ServletForXML</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>AddsnewsServlet</servlet-name>
		<url-pattern>/servlet/AddsnewsServlet</url-pattern>
	</servlet-mapping>
	<welcome-file-list>
		<welcome-file>index.jsp</welcome-file>
	</welcome-file-list>
</web-app>

7、请求：http://localhost:8080/androidHomework/servlet/ServletForXML时得到的效果：

接下来是在Android里面获取并解析xml，以下是主要代码，Activity那些就不贴出来了，主要核心是获取xml和解析xml

8、SchoolNewsService

package com.homework.schoolnews;

import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.ArrayList;
import java.util.List;

import org.xmlpull.v1.XmlPullParser;
import org.xmlpull.v1.XmlPullParserException;

import android.util.Xml;

public class SchoolNewsService {

	public static List<Schoolnews> getSchoolNews()
			throws MalformedURLException, IOException, XmlPullParserException {
		String path = "http://172.19.55.121:8080/androidHomework/servlet/ServletForXML";
		HttpURLConnection con = (HttpURLConnection) new URL(path)
				.openConnection();
		con.setConnectTimeout(15000);
		con.setRequestMethod("GET");
		int i=con.getResponseCode();
		if(i==200){
			InputStream in = con.getInputStream();
			return parseXML(in);
		}
		return null;

	}

	/*
	 * pull方法解析xml
	 */
	
	
	private static List<Schoolnews> parseXML(InputStream in)
			throws XmlPullParserException, IOException {

		List<Schoolnews> snews = null;
		Schoolnews schoolnews = null;
		XmlPullParser pullParser = Xml.newPullParser();
		pullParser.setInput(in, "UTF-8");
		int event = pullParser.getEventType();
		while (event != XmlPullParser.END_DOCUMENT) {
			switch (event) {
			case XmlPullParser.START_DOCUMENT:
				snews = new ArrayList<Schoolnews>();
				break;
			case XmlPullParser.START_TAG:
				if ("Schoolnews".equals(pullParser.getName())) {
					int id = new Integer(pullParser.getAttributeValue(0));
					schoolnews = new Schoolnews();
					schoolnews.setId(id);
				}
				
				if ("title".equals(pullParser.getName())) {
					schoolnews.setTitle(pullParser.nextText());
				}
				if ("content".equals(pullParser.getName())) {
					schoolnews.setContent(pullParser.nextText());
				}
				if ("sharedate".equals(pullParser.getName())) {
					schoolnews.setShareDate(pullParser.nextText());
				}

				if ("shareperson".equals(pullParser.getName())) {
					schoolnews.setShareperson(pullParser.nextText());
				}
				
				if ("pictureuri".equals(pullParser.getName())) {
					schoolnews.setPictureuri(pullParser.nextText());
				}

				break;
			case XmlPullParser.END_TAG:
				if ("Schoolnews".equals(pullParser.getName())) {
					snews.add(schoolnews);
					schoolnews = null;
				}
				break;

			}
			event = pullParser.next();
		}
		return snews;

	}
}

安卓获取并显示数据：//2013-08-09 添加-Mr_Tank_

package com.homework.schoolnews;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import com.homew.shouldnews.R;

import android.os.Bundle;
import android.app.Activity;
import android.content.Intent;
import android.view.Menu;
import android.view.View;
import android.widget.*;

public class MainActivity extends Activity {

	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.activity_main);

		ImageButton bt_add = (ImageButton) this.findViewById(R.id.snews_add);
		find();
		
		//添加校园新鲜事
		bt_add.setOnClickListener(new ImageButton.OnClickListener() {

			@Override
			public void onClick(View v) {
				// TODO Auto-generated method stub
				Intent intent = new Intent();
				intent.setClass(MainActivity.this, AddsnewsActivity.class);
				startActivity(intent);
			}
		});
		

	}

	private void find(){
		final ListView lv = (ListView) this.findViewById(R.id.snews_listView);
		try {
			List<Schoolnews> snews = SchoolNewsService.getSchoolNews();
			List<HashMap<String, Object>> data = new ArrayList<HashMap<String, Object>>();
			for (Schoolnews schoolnews : snews) {
				HashMap<String, Object> item = new HashMap<String, Object>();
				item.put("id", schoolnews.getId());
				item.put("title", schoolnews.getTitle());
				item.put("content", schoolnews.getContent());
				item.put("sharedate", schoolnews.getShareDate());
				item.put("shareperson", schoolnews.getShareperson());
				item.put("pictureuri", schoolnews.getPictureuri());
				data.add(item);
			}

			SimpleAdapter adapter = new SimpleAdapter(MainActivity.this, data,
					R.layout.snews, new String[] { "title", "sharedate",
							"shareperson", "content" }, new int[] {
							R.id.snews_title, R.id.snews_shareTime,
							R.id.snews_writer, R.id.snews_content });
			lv.setAdapter(adapter);

		} catch (Exception ex) {
		}

	}

	
	@Override
	public boolean onCreateOptionsMenu(Menu menu) {
		// Inflate the menu; this adds items to the action bar if it is present.
		getMenuInflater().inflate(R.menu.main, menu);
		return true;
	}

}



效果：
数据上传：
package com.homework.schoolnews;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;

public class AddsnewsService {

	// 静态方法
	public static boolean save(String title, String content, String shareperson)
			throws MalformedURLException, IOException {
		String path = "http://172.19.55.121:8080/androidHomework/servlet/AddsnewsServlet?title="
			+URLEncoder.encode(title, "UTF-8")+"&snewscontent="
			+URLEncoder.encode(content, "UTF-8")+"&shareperson="+URLEncoder.encode(shareperson, "UTF-8");
		
/*bug
 *用以下方法装配path里有点问题 ，shareperson，上传到服务器的时候为null.
 */		
//		Map<String, String> params = new HashMap<String, String>();
//
//		params.put("title", title);
//		params.put("snewscontent", content);
//		params.put("shareperson", shareperson);
//
//		StringBuilder sb = new StringBuilder(path);

		// 装配path
//		for (Map.Entry<String, String> entry : params.entrySet()) {
//			// 获取键
//			sb.append(entry.getKey()).append("=");
//			sb.append(URLEncoder.encode(entry.getValue(), "UTF-8"));
//			sb.append("&");
//		}
		// 删除装配path时多装配的&字符
		//sb.deleteCharAt(sb.length() - 1);

		HttpURLConnection con = (HttpURLConnection) new URL(path)
				.openConnection();
		con.setConnectTimeout(15000);
		con.setRequestMethod("GET");
		con.setDoOutput(true);// 允许对外传输数据

		byte[] pathdata = path.toString().getBytes();

		// 设置通用的请求属性
//		con.setRequestProperty("accept", "*/*");
//		con.setRequestProperty("connection", "Keep-Alive");
//		con.setRequestProperty("user-agent",
//				"Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");
//		
//		con.setRequestProperty("Content-Length", pathdata.length + "");
//		con.connect();
		OutputStream out = con.getOutputStream();
		out.write(pathdata);
		out.flush();
		if (con.getResponseCode() == 200) {
			return true;
		}
		return false;
	}

}