[关闭]
@zhanjindong 2015-02-12T07:36:11.000000Z 字数 15190 阅读 2702

iFlytek

[ossp-framework][v1.0.1][RELEASE LOG][2014-09-17]

Release Log

ossp-framework-common

  1. XML和Properties配置文件读取功能，支持动态监听。
  2. HTTP请求，支持URL负载均衡。
  3. 提供基本的IO和流相关的操作。
  4. 提供邮件和短信发送相关类。
  5. 提供资源寻址和路径相关的工具类。
  6. 提供常用加密解密相关操作的类。
  7. XML和JSON序列化和反序列化操作。
  8. Tomcat端口和服务器IP检测。
  9. 提供用于文本处理相关的类和接口，封装基本的正则操作。
  10. 其他工具类：gzip压缩，FTP帮助类，类型转换的try-parse工具类。

ossp-framework-usdl

  1. MongoDB连接池管理。
  2. Mysql连接池管理。
  3. Redis连接池管理。
  4. Solr连接池管理。
  5. Tfs连接池管理。

ossp-framework-dt

  1. 基准测试基类。
  2. JMeter测试基类。
  3. Testng单元测试基类。

POM Dependency

Nexus私服

ossp-framework-common

  1. <dependency>
  2.   <groupId>com.iflytek</groupId>
  3.   <artifactId>ossp-framework-common</artifactId>
  4.   <version>1.0.1</version>
  5. </dependency>

ossp-framework-usdl

  1. <dependency>
  2.   <groupId>com.iflytek</groupId>
  3.   <artifactId>ossp-framework-usdl</artifactId>
  4.   <version>1.0.1</version>
  5. </dependency>

ossp-framework-dt

  1. <dependency>
  2.   <groupId>com.iflytek</groupId>
  3.   <artifactId>ossp-framework-dt</artifactId>
  4.   <version>1.0.1</version>
  5. </dependency>

Javadoc

点击查看
使用示例，请查看Example Packages的内容。

Benchmark（基准测试）

点击查看

性能测试

Change Log

详细的修改日志，请点击查看。

Example

引入ossp-framework-example可以查看示例代码：

  1. <dependency>
  2.   <groupId>com.iflytek</groupId>
  3.   <artifactId>ossp-framework-example</artifactId>
  4.   <version>1.0.2-SNAPSHOT</version>
  5. </dependency>

