Merge pull request #427 from pasocon1993/master

add sms tools

Author: longbai

examples/SendMessageDemo.java

@@ -0,0 +1,38 @@
+import com.qiniu.common.QiniuException;
+import com.qiniu.http.Response;
+import com.qiniu.sms.SmsManager;
+import com.qiniu.util.Auth;
+
+public class SendMessageDemo {
+	 public static void main(String args[]) {
+	        //设置需要操作的账号的AK和SK
+	        String ACCESS_KEY = "test";
+	        String SECRET_KEY = "test";
+	        Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
+
+
+	        //实例化一个SmsManager对象
+	        SmsManager smsManager = new SmsManager(auth);
+ 
+	        
+
+	        try {
+//	        	Map<String,String> map = new HashMap<String,String>();
+//	        	Response resp = smsManager.sendMessage("templateId", new String[] {"10086"}, map);
+//	        	Response resp = smsManager.describeSignature("passed",0,0);
+//	        	SignatureInfo sinfo =  smsManager.describeSignatureItems("rejected",0,0);
+//	            Response resp = smsManager.createSignature("signature", "app", new String[] {"data:image/gif;base64,xxxxxxxxxx"});
+	        	Response resp = smsManager.describeTemplate("passed",0,0);
+//	            Response resp = smsManager.createTemplate("name","template","notification","test","signatureId");
+//	        	Response resp = smsManager.modifyTemplate("templateId","name","template","test","signatureId");
+//	        	Response resp = smsManager.modifySignature("SignatureId","signature");
+//	        	Response resp = smsManager.deleteSignature("signatureId");
+//	        	Response resp = smsManager.deleteTemplate("templateId");
+	        	System.out.println(resp.bodyString());
+	        } catch (QiniuException e) {
+	        	System.out.println(e);
+	        }
+	        
+
+	    }
+}

src/main/java/com/qiniu/http/Client.java

@@ -44,7 +44,14 @@ public Client(Configuration cfg) {
                 cfg.dispatcherMaxRequests, cfg.dispatcherMaxRequestsPerHost,
                 cfg.connectionPoolMaxIdleCount, cfg.connectionPoolMaxIdleMinutes);
     }
-
+    
+    public Client(com.qiniu.sms.Configuration cfg) {
+        this(null, false, null,
+                cfg.connectTimeout, cfg.readTimeout, cfg.writeTimeout,
+                cfg.dispatcherMaxRequests, cfg.dispatcherMaxRequestsPerHost,
+                cfg.connectionPoolMaxIdleCount, cfg.connectionPoolMaxIdleMinutes);
+    }
+    
     /**
      * 构建一个自定义配置的 HTTP Client 类
      */
@@ -175,6 +182,17 @@ public Response post(String url, byte[] body, StringMap headers, String contentT
         }
         return post(url, rbody, headers);
     }
+    
+    public Response put(String url, byte[] body, StringMap headers, String contentType) throws QiniuException {
+        RequestBody rbody;
+        if (body != null && body.length > 0) {
+            MediaType t = MediaType.parse(contentType);
+            rbody = RequestBody.create(t, body);
+        } else {
+            rbody = RequestBody.create(null, new byte[0]);
+        }
+        return put(url, rbody, headers);
+    }
 
     public Response post(String url, byte[] body, int offset, int size,
                          StringMap headers, String contentType) throws QiniuException {
@@ -192,6 +210,11 @@ private Response post(String url, RequestBody body, StringMap headers) throws Qi
         Request.Builder requestBuilder = new Request.Builder().url(url).post(body);
         return send(requestBuilder, headers);
     }
+    
+    private Response put(String url, RequestBody body, StringMap headers) throws QiniuException {
+        Request.Builder requestBuilder = new Request.Builder().url(url).put(body);
+        return send(requestBuilder, headers);
+    }
 
     public Response multipartPost(String url,
                                   StringMap fields,
@@ -306,6 +329,7 @@ public void accept(String key, Object value) {
             e.printStackTrace();
             throw new QiniuException(e);
         }
+     
         r = Response.create(res, tag.ip, duration);
         if (r.statusCode >= 300) {
             throw new QiniuException(r);

src/main/java/com/qiniu/http/MethodType.java

@@ -0,0 +1,20 @@
+package com.qiniu.http;
+
+public enum MethodType {
+	GET(false),
+    PUT(true),
+    POST(true),
+    DELETE(false),
+    HEAD(false),
+    OPTIONS(false);
+
+    private boolean hasContent;
+
+    MethodType(boolean hasContent) {
+        this.hasContent = hasContent;
+    }
+
+    public boolean hasContent() {
+        return hasContent;
+    }
+}

src/main/java/com/qiniu/sms/Configuration.java

@@ -0,0 +1,60 @@
+package com.qiniu.sms;
+
+import com.qiniu.common.Constants;
+
+public class Configuration implements Cloneable{
+	 /**
+     * 连接超时时间 单位秒(默认10s)
+     */
+    public int connectTimeout = Constants.CONNECT_TIMEOUT;
+    /**
+     * 写超时时间 单位秒(默认 0 , 不超时)
+     */
+    public int writeTimeout = Constants.WRITE_TIMEOUT;
+    /**
+     * 回复超时时间 单位秒(默认30s)
+     */
+    public int readTimeout = Constants.READ_TIMEOUT;
+    /**
+     * 底层HTTP库所有的并发执行的请求数量
+     */
+    public int dispatcherMaxRequests = Constants.DISPATCHER_MAX_REQUESTS;
+    /**
+     * 底层HTTP库对每个独立的Host进行并发请求的数量
+     */
+    public int dispatcherMaxRequestsPerHost = Constants.DISPATCHER_MAX_REQUESTS_PER_HOST;
+    /**
+     * 底层HTTP库中复用连接对象的最大空闲数量
+     */
+    public int connectionPoolMaxIdleCount = Constants.CONNECTION_POOL_MAX_IDLE_COUNT;
+    /**
+     * 底层HTTP库中复用连接对象的回收周期（单位分钟）
+     */
+    public int connectionPoolMaxIdleMinutes = Constants.CONNECTION_POOL_MAX_IDLE_MINUTES;
+    /**
+     * 上传失败重试次数
+     */
+    public int retryMax = 5;
+    
+    /*
+     * 特殊默认域名
+     */
+    public static String defaultSmsHost = "https://sms.qiniuapi.com";
+    
+    public Configuration() {
+    }
+    
+    public Configuration clone() {
+        try {
+            return (Configuration) super.clone();
+        } catch (CloneNotSupportedException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+    
+    public String smsHost() {
+        return defaultSmsHost;
+    }
+
+}