基于DWR推送的web聊天系统

package com.util; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStreamWriter; import java.io.UnsupportedEncodingException; import java.net.MalformedURLException; import java.net.URL; import java.net.URLConnection; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory; import javax.xml.parsers.ParserConfigurationException; import javax.xml.transform.OutputKeys; import javax.xml.transform.Result; import javax.xml.transform.Source; import javax.xml.transform.Transformer; import javax.xml.transform.TransformerConfigurationException; import javax.xml.transform.TransformerException; import javax.xml.transform.TransformerFactory; import javax.xml.transform.dom.DOMSource; import javax.xml.transform.stream.StreamResult; import org.w3c.dom.DOMException; import org.w3c.dom.Document; import org.w3c.dom.Element; import org.w3c.dom.Node; import org.w3c.dom.NodeList; import org.xml.sax.SAXException; public class DomXMLString { // private static String SERVICES_HOST = "www.webxml.com.cn"; // 远程WebService接口url private static String NETDATA_URL = "http://www.webxml.com.cn/WebServices/WeatherWebService.asmx/getWeatherbyCityName?theCityName="; // private static String NETDATA_URL = // "http://www.webxml.com.cn/WebServices/WeatherWebService.asmx/getWeatherbyCityName?theCityName=北京"; // 访问远程WebService接口返回的xml格式的数据保存在本地的绝对路径 private static String LOCAL_PC_SAVEFILE_URL = new SimpleDateFormat( "yyyyMMdd").format(new Date()) + "weather.xml"; public static void main(String[] args) throws Exception { // System.out.println(IpUtils.getMyaddress()); // String // mess=IpUtils.getMyaddress().substring(IpUtils.getMyaddress().indexOf("：")+1,IpUtils.getMyaddress().indexOf("市")); // System.out.println(mess); // Document document = getProvinceCode(NETDATA_URL+mess); // helloOK(document, LOCAL_PC_SAVEFILE_URL); // makeMess(); list=readXML(); for (int i = 0; i < list.size(); i++) { System.out.println(list.get(i)); } } public static String path = "E:/weather/" + LOCAL_PC_SAVEFILE_URL; public static void makeMess() throws IOException, TransformerException { File file = new File(path); if (file.exists()) { System.out.println("有了"); } else { System.out.println(IpUtils.getMyaddress()); String mess = IpUtils.getMyaddress().substring( IpUtils.getMyaddress().indexOf("：") + 1, IpUtils.getMyaddress().indexOf("市")); System.out.println(mess); Document document = getProvinceCode(NETDATA_URL + mess); helloOK(document, LOCAL_PC_SAVEFILE_URL); } } /* 返回一个Document对象 */ public static Document getProvinceCode(String netXMLDataURL) { Document document = null; DocumentBuilderFactory documentBF = DocumentBuilderFactory .newInstance(); documentBF.setNamespaceAware(true); try { DocumentBuilder documentB = documentBF.newDocumentBuilder(); InputStream inputStream = getSoapInputStream(netXMLDataURL); // 具体webService相关 document = documentB.parse(inputStream); inputStream.close(); } catch (DOMException e) { e.printStackTrace(); return null; } catch (ParserConfigurationException e) { e.printStackTrace(); return null; } catch (SAXException e) { e.printStackTrace(); return null; } catch (IOException e) { e.printStackTrace(); return null; } return document; } /* 返回InputStream对象 */ public static InputStream getSoapInputStream(String url) { InputStream inputStream = null; try { URL urlObj = new URL(url); URLConnection urlConn = urlObj.openConnection(); // urlConn.setRequestProperty("Host", SERVICES_HOST); // //具体webService相关 urlConn.connect(); inputStream = urlConn.getInputStream(); } catch (MalformedURLException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return inputStream; } /* 访问远程(WebService)xml数据后返回的xml格式字符串并生成为本地文件 */ public static void helloOK(Document document, String savaFileURL) { File file = new File("E:/weather/"); File file2 = new File(path); deleteFile(file, savaFileURL);// 删除其他文件 if (file2.exists()) {// 已经存在则跳出 System.out.println("存在"); return; } Source source = new DOMSource(document); // Create a new Transformer that performs a copy of the Source to the // Result. TransformerFactory transFactory = TransformerFactory.newInstance(); Transformer transFormer = null; try { transFormer = transFactory.newTransformer(); } catch (TransformerConfigurationException e) { // TODO Auto-generated catch block e.printStackTrace(); } transFormer.setOutputProperty(OutputKeys.ENCODING, "UTF-8"); transFormer.setOutputProperty(OutputKeys.METHOD, "xml"); transFormer.setOutputProperty(OutputKeys.INDENT, "no"); OutputStreamWriter outputStreamWriter = null; try { outputStreamWriter = new OutputStreamWriter(new FileOutputStream(//生成本地的xml文件 path), "UTF-8"); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (FileNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } Result xmlResult = new StreamResult(outputStreamWriter); // Transform the XML Source to a Result. try { transFormer.transform(source, xmlResult); } catch (TransformerException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 删除其他文件 * * @param file * @param fileName */ private static void deleteFile(File file, String fileName) { // 传入的文件夹是否存在 if (file.exists() && file.isDirectory() && file != null) { // 通过File类的listFiles方法获取文件夹中所有文件的全路径 File[] files = file.listFiles(); // 如果文件夹不为空 if (files != null && files.length > 0) { // 遍历改文件夹下的所有内容 for (int i = 0; i < files.length; i++) { // 如果是文件夹 if (files[i].isDirectory()) { // 再次调用自己 deleteFile(files[i], fileName); } else { if (!files[i].getName().equals(fileName)) {// 删除除XX以外的文件 System.out.println(files[i]); files[i].delete(); } } } } } } public static List<String> list=new ArrayList<String>(); public static List<String> readXML() { try { File file = new File(path); DocumentBuilderFactory factory = DocumentBuilderFactory .newInstance(); DocumentBuilder builder = factory.newDocumentBuilder(); Document doc = builder.parse(file); Element root = doc.getDocumentElement(); NodeList books = root.getChildNodes(); if (books != null) { for (int i = 0; i < books.getLength(); i++) { Node book = books.item(i); if (book.getNodeName().equals("string")) { list.add(book.getTextContent()); // System.out.println(book.getTextContent()); } } } } catch (Exception e) { e.printStackTrace(); return null; } return list; } }