MyqlClientExample

  1. package com.iflytek.ossp.framework.example.usdl.mysql;
  3. import java.beans.PropertyVetoException;
  4. import java.io.IOException;
  5. import java.net.URISyntaxException;
  6. import java.sql.ResultSet;
  7. import java.sql.SQLException;
  8. import java.util.Iterator;
  9. import java.util.Random;
  11. import com.iflytek.ossp.framework.usdl.mysql.ConnectionCallback;
  12. import com.iflytek.ossp.framework.usdl.mysql.MySqlClient;
  13. import com.iflytek.ossp.framework.usdl.mysql.MySqlConnectionManagement;
  15. /**
  16.  * 
  17.  * {@link MySqlClient} API使用示例。
  18.  * 
  19.  * @author jdzhan,2014-9-22
  20.  * 
  21.  */
  22. public class MyqlClientExample {
  24.     static Random random = new Random();
  26.     public static void main(String[] args) throws PropertyVetoException, IOException, URISyntaxException, SQLException,
  27.             IllegalAccessException {
  28.         MySqlConnectionManagement.load();
  29.         System.out.println("执行存储过程，只能处理第一个结果集：");
  30.         execProcedureExample();
  31.         System.out.println("执行存储过程，可以处理多结果集：");
  32.         execMutilResultProcedureExample();
  33.         System.out.println("执行存储过程，也可以不指定回调接口，返回null：");
  34.         execProcedureWithNullCallback();
  35.         MySqlConnectionManagement.destroy();
  36.     }
  38.     // 执行存储过程，只返回第一个结果集。
  39.     private static void execProcedureExample() throws PropertyVetoException, IOException, SQLException,
  40.             URISyntaxException, IllegalAccessException {
  41.         MySqlClient<Object> client = MySqlConnectionManagement.sharedClient("example-2");
  42.         int i = random.nextInt(100);
  43.         client.execProc("test_query_proc4", new ConnectionCallback<String>() {
  45.             @Override
  46.             public String callback(ResultSet resultSet) throws SQLException {
  47.                 while (resultSet.next()) {
  48.                     System.out.println(resultSet.getString(1));
  49.                 }
  50.                 return "";
  51.             }
  52.         }, "framework-" + i, i);
  53.     }
  55.     // 执行多结果集的存储过程。
  56.     // begin
  57.     // insert into test(name,age,description,height)
  58.     // values('zdd',11,'dede',122);
  59.     // select 1;
  60.     // select 2;
  61.     // select 3;
  62.     // select 4;
  63.     // end;
  64.     private static void execMutilResultProcedureExample() throws PropertyVetoException, IOException,
  65.             URISyntaxException, IllegalAccessException, SQLException {
  66.         MySqlClient<Object> client = MySqlConnectionManagement.sharedClient("example-2");
  67.         int i = random.nextInt(100);
  68.         client.execMutilProc("test_query_proc4",
  69.                 new com.iflytek.ossp.framework.usdl.mysql.ConnectionMutilCallback<String>() {
  71.                     @Override
  72.                     public String callback(Iterable<ResultSet> resultSets) throws SQLException {
  73.                         Iterator<ResultSet> iterator = resultSets.iterator();
  74.                         for (ResultSet resultSet : resultSets) {
  75.                             while (resultSet.next()) {
  76.                                 System.out.println(resultSet.getString(1));
  77.                             }
  78.                         }
  79.                         return "";
  80.                     }
  81.                 }, "framework-" + i, i);
  82.     }
  84.     /** 可以不知道回调接口，返回结果为null */
  85.     private static void execProcedureWithNullCallback() throws PropertyVetoException, IOException, URISyntaxException,
  86.             IllegalAccessException, SQLException {
  87.         MySqlClient<Object> client = MySqlConnectionManagement.sharedClient("example-2");
  88.         int i = random.nextInt(100);
  89.         Object result = client.execMutilProc("test_query_proc4", null, "framework-" + i, i);
  90.         System.out.println("result:" + result);
  91.         result = client.execProc("test_query_proc4", null, "framework-" + i, i);
  92.         System.out.println("result:" + result);
  93.     }
  95. }

