zis.rar_active MQ_activemq_java activeMQ_java 转发

package edu.scau.agent.only; import java.io.File; import java.util.Iterator; import java.util.List; import org.dom4j.Attribute; import org.dom4j.Document; import org.dom4j.DocumentException; import org.dom4j.DocumentHelper; import org.dom4j.Element; import edu.scau.message.ThemeMessage; import edu.scau.message.common.util.ConvertUtil; import edu.scau.message.common.util.DocumentUtil; import edu.scau.message.factory.MessageFactory; import edu.scau.message.factory.MessageType; import edu.scau.zis.file.FileConstant; import edu.scau.zis.file.FileUtil; import edu.scau.zis.recieve.XmlParser; import edu.scau.zis.xml.UserBeanAnalyer; public class FileAction { // 代理使用，获取自己的id public static String getMyId() { String id = null; File file = new File(FileConstant.MY_AGENT_ID); if (!file.exists()) { return id; } Document doc1 = DocumentUtil.readDocument(FileConstant.MY_AGENT_ID); id = doc1.getRootElement().selectSingleNode("/agent_id/id").getText(); return id; } // agent使用，保存自己的id public static boolean saveMyId(String id) { File file = new File(FileConstant.MY_AGENT_ID); if (!file.exists()) { FileUtil.createDir(FileConstant.AGENT_ID_DIR); Document doc = DocumentHelper.createDocument(); doc.addElement("agent_id"); DocumentUtil.saveDocument(doc, FileConstant.MY_AGENT_ID); Document doc1 = DocumentUtil.readDocument(FileConstant.MY_AGENT_ID); Element e=doc1.getRootElement().addElement(FileConstant.AGENT_ID_TARGET); e.setText(id); e.addAttribute("still", "true"); DocumentUtil.saveDocument(doc1, FileConstant.MY_AGENT_ID); return true; } else { System.out.println("已经存在！"); return false; } } //代理使用，判断注册是否有效 public static boolean RegisterConnect(){ File file = new File(FileConstant.MY_AGENT_ID); if (!file.exists()) { return false;//文件不存在，无效 } else { Document doc1 = DocumentUtil.readDocument(FileConstant.MY_AGENT_ID); String still= ((Element)doc1.getRootElement().selectSingleNode("/agent_id/id")).attributeValue("still"); if(still.equals("false")) return false; return true; } } //代理使用，取消注册 public static boolean cancelRegister(){ File file = new File(FileConstant.MY_AGENT_ID); if (file.exists()) { Document doc1 = DocumentUtil.readDocument(FileConstant.MY_AGENT_ID); ((Element)doc1.getRootElement().selectSingleNode("/agent_id/id")).addAttribute("still", "false"); DocumentUtil.saveDocument(doc1, FileConstant.MY_AGENT_ID); return true; } else { return false; } } // 代理使用，更新主题报文 public static boolean saveTheme(String xml) { File file = new File(FileConstant.THEME_FILE); if (file.exists()) { FileUtil.deleteFile(FileConstant.THEME_FILE); } Document doc1=null; try { doc1 = DocumentHelper.parseText(xml); } catch (DocumentException e) { e.printStackTrace(); } DocumentUtil.saveDocument(doc1, FileConstant.THEME_FILE); return true; } //代理使用，订阅主题 public static boolean subscribeTheme(String theme){ File file = new File(FileConstant.THEME_DIR+theme+"/"); if(!file.exists()){ FileUtil.createDir(FileConstant.THEME_DIR+theme+"/"); return true; } return false; } //代理使用，取消订阅 public static boolean subscribeConcel(String theme){ File file = new File(FileConstant.THEME_DIR+theme+"/"); if(file.exists()){ FileUtil.deleteAllFile(FileConstant.THEME_DIR+theme+"/"); return true; } return false; } //代理使用，保存来自其他代理的数据,参数为主题，显示标记，文件名，数据 public static boolean saveOtherPublishData(String theme,String mark,String fileName,String xml){ File file = new File(FileConstant.THEME_DIR + theme + "/"); if(file.exists()){ file=new File(FileConstant.THEME_DIR + theme + "/"+FileConstant.PUBLISH_INDEX_FILE); if(!file.exists()){ Document doc=DocumentHelper.createDocument(); doc.addElement(FileConstant.PUBLISH_INDEX_FILE_ROOT); DocumentUtil.saveDocument(doc, FileConstant.THEME_DIR + theme + "/"+FileConstant.PUBLISH_INDEX_FILE); } Document doc=DocumentUtil.readDocument(FileConstant.THEME_DIR + theme + "/"+FileConstant.PUBLISH_INDEX_FILE); Element node=doc.getRootElement().addElement(FileConstant.PUBLISH_INDEX_FILE_NODE); node.addAttribute(FileConstant.PUBLISH_INDEX_FILE_NODE_ATTR1, mark); node.addAttribute(FileConstant.PUBLISH_INDEX_FILE_NODE_ATTR2, fileName); DocumentUtil.saveDocument(doc, FileConstant.THEME_DIR + theme + "/"+FileConstant.PUBLISH_INDEX_FILE); try { DocumentUtil.saveDocument(DocumentHelper.parseText(xml), FileConstant.THEME_DIR + theme + "/"+fileName); } catch (DocumentException e) { e.printStackTrace(); } return true; }else{ System.out.println("尚未订阅该主题"); return false; } } //代理使用，删除存在于本地的文件 public static boolean deleteOtherPublishData(String theme,String mark,String fileName){ File file = new File(FileConstant.THEME_DIR + theme + "/"); if(file.exists()){ file=new File(FileConstant.THEME_DIR + theme + "/"+FileConstant.PUBLISH_INDEX_FILE); if(!file.exists()){ System.out.println("无保存文件！"); return false; } Document doc=DocumentUtil.readDocument(FileConstant.THEME_DIR + theme + "/"+FileConstant.PUBLISH_INDEX_FILE); Element root=doc.getRootElement(); for(Iterator<Element> it=root.elementIterator(FileConstant.PUBLISH_INDEX_FILE_NODE);it.hasNext();){ Element a=it.next(); if(a.attributeValue(FileConstant.PUBLISH_INDEX_FILE_NODE_ATTR1).equals(mark)&&a.attributeValue(FileConstant.PUBLISH_INDEX_FILE_NODE_ATTR2).equals(fileName)){ root.remove(a); FileUtil.deleteFile(FileConstant.THEME_DIR + theme + "/"+fileName); break; } } DocumentUtil.saveDocument(doc, FileConstant.THEME_DIR + theme + "/"+FileConstant.PUBLISH_INDEX_FILE); return true; }else{ System.out.println("尚未订阅该主题"); return false; } } //代理使用，以一定格式保存数据 public static void saveData(String theme,String xml){ try { String xml_root=DocumentHelper.parseText(xml).getRootElement().getName(); UserBeanAnalyer a=((UserBeanAnalyer)Application.context.get(Application.ANALYER)); String node=a.markMap.get(xml_root); String mark=XmlParser.parseMark(xml, node); String fileName=mark+"_"+System.currentTimeMillis()+".xml"; if(FileAction.saveOtherPublishData(theme, mark, fileName, xml)){ System.out.println("保存成功"); return ; } System.out.println("保存失败"); } catch (DocumentException e) { // TODO Auto-generated catch block e.printStackTrace(); } } // 代理使用，装载所有的主题 public static List<String> initTheme() { File file = new File(FileConstant.THEME_FILE); if (file.exists()) { Document doc = DocumentUtil.readDocument(FileConstant.THEME_FILE); ThemeMessage tm = (ThemeMessage) MessageFactory .createMessage(MessageType.THEME); DocumentUtil.parse(tm, doc); return tm.getThemes(); } else { return null; } } }