一.项目简介
1.环境
1).jdk 1.6
2.jar包
commons-net-1.4.1.jar
gson-2.2.4.jar
jar 建议大家去官网上下载
3.项目结构
二.创建Json
1.javaBean
package kingdom.json;public class TransData {private String fq_name; //交易发起人private String js_name; //交易接收人private String hl_name; //交易处理人private int money; //交易金额private int pay_way; //支付方式private String begin_time; //交易发起时间private String end_time; //交易结束时间public String getFq_name() {return fq_name;}public void setFq_name(String fq_name) {this.fq_name = fq_name;}public String getJs_name() {return js_name;}public void setJs_name(String js_name) {this.js_name = js_name;}public String getHl_name() {return hl_name;}public void setHl_name(String hl_name){this.hl_name = hl_name;}public int getMoney() {return money;}public void setMoney(int money) {this.money = money;}public int getPay_way(){return pay_way;}public void setPay_way(int pay_way) {this.pay_way = pay_way;}public String getBegin_time() {return begin_time;}public void setBegin_time(String begin_time) {this.begin_time = begin_time;}public String getEnd_time() {return end_time;}public void setEnd_time(String end_time){this.end_time = end_time;}}package kingdom.json;import java.util.List;public class DataGram {private String trans_code; //交易代码private String trans_type; //交易类型private String trans_name; //交易名称private String jys_code;//交易所代码private String jys_name;//交易所名字private String jy_way; //交易方式private List<TransData> ts_data; //交易数据public String getTrans_code() {return trans_code;}public void setTrans_code(String trans_code) {this.trans_code = trans_code;}public String getTrans_type() {return trans_type;}public void setTrans_type(String trans_type) {this.trans_type = trans_type;}public String getTrans_name() {return trans_name;}public void setTrans_name(String trans_name) {this.trans_name = trans_name;}public String getJys_code() {return jys_code;}public void setJys_code(String jys_code) {this.jys_code = jys_code;}public String getJys_name() {return jys_name;}public void setJys_name(String jys_name) {this.jys_name = jys_name;}public String getJy_way() {return jy_way;}public void setJy_way(String jy_way) {this.jy_way = jy_way;}public List<TransData> getTs_data() {return ts_data;}public void setTs_data(List<TransData> ts_data) {this.ts_data = ts_data;}}
2.创建Json
package kingdom.json;import java.util.List;import java.util.ArrayList;import com.google.gson.Gson;public class CreatJson {public static String CreatTransJson(){String beanStr = null;DataGram dg = new DataGram();Gson gson = new Gson(); TransData td = new TransData();List<TransData> list = new ArrayList<TransData>();dg.setTrans_code("10016");dg.setTrans_type("转账");dg.setTrans_name("发行债券");dg.setJys_code("009");dg.setJys_name("北京金融交易所");dg.setJy_way("债券");dg.setTs_data(list);for(int i = 0; i < 3; ++i){td.setFq_name("小明");td.setJs_name("小王");td.setHl_name("小张");td.setMoney(100000 + i);td.setBegin_time("-03-09");td.setEnd_time("-09-22");list.add(td);}beanStr = gson.toJson(dg); return beanStr;}}
3.json数据格式
{"trans_code":"10016","trans_type":"转账", "trans_name":"发行债券", "jys_code":"009", "jys_name":"北京金融交易所", "jy_way":"债券", "ts_data": [ { "fq_name":"小明", "js_name":"小王", "hl_name":"小张"," money":100002, "pay_way":0, "begin_time":"-03-09", "end_time":"-09-22" } ,{"fq_name":"小明", "js_name":"小王", "hl_name":"小张"," money":100002, "pay_way":0, "begin_time":"-03-09", "end_time":"-09-22" } ,{"fq_name":"小明", "js_name":"小王", "hl_name":"小张"," money":100002, "pay_way":0, "begin_time":"-03-09", "end_time":"-09-22" }]}
三.解析Json并创建XML
1.JavaBean代码
package kingdom.xml;import java.util.List;public class Result {private String trans_code;private String trans_type;private String trans_name;private String jys_code;private String jys_name;private String jy_way;private List<TranInfo> ts_data;public String getTrans_code() {return trans_code;}public void setTrans_code(String trans_code) {this.trans_code = trans_code;}public String getTrans_type(){return trans_type;}public void setTrans_type(String trans_type) {this.trans_type = trans_type;}public String getTrans_name() {return trans_name;}public void setTrans_name(String trans_name) {this.trans_name = trans_name;}public String getJys_code() {return jys_code;}public void setJys_code(String jys_code) {this.jys_code = jys_code;}public String getJys_name() {return jys_name;}public void setJys_name(String jys_name) {this.jys_name = jys_name;}public String getJy_way() {return jy_way;}public void setJy_way(String jy_way) {this.jy_way = jy_way;}public List<TranInfo> getTs_data(){return ts_data;}public void setTs_data(List<TranInfo> ts_data) {this.ts_data = ts_data;}public static class TranInfo {private String fq_name;private String js_name;private String hl_name;private int money;@Overridepublic String toString(){return "TranInfo [money=" + money + ", pay_way=" + pay_way + "]";}private int pay_way;private String begin_time;private String end_time;public String getFq_name() {return fq_name;}public void setFq_name(String fq_name) {this.fq_name = fq_name;}public String getJs_name() {return js_name;}public void setJs_name(String js_name) {this.js_name = js_name;}public String getHl_name() {return hl_name;}public void setHl_name(String hl_name) {this.hl_name = hl_name;}public int getMoney() {return money;}public void setMoney(int money) {this.money = money;}public int getPay_way() {return pay_way;}public void setPay_way(int pay_way) {this.pay_way = pay_way;}public String getBegin_time() {return begin_time;}public void setBegin_time(String begin_time) {this.begin_time = begin_time;}public String getEnd_time(){return end_time;}public void setEnd_time(String end_time){this.end_time = end_time;}}}
2.解析Json并创建XML文件
package kingdom.xml;import kingdom.json.CreatJson;import kingdom.xml.Result.TranInfo;import org.dom4j.*;import org.dom4j.io.*;import org.xml.sax.SAXException;import com.google.gson.*;import com.google.gson.reflect.TypeToken;import com.sun.xml.internal.bind.util.AttributesImpl;import java.lang.reflect.*;import java.util.List;import javax.xml.parsers.ParserConfigurationException;import javax.xml.parsers.SAXParser;import javax.xml.parsers.SAXParserFactory;import javax.xml.transform.OutputKeys;import javax.xml.transform.Transformer;import javax.xml.transform.TransformerConfigurationException;import javax.xml.transform.sax.SAXTransformerFactory;import javax.xml.transform.sax.TransformerHandler;import javax.xml.transform.stream.StreamResult;public class XmlCreate {public static void creatXml() throws Exception{CreatJson cj = new CreatJson();String str = cj.CreatTransJson();System.out.println(str);Gson gson = new Gson();Result result = gson.fromJson(str, Result.class);SAXTransformerFactory factory = (SAXTransformerFactory) SAXTransformerFactory.newInstance();try { TransformerHandler handler = factory.newTransformerHandler(); Transformer transformer = handler.getTransformer(); transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8"); transformer.setOutputProperty(OutputKeys.INDENT, "yes"); StreamResult ret = new StreamResult("./saxToxml.xml"); handler.setResult(ret); AttributesImpl attr = new AttributesImpl(); handler.startDocument(); handler.startElement("", "", "root", attr); attr.clear(); handler.startElement("", "", "trans_code", attr); handler.characters(result.getTrans_code().toCharArray(), 0, result.getTrans_code().toCharArray().length); handler.endElement("", "", "trans_code"); attr.clear(); handler.startElement("", "", "trans_type", attr); handler.characters(result.getTrans_type().toCharArray(), 0, result.getTrans_type().toCharArray().length); handler.endElement("", "", "trans_type"); attr.clear(); handler.startElement("", "", "jys_code", attr); handler.characters(result.getJys_code().toCharArray(), 0, result.getJys_code().toCharArray().length); handler.endElement("", "", "jys_code"); attr.clear(); handler.startElement("", "", "jy_way", attr); handler.characters(result.getJy_way().toCharArray(), 0, result.getJy_way().toCharArray().length); handler.endElement("", "", "jy_way"); attr.clear();List<TranInfo> ts_data = result.getTs_data();for(int i = 0; i < ts_data.size(); ++i){handler.startElement("", "", "trans", attr); attr.clear(); String m_mony = String.valueOf(ts_data.get(i).getMoney());handler.startElement("", "", "money", attr); handler.characters(m_mony.toCharArray(), 0, m_mony.toCharArray().length); handler.endElement("", "", "money"); attr.clear();String pay_way = String.valueOf(ts_data.get(i).getPay_way());handler.startElement("", "", "pay_way", attr); handler.characters(pay_way.toCharArray(), 0, pay_way.toCharArray().length); handler.endElement("", "", "pay_way"); attr.clear();handler.startElement("", "", "begin_time", attr); handler.characters(ts_data.get(i).getBegin_time().toCharArray(), 0, ts_data.get(i).getBegin_time().toCharArray().length); handler.endElement("", "", "begin_time"); attr.clear();handler.endElement("", "", "trans"); }handler.endElement("", "", "root"); handler.endDocument(); } catch (TransformerConfigurationException e) { e.printStackTrace(); } catch (SAXException e) { e.printStackTrace(); }}}
2.XML文件数据
<?xml version="1.0" encoding="UTF-8"?><root><trans_code>10016</trans_code><trans_type>转账</trans_type><jys_code>009</jys_code><jy_way>债券</jy_way><trans><money>100002</money><pay_way>0</pay_way><begin_time>-03-092</begin_time></trans><trans><money>100002</money><pay_way>0</pay_way><begin_time>-03-092</begin_time></trans><trans><money>100002</money><pay_way>0</pay_way><begin_time>-03-092</begin_time></trans></root>
四.ftp发送到服务器
1.javaBean
package kingdom.ftp;public class Ftp {private String ipAddr;private Integer port;private String userName;private String pwd;private String path;public String getIpAddr() {return ipAddr;}public void setIpAddr(String ipAddr) {this.ipAddr = ipAddr;}public Integer getPort() {return port;}public void setPort(Integer port) {this.port = port;}public String getUserName() {return userName;}public void setUserName(String userName) {this.userName = userName;}public String getPwd() {return pwd;}public void setPwd(String pwd) {this.pwd = pwd;}public String getPath() {return path;}public void setPath(String path) {this.path = path;}}
2.ftp代码
package kingdom.ftp;import java.io.InputStream;import kingdom.json.CreatJson;import kingdom.xml.XmlCreate;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.IOException;import java.io.OutputStream;import .ftp.FTPClient;import .ftp.FTPFile;import .ftp.FTPReply;public class FtpClient { private static FTPClient ftp;public static boolean connectFtp(Ftp f) throws Exception{ftp = new FTPClient();boolean flag=false;int reply;if(f.getPort()==null) {ftp.connect(f.getIpAddr(), 21);}else{ftp.connect(f.getIpAddr(), f.getPort());}boolean ok = ftp.login(f.getUserName(), f.getPwd());if(ok == false){System.out.println("ftp服务器登录失败");return flag;}ok = ftp.setFileType(FTPClient.BINARY_FILE_TYPE);if(ok == false){System.out.println("设置文件类型失败");return flag;}reply = ftp.getReplyCode();if (!FTPReply.isPositiveCompletion(reply)) {ftp.disconnect();return flag;}ftp.changeWorkingDirectory(f.getPath()); flag = true;return flag;}public static void closeFtp(){if (ftp!=null && ftp.isConnected()) {try{ftp.logout();ftp.disconnect();} catch (IOException e) {e.printStackTrace();}}}public static void upload(File f) throws Exception{if (f.isDirectory()) {ftp.makeDirectory(f.getName());ftp.changeWorkingDirectory(f.getName());String[] files=f.list();for(String fstr : files){File file1 = new File(f.getPath()+"/"+fstr);if (file1.isDirectory()) {upload(file1);ftp.changeToParentDirectory();}else{File file2 = new File(f.getPath()+"/"+fstr);FileInputStream input = new FileInputStream(file2);ftp.storeFile(file2.getName(), input);input.close();}}}else{File file2=new File(f.getPath());FileInputStream input=new FileInputStream(file2);ftp.storeFile(file2.getName(), input);input.close();}}public static void startDown(Ftp f,String localBaseDir,String remoteBaseDir ) throws Exception{if (FtpClient.connectFtp(f)) { try { FTPFile[] files = null; boolean changedir = ftp.changeWorkingDirectory(remoteBaseDir); if (changedir) { ftp.setControlEncoding("GBK"); files = ftp.listFiles(); for (int i = 0; i < files.length; i++) { try{ downloadFile(files[i], localBaseDir, remoteBaseDir); }catch(Exception e){ System.out.println("<"+files[i].getName()+">下载失败"); } } } } catch (Exception e) { System.out.println("下载过程中出现异常"); } }else{System.out.println("链接失败！");}}private static void downloadFile(FTPFile ftpFile, String relativeLocalPath,String relativeRemotePath){ if (ftpFile.isFile()) {if (ftpFile.getName().indexOf("?") == -1) { OutputStream outputStream = null; try { File locaFile= new File(relativeLocalPath+ ftpFile.getName()); if(locaFile.exists()){ return; }else{ outputStream = new FileOutputStream(relativeLocalPath+ ftpFile.getName()); ftp.retrieveFile(ftpFile.getName(), outputStream); outputStream.flush(); outputStream.close(); } } catch (Exception e) { e.printStackTrace();} finally{ try { if (outputStream != null){ outputStream.close(); }} catch (IOException e) { System.out.println("输出文件流异常"); } } } } else { String newlocalRelatePath = relativeLocalPath + ftpFile.getName(); String newRemote = new String(relativeRemotePath+ ftpFile.getName().toString()); File fl = new File(newlocalRelatePath); if (!fl.exists()) { fl.mkdirs(); } try { newlocalRelatePath = newlocalRelatePath + '/'; newRemote = newRemote + "/"; String currentWorkDir = ftpFile.getName().toString(); boolean changedir = ftp.changeWorkingDirectory(currentWorkDir); if (changedir){ FTPFile[] files = null; files = ftp.listFiles(); for (int i = 0; i < files.length; i++) { downloadFile(files[i], newlocalRelatePath, newRemote); } } if (changedir){ftp.changeToParentDirectory(); } } catch (Exception e){ e.printStackTrace();} } } public static void main(String[] args) throws Exception{CreatJson cj = new CreatJson();System.out.println(cj.CreatTransJson());XmlCreate xmlc = new XmlCreate();xmlc.creatXml();Ftp f = new Ftp();f.setIpAddr("192.168.191.5");f.setUserName("guosj1");f.setPwd("123456");f.setPath("D:/iTudou");FtpClient.connectFtp(f);File file = new File("D:/Workplace/KindomFtpClient/saxToxml.xml"); FtpClient.upload(file);System.out.println("ok"); } }
关注问我技术公众号，加小问，拉您入技术交流群：