MysqlConnectionManagementExample

  1. package com.iflytek.ossp.framework.example.usdl.mysql;
  3. import java.beans.PropertyVetoException;
  4. import java.io.IOException;
  5. import java.net.URISyntaxException;
  6. import java.sql.ResultSet;
  7. import java.sql.SQLException;
  9. import com.iflytek.ossp.framework.usdl.mysql.ConnectionCallback;
  10. import com.iflytek.ossp.framework.usdl.mysql.MySqlClient;
  11. import com.iflytek.ossp.framework.usdl.mysql.MySqlConnectionManagement;
  13. /**
  14.  * {@link MySqlConnectionManagement}使用示例。
  15.  * 
  16.  */
  17. public class MysqlConnectionManagementExample {
  18.     public static void main(String[] args) throws PropertyVetoException, IOException, URISyntaxException, SQLException,
  19.             IllegalAccessException {
  20.         // 在调用之前需要先调用load方法，默认无参的方法会初始化classpath:config/dbaccess/mysql路径下的所有配置。
  21.         // 默认使用c3p0连接池，如果需要使用druid或dbcp，请在配置文件中指定dataSource的值为c3p0.
  22.         MySqlConnectionManagement.load();
  23.         // 重复调用无效
  24.         MySqlConnectionManagement.load("/error/path");
  25.         MySqlClient<Object> client = MySqlConnectionManagement.sharedClient("example");
  26.         int rst = (Integer) client.query("select count(*) as count from pet", new TestQueryCallback());
  27.         System.out.println(rst);
  29.         // insert和update操作
  30.         rst = client.update("insert into pet(name,psssword)values('zjd3','121313')");
  31.         System.out.println(rst);
  33.         rst = client.update("update pet set name = 'zs' where name = 'zjd3'");
  34.         System.out.println(rst);
  36.         // 程序关闭的时候建议调用静态方法来销毁资源。
  37.         MySqlConnectionManagement.destroy();
  39.         // 如果配置文件不是在默认的classpath路径下，可以调用重载的load方法指定父级路径,
  40.         // 但注意配置文件所在的上级目录必须为mysql,如下面的参数则配置文件在classpath:config/mysql路径下
  41.         MySqlConnectionManagement.load("classpath:config");
  42.         client = MySqlConnectionManagement.sharedClient("example2");
  43.         rst = (Integer) client.query("select count(*) as count from pet", new TestQueryCallback());
  44.         System.out.println(rst);
  46.         // insert和update操作
  47.         rst = client.update("insert into pet(name,psssword)values('zjd3','121313')");
  48.         System.out.println(rst);
  50.         rst = client.update("update pet set name = 'zs' where name = 'zjd3'");
  51.         System.out.println(rst);
  53.         MySqlConnectionManagement.destroy();
  55.         // dbcp example
  56.         // 注意dbcp除了基本的配置项 其余的和c3p0以及druid差别较大。
  57.         MySqlConnectionManagement.load();
  58.         // 重复调用无效
  59.         client = MySqlConnectionManagement.sharedClient("example-dbcp");
  60.         rst = (Integer) client.query("select count(*) as count from pet", new TestQueryCallback());
  61.         System.out.println(rst);
  63.         // insert和update操作
  64.         rst = client.update("insert into pet(name,psssword)values('zjd3','121313')");
  65.         System.out.println(rst);
  67.         rst = client.update("update pet set name = 'zs' where name = 'zjd3'");
  68.         System.out.println(rst);
  70.         // 程序关闭的时候建议调用静态方法来销毁资源。
  71.         MySqlConnectionManagement.destroy();
  73.         // 父级路径也可以是绝对路径，如：配置文件在D:\example\mysql下。
  74.         MySqlConnectionManagement.load("file:D:\\example");
  75.         // 或
  76.         // MySqlConnectionManagement.load("D:\\example");
  77.         // 或
  78.         // MySqlConnectionManagement.load("D:/example");
  80.         // reload:相当于先destroy再load
  81.         MySqlConnectionManagement.reload("file:D:\\example");
  83.         MySqlConnectionManagement.destroy();
  84.     }
  86.     public static class TestQueryCallback implements ConnectionCallback<Integer> {
  88.         @Override
  89.         public Integer callback(ResultSet resultSet) throws SQLException {
  90.             while (resultSet.next()) {
  91.                 return resultSet.getInt("count");
  92.             }
  93.             return -1;
  94.         }
  95.     }
  97. }

FastjsonExample

  1. package com.iflytek.ossp.framework.example.common.serializable;
  3. import java.util.ArrayList;
  4. import java.util.List;
  6. import com.alibaba.fastjson.annotation.JSONField;
  7. import com.alibaba.fastjson.serializer.SerializerFeature;
  8. import com.iflytek.ossp.framework.common.serializable.JSONRoot;
  9. import com.iflytek.ossp.framework.common.serializable.SerializationInstance;
  10. import com.iflytek.ossp.framework.common.serializable.SerializationTools;
  11. import com.thoughtworks.xstream.annotations.XStreamAlias;
  12. import com.thoughtworks.xstream.annotations.XStreamImplicit;
  13. import com.thoughtworks.xstream.annotations.XStreamOmitField;
  15. /**
  16.  * 
  17.  * {@link SerializationTools#fastFromJson(Class, String)}<br />
  18.  * {@link SerializationTools#fastToJson(Object)}<br />
  19.  * 
  20.  * @author jdzhan,2014-8-21
  21.  * 
  22.  */
  23. public class FastjsonExample {
  25.     static SerializationInstance tools = SerializationInstance.sharedInstance();
  27.     public static void main(String[] args) throws IllegalStateException, Exception {
  28.         // annotationBenchmark();
  29.         fastJsonExample();
  30.     }
  32.     public static void fastJsonExample() throws SecurityException, IllegalArgumentException, NoSuchFieldException,
  33.             IllegalAccessException {
  34.         A a = new A();
  35.         a.setStr1("str1");
  36.         a.setStr2("str2");
  38.         List<String> list = new ArrayList<String>();
  39.         list.add("item1");
  40.         list.add("item1");
  41.         a.setLists(list);
  43.         List<B> barr = new ArrayList<FastjsonExample.B>();
  44.         for (int i = 0; i < 2; i++) {
  45.             B b = new B();
  46.             b.setBstr1("b str1");
  47.             b.setBstr2("b str2");
  48.             barr.add(b);
  49.         }
  50.         a.setBarr(barr);
  52.         // fastjson
  53.         String json = tools.fastToJson(a, true);
  54.         System.out.println("fastjson result:\r\n" + json);
  56.         A newA = tools.fastFromJson(A.class, json);
  57.         System.out.println(newA);
  59.         // xstream
  60.         json = tools.toJson(a);
  61.         System.out.println("xstream result:\r\n" + json);
  63.         newA = tools.fromJson(A.class, json);
  64.         System.out.println(newA);
  65.     }
  67.     @XStreamAlias("abc")
  68.     @JSONRoot(name = "abc")
  69.     public static class A {
  71.         /** 忽略 */
  72.         @JSONField(serialize = false)
  73.         // fastjson
  74.         @XStreamOmitField
  75.         // xstream
  76.         public String str1 = "str1";
  78.         /** 指定别名 */
  79.         @JSONField(name = "name")
  80.         // xtream
  81.         @XStreamAlias("name")
  82.         // fastjson
  83.         public String str2;
  85.         /** 未指定默认为0 */
  86.         @JSONField(serialzeFeatures = { SerializerFeature.WriteNullNumberAsZero })
  87.         // fastjson
  88.         public int ivalue;
  90.         /** 未指定默认为空字符串 */
  91.         @JSONField(serialzeFeatures = { SerializerFeature.WriteNullStringAsEmpty })
  92.         // fastjson
  93.         public String str3;
  95.         @JSONField(name = "items")
  96.         @XStreamImplicit(itemFieldName = "key")
  97.         public List<String> lists;
  99.         @JSONField(name = "bitems")
  100.         @XStreamAlias("bitems")
  101.         //@XStreamImplicit(itemFieldName = "bitem")
  102.         public List<B> barr;
  104.         public String getStr1() {
  105.             return str1;
  106.         }
  108.         public void setStr1(String str1) {
  109.             this.str1 = str1;
  110.         }
  112.         public String getStr2() {
  113.             return str2;
  114.         }
  116.         public void setStr2(String str2) {
  117.             this.str2 = str2;
  118.         }
  120.         public int getIvalue() {
  121.             return ivalue;
  122.         }
  124.         public void setIvalue(int ivalue) {
  125.             this.ivalue = ivalue;
  126.         }
  128.         public String getStr3() {
  129.             return str3;
  130.         }
  132.         public void setStr3(String str3) {
  133.             this.str3 = str3;
  134.         }
  136.         public List<String> getLists() {
  137.             return lists;
  138.         }
  140.         public void setLists(List<String> lists) {
  141.             this.lists = lists;
  142.         }
  144.         public List<B> getBarr() {
  145.             return barr;
  146.         }
  148.         public void setBarr(List<B> barr) {
  149.             this.barr = barr;
  150.         }
  152.         @Override
  153.         public String toString() {
  154.             return "str1:" + str1 + ",str2:" + str2 + ",str3:" + str3 + ",ivalue" + ivalue + ",lists:" + lists
  155.                     + "B list:" + barr;
  156.         }
  158.     }
  160.     public static class B {
  161.         private String bstr1;
  162.         private String bstr2;
  164.         public String getBstr1() {
  165.             return bstr1;
  166.         }
  168.         public void setBstr1(String bstr1) {
  169.             this.bstr1 = bstr1;
  170.         }
  172.         public String getBstr2() {
  173.             return bstr2;
  174.         }
  176.         public void setBstr2(String bstr2) {
  177.             this.bstr2 = bstr2;
  178.         }
  180.         @Override
  181.         public String toString() {
  182.             return "bstr1:" + bstr1 + ",bstr2:" + bstr2;
  183.         }
  184.     }
  185. }

SimpleXmlExample

  1. package com.iflytek.ossp.framework.example.common.serializable;
  3. import java.util.Date;
  5. import org.simpleframework.xml.Attribute;
  6. import org.simpleframework.xml.Element;
  7. import org.simpleframework.xml.ElementList;
  8. import org.simpleframework.xml.Root;
  10. import com.iflytek.ossp.framework.common.serializable.SerializationInstance;
  11. import com.iflytek.ossp.framework.example.ExampleUtils;
  12. import com.iflytek.ossp.framework.example.common.serializable.weather.cmcc.CmccWeatherBaseResponseObject;
  13. import com.iflytek.ossp.framework.example.common.serializable.weather.cmcc.Result;
  14. import com.thoughtworks.xstream.annotations.XStreamAlias;
  15. import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
  16. import com.thoughtworks.xstream.annotations.XStreamImplicit;
  17. import com.thoughtworks.xstream.annotations.XStreamOmitField;
  19. /**
  20.  * 
  21.  * Simple XML API示例：{@link SerializationInstance#simpleToXml(Object)},
  22.  * {@link SerializationInstance#simpleFromXml(Class, String)}<br />
  23.  * 详细参看：<a href=
  24.  * "http://simple.sourceforge.net/download/stream/doc/examples/examples.php"
  25.  * >http://simple.sourceforge.net/download/stream/doc/examples/examples.php</a> <br />
  26.  * <a href=
  27.  * "http://simple.sourceforge.net/download/stream/doc/tutorial/tutorial.php"
  28.  * >http://simple.sourceforge.net/download/stream/doc/tutorial/tutorial.php</a>
  29.  * 
  30.  * <p>
  31.  * XStream的注解，Simple-XML基本都有等价的，{@link CmccWeatherBaseResponseObject}。<br />
  32.  * <code>CDATA => @Element(data = true)</code><br/>
  33.  * <code>@XStreamAlias("allresult") => @Root(name ="root"),@Element(name="test")</code>
  34.  * <br/>
  35.  * <code>@XStreamAsAttribute => @Attribute</code><br/>
  36.  * <code>@XStreamImplicit(itemFieldName = "result") => @ElementList(name = "resultlist", inline = true)</code>
  37.  * <br/>
  38.  * <code>@XStreamOmitField => 没有注解</code>
  39.  * 
  40.  * @author jdzhan,2014-9-10
  41.  * 
  42.  */
  43. public class SimpleXmlExample {
  45.     static SerializationInstance tools = SerializationInstance.sharedInstance();
  47.     public static void main(String[] args) throws Exception {
  48.         SimpleObject vo = new SimpleObject();
  49.         vo.setUserName("michael");
  50.         vo.setRealName("大大");
  51.         vo.setWife("小小");
  52.         vo.setHeight(173.3d);
  53.         vo.setBornDate(new Date());
  55.         Configuration conf = new Configuration();
  56.         Server server = new Server();
  57.         Security security = new Security();
  58.         server.setSecurity(security);
  59.         conf.setServer(server);
  61.         security.setKeyStore("KeyStore");
  62.         security.setSsl(false);
  63.         server.setHost("172.16.1.1");
  64.         server.setPort(8080);
  65.         conf.setId(1);
  67.         System.out.println("======================================================");
  68.         System.out.println("simple object example:");
  69.         // simple object
  70.         String xml = tools.simpleToXml(vo);
  71.         System.out.println(xml);
  72.         vo = tools.simpleFromXml(SimpleObject.class, xml);
  73.         System.out.println(vo);
  75.         System.out.println("======================================================");
  76.         System.out.println("nested object example:");
  77.         // nested object
  78.         xml = tools.simpleToXml(conf);
  79.         System.out.println(xml);
  80.         conf = tools.simpleFromXml(Configuration.class, xml);
  81.         System.out.println(conf.getServer().getSecurity().getKeyStore());
  83.         System.out.println("======================================================");
  84.         System.out.println("complex object & annotation vs XStream:");
  85.         // annotation
  86.         xml = ExampleUtils.readFile("classpath:serializable/cmcc.xml");
  87.         System.out.println(xml);
  88.         // XStream
  89.         CmccWeatherBaseResponseObject obj = tools.fromXml(CmccWeatherBaseResponseObject.class, xml);
  90.         System.out.println(obj);
  92.         // Simple-XML
  93.         xml = tools.simpleToXml(obj);
  94.         System.out.println(xml);
  96.     }
  98.     @Root(name = "root")
  99.     public static class SimpleObject {
  101.         @Element(name = "UserName")
  102.         private String userName;
  104.         @Attribute(name = "MyWife")
  105.         private String wife;
  107.         // CDATA
  108.         @Element(name = "RealName", data = true)
  109.         private String realName;
  111.         @Element(name = "BornDate")
  112.         private Date bornDate;
  114.         @Element(name = "Height")
  115.         private Double height;
  117.         public String toString() {
  118.             return "MyTestVo : [ userName = " + userName + " , wife = " + wife + " , realName = " + realName
  119.                     + " , height = " + height + " , bornDate = " + bornDate + " ]";
  120.         }
  122.         public String getUserName() {
  123.             return userName;
  124.         }
  126.         public void setUserName(String userName) {
  127.             this.userName = userName;
  128.         }
  130.         public String getWife() {
  131.             return wife;
  132.         }
  134.         public void setWife(String wife) {
  135.             this.wife = wife;
  136.         }
  138.         public String getRealName() {
  139.             return realName;
  140.         }
  142.         public void setRealName(String realName) {
  143.             this.realName = realName;
  144.         }
  146.         public Date getBornDate() {
  147.             return bornDate;
  148.         }
  150.         public void setBornDate(Date bornDate) {
  151.             this.bornDate = bornDate;
  152.         }
  154.         public Double getHeight() {
  155.             return height;
  156.         }
  158.         public void setHeight(Double height) {
  159.             this.height = height;
  160.         }
  161.     }
  163.     @Root(name = "root")
  164.     @XStreamAlias("root")
  165.     public static class Configuration {
  167.         @Element
  168.         private Server server;
  170.         @Attribute
  171.         @XStreamAsAttribute
  172.         private int id;
  174.         public int getIdentity() {
  175.             return id;
  176.         }
  178.         public Server getServer() {
  179.             return server;
  180.         }
  182.         public int getId() {
  183.             return id;
  184.         }
  186.         public void setId(int id) {
  187.             this.id = id;
  188.         }
  190.         public void setServer(Server server) {
  191.             this.server = server;
  192.         }
  194.     }
  196.     public static class Server {
  198.         @Attribute
  199.         private int port;
  201.         @Element
  202.         private String host;
  204.         @Element
  205.         private Security security;
  207.         public int getPort() {
  208.             return port;
  209.         }
  211.         public String getHost() {
  212.             return host;
  213.         }
  215.         public Security getSecurity() {
  216.             return security;
  217.         }
  219.         public void setPort(int port) {
  220.             this.port = port;
  221.         }
  223.         public void setHost(String host) {
  224.             this.host = host;
  225.         }
  227.         public void setSecurity(Security security) {
  228.             this.security = security;
  229.         }
  231.     }
  233.     public static class Security {
  235.         @Attribute
  236.         @XStreamAsAttribute
  237.         private boolean ssl;
  239.         @Element
  240.         private String keyStore;
  242.         public boolean isSSL() {
  243.             return ssl;
  244.         }
  246.         public String getKeyStore() {
  247.             return keyStore;
  248.         }
  250.         public boolean isSsl() {
  251.             return ssl;
  252.         }
  254.         public void setSsl(boolean ssl) {
  255.             this.ssl = ssl;
  256.         }
  258.         public void setKeyStore(String keyStore) {
  259.             this.keyStore = keyStore;
  260.         }
  262.     }
  264. }
添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注