- *
- * @author 陈雄华
- * @version 1.0
- */
-public interface CompositeResponse {
-
- /**
- * 获取错误的响应对象
- *
- * @return
- */
- ErrorResponse getErrorResponse();
-
- /**
- * 获取正确的响应对象
- *
- * @param responseClass
- * @param
- * @return
- */
- T getSuccessResponse();
-
- /**
- * 响应是否是正确的
- *
- * @return
- */
- boolean isSuccessful();
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client;
+
+import com.rop.response.ErrorResponse;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-public class DefaultCompositeResponse implements CompositeResponse {
-
- private boolean successful;
-
- private ErrorResponse errorResponse;
-
- private T successRopResponse;
-
- public DefaultCompositeResponse(boolean successful) {
- this.successful = successful;
- }
-
-
- public ErrorResponse getErrorResponse() {
- return this.errorResponse;
- }
-
-
- public T getSuccessResponse() {
- return this.successRopResponse;
- }
-
- public void setErrorResponse(ErrorResponse errorResponse) {
- this.errorResponse = errorResponse;
- }
-
- public void setSuccessRopResponse(T successRopResponse) {
- this.successRopResponse = successRopResponse;
- }
-
-
- public boolean isSuccessful() {
- return successful;
- }
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client;
+
+import com.rop.response.ErrorResponse;
+
+/**
+ *
+ * 功能说明：
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public class DefaultCompositeResponse implements CompositeResponse {
+
+ private boolean successful;
+
+ private ErrorResponse errorResponse;
+
+ private T successRopResponse;
+
+ public DefaultCompositeResponse(boolean successful) {
+ this.successful = successful;
+ }
+
+
+ public ErrorResponse getErrorResponse() {
+ return this.errorResponse;
+ }
+
+
+ public T getSuccessResponse() {
+ return this.successRopResponse;
+ }
+
+ public void setErrorResponse(ErrorResponse errorResponse) {
+ this.errorResponse = errorResponse;
+ }
+
+ public void setSuccessRopResponse(T successRopResponse) {
+ this.successRopResponse = successRopResponse;
+ }
+
+
+ public boolean isSuccessful() {
+ return successful;
+ }
+}
+
diff --git a/rop-client/src/main/java/com/rop/client/DefaultRopClient.java b/rop-client/src/main/java/com/rop/client/DefaultRopClient.java
new file mode 100644
index 0000000..e9a6629
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/DefaultRopClient.java
@@ -0,0 +1,487 @@
+/*
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client;
+
+import org.apache.commons.lang.ClassUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.rop.MessageFormat;
+import com.rop.RopMarshaller;
+import com.rop.RopUnmarshaller;
+import com.rop.annotation.IgnoreSign;
+import com.rop.client.http.HttpClient;
+import com.rop.client.http.HttpResponse;
+import com.rop.client.http.JdkHttpClient;
+import com.rop.config.SystemParameterNames;
+import com.rop.converter.RopConverter;
+import com.rop.converter.UploadFile;
+import com.rop.converter.UploadFileConverter;
+import com.rop.marshaller.FastjsonRopMarshaller;
+import com.rop.marshaller.JaxbXmlRopMarshaller;
+import com.rop.response.ErrorResponse;
+import com.rop.sign.SignHandler;
+import com.rop.unmarshaller.FastjsonRopUnmarshaller;
+import com.rop.unmarshaller.JaxbXmlRopUnmarshaller;
+import com.rop.utils.AnnotationUtils;
+import com.rop.utils.Assert;
+import com.rop.utils.ReflectionUtils;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.lang.reflect.Field;
+import java.util.*;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-public interface RopClient {
-
- /**
- * 添加自定义的转换器
- *
- * @param ropConverter
- */
- void addRopConvertor(RopConverter ropConverter);
-
- /**
- * 设置method系统参数的参数名，下同
- *
- * @param paramName
- * @return
- */
- RopClient setAppKeyParamName(String paramName);
-
- /**
- * 设置sessionId的参数名
- *
- * @param paramName
- * @return
- */
- RopClient setSessionIdParamName(String paramName);
-
- /**
- * 设置method的参数名
- *
- * @param paramName
- * @return
- */
- RopClient setMethodParamName(String paramName);
-
- /**
- * 设置version的参数名
- *
- * @param paramName
- * @return
- */
- RopClient setVersionParamName(String paramName);
-
- /**
- * 设置format的参数名
- *
- * @param paramName
- * @return
- */
- RopClient setFormatParamName(String paramName);
-
- /**
- * 设置locale的参数名
- *
- * @param paramName
- * @return
- */
- RopClient setLocaleParamName(String paramName);
-
- /**
- * 设置sign的参数名
- *
- * @param paramName
- * @return
- */
- RopClient setSignParamName(String paramName);
-
- /**
- * 设置sessionId
- *
- * @param sessionId
- */
- void setSessionId(String sessionId);
-
- /**
- * 创建一个新的服务请求
- * @return
- */
- ClientRequest buildClientRequest();
-}
-
+/*
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client;
+
+import com.rop.converter.RopConverter;
+import com.rop.sign.SignHandler;
+
+/**
+ *
+ * 功能说明：
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public interface RopClient {
+
+ /**
+ * 添加自定义的转换器
+ *
+ * @param ropConverter
+ */
+ void addRopConvertor(RopConverter ropConverter);
+
+ /**
+ * 设置method系统参数的参数名，下同
+ *
+ * @param paramName
+ * @return RopClient
+ */
+ RopClient setAppKeyParamName(String paramName);
+
+ /**
+ * 设置sessionId的参数名
+ *
+ * @param paramName
+ * @return RopClient
+ */
+ RopClient setSessionIdParamName(String paramName);
+
+ /**
+ * 设置method的参数名
+ *
+ * @param paramName
+ * @return RopClient
+ */
+ RopClient setMethodParamName(String paramName);
+
+ /**
+ * 设置version的参数名
+ *
+ * @param paramName
+ * @return RopClient
+ */
+ RopClient setVersionParamName(String paramName);
+
+ /**
+ * 设置format的参数名
+ *
+ * @param paramName
+ * @return RopClient
+ */
+ RopClient setFormatParamName(String paramName);
+
+ /**
+ * 设置locale的参数名
+ *
+ * @param paramName
+ * @return RopClient
+ */
+ RopClient setLocaleParamName(String paramName);
+
+ /**
+ * 设置sign的参数名
+ *
+ * @param paramName
+ * @return RopClient
+ */
+ RopClient setSignParamName(String paramName);
+
+ /**
+ * 设置sessionId
+ *
+ * @param sessionId
+ */
+ void setSessionId(String sessionId);
+
+ /**
+ * 设置签名处理接口对象
+ * @param handler
+ * @return RopClient
+ */
+ RopClient setSignHandler(SignHandler handler);
+
+ /**
+ * 创建一个新的服务请求
+ * @return
+ */
+ ClientRequest buildClientRequest();
+}
+
diff --git a/rop-client/src/main/java/com/rop/client/http/HttpClient.java b/rop-client/src/main/java/com/rop/client/http/HttpClient.java
new file mode 100644
index 0000000..e3b2419
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/http/HttpClient.java
@@ -0,0 +1,110 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.http;
+
+import java.io.IOException;
+import java.util.Map;
+
+/**
+ * 简单的http请求客户端接口
+ *
+ * @author liangruisen
+ *
+ */
+public interface HttpClient {
+
+ /**
+ * 同步发送HTTP GET 请求
+ * @param url
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse get(String url) throws IOException;
+
+ /**
+ * 同步发送HTTP GET 请求
+ * @param heads
+ * @param url
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse get(String url, Map params) throws IOException;
+
+ /**
+ * 设置HTTP Header信息并同步发送HTTP GET 请求
+ * @param heads
+ * @param url
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse get(Map heads, String url) throws IOException;
+
+ /**
+ * 设置HTTP Header信息并同步发送HTTP GET 请求
+ * @param heads
+ * @param url
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse get(Map heads, String url, Map params) throws IOException;
+
+ /**
+ * 同步发送HTTP POST 请求
+ * @param url
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse post(String url) throws IOException;
+
+ /**
+ * 设置HTTP Header信息并同步发送HTTP POST 请求
+ * @param heads
+ * @param url
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse post(Map heads, String url) throws IOException;
+
+ /**
+ * 同步发送HTTP POST 请求
+ * @param url
+ * @param params
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse post(String url, Map params) throws IOException;
+
+ /**
+ * 设置HTTP Header信息并同步发送HTTP POST 请求
+ * @param heads
+ * @param url
+ * @param params
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse post(Map heads, String url, Map params) throws IOException;
+
+ /**
+ * 设置HTTP Header信息并同步发送HTTP 请求
+ * @param heads
+ * @param url
+ * @param method
+ * @param params
+ * @return SimpleResponse
+ * @throws IOException
+ */
+ HttpResponse execute(Map heads, String url, String method, Map params) throws IOException;
+}
diff --git a/rop-client/src/main/java/com/rop/client/http/HttpRequest.java b/rop-client/src/main/java/com/rop/client/http/HttpRequest.java
new file mode 100644
index 0000000..e32cd46
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/http/HttpRequest.java
@@ -0,0 +1,67 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.http;
+
+import java.net.URI;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 简单的HTTP请求接口，用于获取该次请求的信息
+ * @author liangruisen
+ *
+ */
+public interface HttpRequest {
+
+ /**
+ * 获取实现请求的Request对象
+ * @return Object
+ */
+ Object getRequest();
+
+ /**
+ * 获取该次请求的URI
+ * @return URI
+ */
+ URI getURI();
+
+ /**
+ * 获取HTTP请求的方法名称，
+ * 返回 GET/POST/PUT/HEAD/OPTIONS/PATCH/DELETE/TRACE 中的一个
+ * @return String
+ */
+ String getMethod();
+
+ /**
+ * 获取指定名称的HTTP头信息的值
+ * @param name
+ * @return String
+ */
+ String getHeader(String name);
+
+ /**
+ * 获取获取指定名称的HTTP头信息的值列表
+ * @param name
+ * @return List
+ */
+ List getHeaders(String name);
+
+ /**
+ * 获取所有的HTTP头信息
+ * @return Map>
+ */
+ Map> getHeaders();
+}
diff --git a/rop-client/src/main/java/com/rop/client/http/HttpResponse.java b/rop-client/src/main/java/com/rop/client/http/HttpResponse.java
new file mode 100644
index 0000000..9b4d1d9
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/http/HttpResponse.java
@@ -0,0 +1,107 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.http;
+
+import java.io.Closeable;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 简单的HTTP请求返回结果接口，用于获取该次请求的结果信息
+ * @author liangruisen
+ *
+ */
+public interface HttpResponse extends Closeable {
+
+ /**
+ * 获取实现请求的Response对象
+ * @return Object
+ */
+ public Object getResponse();
+
+ /**
+ * 获取请求结果的内容字符串
+ * @return String
+ * @throws IOException
+ */
+ public String getString() throws IOException;
+
+ /**
+ * 获取请求结果的内容字节数组
+ * @return byte[]
+ * @throws IOException
+ */
+ public byte[] getBytes() throws IOException;
+
+ /**
+ * 获取请求结果的内容输入流
+ * @return InputStream
+ * @throws IOException
+ */
+ public InputStream getInputStream() throws IOException;
+
+ /**
+ * 获取请求的HTTP返回状态代码
+ * @return int
+ */
+ public int getCode();
+
+ /**
+ * 获取实现请求的Request对象
+ * @return Object
+ */
+ public Object getRequest();
+
+ /**
+ * 获取请求的返回消息
+ * @return String
+ */
+ public String getMessage();
+
+ /**
+ * 获取HTTP请求的方法名称，
+ * 返回 GET/POST/PUT/HEAD/OPTIONS/PATCH/DELETE/TRACE 中的一个
+ * @return String
+ */
+ public String getHeader(String name);
+
+ /**
+ * 获取指定名称的HTTP头信息的值
+ * @param name
+ * @return String
+ */
+ public List getHeaders(String name);
+
+ /**
+ * 获取所有的HTTP头信息
+ * @return Map>
+ */
+ public Map> getHeaders();
+
+ /**
+ * 获取该次请求是否正确返回
+ * @return boolean
+ */
+ public boolean isSuccessful();
+
+ /**
+ * 获取协议的名称及其版本信息
+ * @return String
+ */
+ public String getProtocol();
+}
diff --git a/rop-client/src/main/java/com/rop/client/http/JdkHttpClient.java b/rop-client/src/main/java/com/rop/client/http/JdkHttpClient.java
new file mode 100644
index 0000000..34c1c40
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/http/JdkHttpClient.java
@@ -0,0 +1,211 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.http;
+
+import java.io.IOException;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLEncoder;
+import java.util.List;
+import java.util.Locale;
+import java.util.Map;
+
+/**
+ * 简单的http请求客户端接口jdk实现
+ *
+ * @author liangruisen
+ *
+ */
+public class JdkHttpClient implements HttpClient {
+
+ /**
+ * @see com.rop.client.http.HttpClient#get(java.lang.String)
+ */
+ @Override
+ public HttpResponse get(String url) throws IOException {
+ return execute(null, url, "GET", null);
+ }
+
+ /**
+ * @see com.rop.client.http.HttpClient#get(java.lang.String, java.util.Map)
+ */
+ @Override
+ public HttpResponse get(String url, Map params) throws IOException {
+ return execute(null, url, "GET", params);
+ }
+
+ /**
+ * @see com.rop.client.http.HttpClient#get(java.util.Map,
+ * java.lang.String)
+ */
+ @Override
+ public HttpResponse get(Map heads, String url) throws IOException {
+ return execute(heads, url, "GET", null);
+ }
+
+ /**
+ * @see com.rop.client.http.HttpClient#get(java.util.Map, java.lang.String, java.util.Map)
+ */
+ @Override
+ public HttpResponse get(Map heads, String url, Map params) throws IOException {
+ return execute(heads, url, "GET", params);
+ }
+
+ /**
+ * @see
+ * com.rop.client.http.HttpClient#post(java.lang.String)
+ */
+ @Override
+ public HttpResponse post(String url) throws IOException {
+ return execute(null, url, "POST", null);
+ }
+
+ /**
+ * @see com.rop.client.http.HttpClient#post(java.util.Map,
+ * java.lang.String)
+ */
+ @Override
+ public HttpResponse post(Map heads, String url) throws IOException {
+ return execute(heads, url, "POST", null);
+ }
+
+ /**
+ * @see
+ * com.rop.client.http.HttpClient#post(java.lang.String,
+ * java.util.Map)
+ */
+ @Override
+ public HttpResponse post(String url, Map params) throws IOException {
+ return execute(null, url, "POST", params);
+ }
+
+ /**
+ * @see com.rop.client.http.HttpClient#post(java.util.Map,
+ * java.lang.String, java.util.Map)
+ */
+ @Override
+ public HttpResponse post(Map heads, String url, Map params) throws IOException {
+ return execute(heads, url, "POST", params);
+ }
+
+ /**
+ * @see
+ * com.rop.client.http.HttpClient#execute(java.util.Map,
+ * java.lang.String, java.lang.String, java.util.Map)
+ */
+ @Override
+ public HttpResponse execute(Map heads, String url, String method, Map params)
+ throws IOException {
+ JdkHttpRequest request = createRequest(heads, url, method.toUpperCase(Locale.US), params);
+ return execute(request);
+ }
+
+ private JdkHttpResponse execute(JdkHttpRequest request) throws IOException {
+ HttpURLConnection connection = (HttpURLConnection) request.getUrl().openConnection();
+ JdkHttpResponse response = new JdkHttpResponse(request, connection);
+ Map> headers = request.getHeaders();
+ if (headers != null) {
+ for (Map.Entry> entry : headers.entrySet()) {
+ String name = entry.getKey();
+ List list = entry.getValue();
+ for (String value : list) {
+ connection.addRequestProperty(name, value);
+ }
+ }
+ }
+ connection.setReadTimeout(1000 * 30);
+ connection.setConnectTimeout(1000 * 10);
+ connection.setRequestMethod(request.getMethod());
+ if (request.getBody() != null) {
+ connection.setDoOutput(true);
+ connection.setRequestProperty("Accept-Charset", "UTF-8");
+ connection.setRequestProperty("Content-Type", request.getBody().getType());
+ connection.setRequestProperty("Content-Length", String.valueOf(request.getBody().getContentSize()));
+ }
+ connection.connect();
+ if (request.getBody() != null) {
+ request.getBody().writeTo(connection.getOutputStream());
+ connection.getOutputStream().flush();
+ connection.getOutputStream().close();
+ }
+ return response;
+ }
+
+ private JdkHttpRequest createRequest(Map heads, String url, String method,
+ Map params) throws IOException {
+ JdkHttpRequest request = new JdkHttpRequest();
+ request.setMethod(method);
+ if (!isHasBodyMethod(method)) {
+ url = appendUrlParams(url, params);
+ } else {
+ request.setBody(parseParams(params));
+ }
+ URL urlobj = new URL(url);
+ request.setUrl(urlobj);
+ addHeaders(request, heads);
+ return request;
+ }
+
+ /**
+ * 在URL字符串后面拼接请求参数
+ * @param urlstring
+ * @param params
+ * @return String
+ * @throws IOException
+ */
+ public static String appendUrlParams(String urlstring, Map params) throws IOException {
+ if(params == null || params.isEmpty()){
+ return urlstring;
+ }
+ StringBuilder buf = new StringBuilder(512);
+ for(Map.Entry entry : params.entrySet()){
+ buf.append("&").append(entry.getKey()).append("=");
+ buf.append(URLEncoder.encode(entry.getValue(), "UTF-8"));
+ }
+ boolean hasParams = urlstring.indexOf("?") > 0;
+ if(!hasParams){
+ buf.replace(0, 1, "?");
+ }
+ buf.insert(0, urlstring);
+ return buf.toString();
+ }
+
+ private void addHeaders(JdkHttpRequest request, Map headers) {
+ if (headers == null || headers.isEmpty()) {
+ request.addHeader("Accept-Encoding", "gzip");
+ return;
+ }
+ headers.put("Accept-Encoding", "gzip");
+ for (Map.Entry entry : headers.entrySet()) {
+ request.addHeader(entry.getKey(), entry.getValue());
+ }
+ }
+
+ private JdkHttpRequestBody parseParams(Map params) throws IOException {
+ JdkHttpRequestBody body = new JdkHttpRequestBody();
+ if (params == null || params.isEmpty()) {
+ return body;
+ }
+ for (Map.Entry entry : params.entrySet()) {
+ body.add(entry.getKey(), entry.getValue());
+ }
+ return body;
+ }
+
+ private boolean isHasBodyMethod(String method) {
+ return method.equals("POST") || method.equals("PATCH") || method.equals("PUT") || method.equals("DELETE");
+ }
+}
diff --git a/rop-client/src/main/java/com/rop/client/http/JdkHttpRequest.java b/rop-client/src/main/java/com/rop/client/http/JdkHttpRequest.java
new file mode 100644
index 0000000..15bf7ca
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/http/JdkHttpRequest.java
@@ -0,0 +1,174 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.http;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.commons.lang.StringUtils;
+
+/**
+ * @author liangruisen
+ *
+ */
+public class JdkHttpRequest implements HttpRequest {
+
+ private String method;
+ private URL url;
+ private Map> headers = new HashMap>();
+
+ private JdkHttpRequestBody body;
+
+ /**
+ * @see com.rop.client.http.HttpRequest#getRequest()
+ */
+ @Override
+ public Object getRequest() {
+ return this;
+ }
+
+ /**
+ * @see com.rop.client.http.HttpRequest#getURI()
+ */
+ @Override
+ public URI getURI() {
+ try {
+ return url.toURI();
+ } catch (URISyntaxException e) {
+ }
+ return null;
+ }
+
+ /**
+ * @see com.rop.client.http.HttpRequest#getMethod()
+ */
+ @Override
+ public String getMethod() {
+ return method;
+ }
+
+ /**
+ * @see com.rop.client.http.HttpRequest#getHeader(java.lang.String)
+ */
+ @Override
+ public String getHeader(String name) {
+ List list = getHeaders(name);
+ if(list == null || list.isEmpty()){
+ return "";
+ }
+ return StringUtils.join(list, ";");
+ }
+
+ /**
+ * @see com.rop.client.http.HttpRequest#getHeaders(java.lang.String)
+ */
+ @Override
+ public List getHeaders(String name) {
+ return headers.get(name);
+ }
+
+ /**
+ * @see com.rop.client.http.HttpRequest#getHeaders()
+ */
+ @Override
+ public Map> getHeaders() {
+ return headers;
+ }
+
+ /**
+ * 设置http请求头信息
+ * @param headers
+ */
+ public void setHeaders(Map> headers){
+ if(headers != null){
+ this.headers.putAll(headers);
+ }
+ }
+
+ /**
+ * 添加http请求头信息
+ * @param name
+ * @param value
+ */
+ public void addHeader(String name, String value){
+ List list = headers.get(name);
+ if(list == null){
+ list = new ArrayList(1);
+ headers.put(name, list);
+ }
+ list.add(value);
+ }
+
+ /**
+ * 设置http请求头信息
+ * @param name
+ * @param value
+ */
+ public void setHeader(String name, String value){
+ List list = headers.get(name);
+ if(list == null){
+ list = new ArrayList(1);
+ headers.put(name, list);
+ }else{
+ list.clear();
+ }
+ list.add(value);
+ }
+
+ /**
+ * 设置http请求方法
+ */
+ public void setMethod(String method) {
+ this.method = method;
+ }
+
+ /**
+ * 获取http请求内容参数
+ * @return JdkRequestBody
+ */
+ public JdkHttpRequestBody getBody() {
+ return body;
+ }
+
+ /**
+ * 设置http请求内容参数
+ * @param body
+ */
+ public void setBody(JdkHttpRequestBody body) {
+ this.body = body;
+ }
+
+ /**
+ * 获取请求的链接
+ * @return
+ */
+ public URL getUrl() {
+ return url;
+ }
+
+ /**
+ * 设置请求的链接
+ * @param url
+ */
+ public void setUrl(URL url) {
+ this.url = url;
+ }
+}
diff --git a/rop-client/src/main/java/com/rop/client/http/JdkHttpRequestBody.java b/rop-client/src/main/java/com/rop/client/http/JdkHttpRequestBody.java
new file mode 100644
index 0000000..bcc8271
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/http/JdkHttpRequestBody.java
@@ -0,0 +1,57 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.http;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.net.URLEncoder;
+
+/**
+ * @author liangruisen
+ *
+ */
+public class JdkHttpRequestBody {
+
+ private String type = "application/x-www-form-urlencoded";
+
+ private ByteArrayOutputStream content = new ByteArrayOutputStream();
+
+ public String getType() {
+ return type;
+ }
+
+ public void setType(String type) {
+ this.type = type;
+ }
+
+ public long getContentSize() {
+ return content.size();
+ }
+
+ public void writeTo(OutputStream out) throws IOException{
+ content.writeTo(out);
+ }
+
+ public void add(String name, String value) throws IOException{
+ if(content.size() > 0){
+ content.write('&');
+ }
+ content.write(name.getBytes());
+ content.write('=');
+ content.write(URLEncoder.encode(value, "UTF-8").getBytes());
+ }
+}
diff --git a/rop-client/src/main/java/com/rop/client/http/JdkHttpResponse.java b/rop-client/src/main/java/com/rop/client/http/JdkHttpResponse.java
new file mode 100644
index 0000000..7595204
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/http/JdkHttpResponse.java
@@ -0,0 +1,165 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.http;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.HttpURLConnection;
+import java.util.List;
+import java.util.Locale;
+import java.util.Map;
+import java.util.zip.GZIPInputStream;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang.StringUtils;
+
+/**
+ * @author liangruisen
+ *
+ */
+public class JdkHttpResponse implements HttpResponse {
+
+ public JdkHttpResponse(JdkHttpRequest request,
+ HttpURLConnection connection) {
+ super();
+ this.request = request;
+ this.connection = connection;
+ }
+
+ private JdkHttpRequest request;
+
+ private HttpURLConnection connection;
+
+ /**
+ * @see java.io.Closeable#close()
+ */
+ @Override
+ public void close() throws IOException {
+ if(connection != null){
+ connection.disconnect();
+ }
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getResponse()
+ */
+ @Override
+ public Object getResponse() {
+ return this;
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getString()
+ */
+ @Override
+ public String getString() throws IOException {
+ return IOUtils.toString(getInputStream(), "UTF-8");
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getBytes()
+ */
+ @Override
+ public byte[] getBytes() throws IOException {
+ return IOUtils.toByteArray(getInputStream());
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getInputStream()
+ */
+ @Override
+ public InputStream getInputStream() throws IOException {
+ String contentEncoding = connection.getContentEncoding();
+ if(StringUtils.isNotBlank(contentEncoding) && contentEncoding.toLowerCase(Locale.US).indexOf("gzip") >= 0){
+ return new GZIPInputStream(connection.getInputStream());
+ }
+ return connection.getInputStream();
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getCode()
+ */
+ @Override
+ public int getCode() {
+ try {
+ return connection.getResponseCode();
+ } catch (IOException e) {
+ }
+ return -1;
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getRequest()
+ */
+ @Override
+ public Object getRequest() {
+ return request;
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getMessage()
+ */
+ @Override
+ public String getMessage() {
+ try {
+ return connection.getResponseMessage();
+ } catch (IOException e) {
+ }
+ return "";
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getHeader(java.lang.String)
+ */
+ @Override
+ public String getHeader(String name) {
+ return connection.getHeaderField(name);
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getHeaders(java.lang.String)
+ */
+ @Override
+ public List getHeaders(String name) {
+ return getHeaders().get(name);
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getHeaders()
+ */
+ @Override
+ public Map> getHeaders() {
+ return connection.getHeaderFields();
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#isSuccessful()
+ */
+ @Override
+ public boolean isSuccessful() {
+ int code = getCode();
+ return code >= 200 && code < 300;
+ }
+
+ /**
+ * @see com.rop.client.http.HttpResponse#getProtocol()
+ */
+ @Override
+ public String getProtocol() {
+ return request.getUrl().getProtocol();
+ }
+
+}
diff --git a/rop-client/src/main/java/com/rop/client/sign/DigestSignHandler.java b/rop-client/src/main/java/com/rop/client/sign/DigestSignHandler.java
new file mode 100644
index 0000000..f80e39d
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/sign/DigestSignHandler.java
@@ -0,0 +1,136 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.sign;
+
+import java.io.IOException;
+import java.security.GeneralSecurityException;
+import java.security.MessageDigest;
+import java.util.Collection;
+import java.util.Map;
+
+import com.rop.RopException;
+import com.rop.sign.SignHandler;
+import com.rop.utils.RopUtils;
+
+/**
+ * 消息摘要数字签名处理实现
+ * @author liangruisen
+ */
+public class DigestSignHandler implements SignHandler {
+
+ public DigestSignHandler() {
+ super();
+ }
+
+ public DigestSignHandler(String algorithm, String secret) {
+ super();
+ this.algorithm = algorithm;
+ this.secret = secret;
+ }
+
+ protected String secret;
+
+ protected String algorithm = "SHA-1";
+
+ /**
+ * 产生签名
+ * @see com.rop.sign.SignHandler#sign(java.util.Map)
+ */
+ @Override
+ public String sign(Map paramMap) {
+ return sign(paramMap, null);
+ }
+
+ /**
+ * 产生签名
+ * @see com.rop.sign.SignHandler#sign(java.util.Map, java.util.Collection)
+ */
+ @Override
+ public String sign(Map paramValues, Collection ignore) {
+ try {
+ StringBuilder sb = new StringBuilder();
+ sb.append(secret);
+ sb.append(RopUtils.getSignContent(paramValues, ignore));
+ sb.append(secret);
+ byte[] sha1Digest = getDigest(sb.toString());
+ return byte2hex(sha1Digest);
+ } catch (IOException e) {
+ throw new RopException(e);
+ }
+ }
+
+ /**
+ * 检查签名是否正确
+ * @see com.rop.sign.SignHandler#signCheck(java.lang.String, java.util.Map, java.util.Collection)
+ */
+ @Override
+ public boolean signCheck(String sign, Map paramMap, Collection ignore) {
+ String signValue = sign(paramMap, ignore);
+ return signValue.equals(sign);
+ }
+
+ /**
+ * 检查签名是否正确
+ * @see com.rop.sign.SignHandler#signCheck(java.lang.String, java.util.Map)
+ */
+ @Override
+ public boolean signCheck(String sign, Map paramMap) {
+ return signCheck(sign, paramMap, null);
+ }
+
+ /**
+ * 获取消息的摘要
+ * @param data
+ * @return
+ * @throws IOException
+ */
+ protected byte[] getDigest(String data) throws IOException {
+ byte[] bytes = null;
+ try {
+ MessageDigest md = MessageDigest.getInstance(algorithm);
+ bytes = md.digest(data.getBytes());
+ } catch (GeneralSecurityException gse) {
+ throw new IOException(gse.getMessage());
+ }
+ return bytes;
+ }
+
+ /**
+ * 二进制转十六进制字符串
+ *
+ * @param bytes
+ * @return
+ */
+ protected String byte2hex(byte[] bytes) {
+ StringBuilder sign = new StringBuilder();
+ for (int i = 0; i < bytes.length; i++) {
+ String hex = Integer.toHexString(bytes[i] & 0xFF);
+ if (hex.length() == 1) {
+ sign.append("0");
+ }
+ sign.append(hex.toUpperCase());
+ }
+ return sign.toString();
+ }
+
+ public void setSecret(String secret) {
+ this.secret = secret;
+ }
+
+ public void setAlgorithm(String algorithm) {
+ this.algorithm = algorithm;
+ }
+}
diff --git a/rop-client/src/main/java/com/rop/client/sign/HmacDigestSignHandler.java b/rop-client/src/main/java/com/rop/client/sign/HmacDigestSignHandler.java
new file mode 100644
index 0000000..e36630f
--- /dev/null
+++ b/rop-client/src/main/java/com/rop/client/sign/HmacDigestSignHandler.java
@@ -0,0 +1,81 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client.sign;
+
+import java.io.IOException;
+import java.security.GeneralSecurityException;
+import java.util.Collection;
+import java.util.Map;
+
+import javax.crypto.Mac;
+import javax.crypto.SecretKey;
+import javax.crypto.spec.SecretKeySpec;
+
+import com.rop.RopException;
+import com.rop.utils.RopUtils;
+
+/**
+ * hmac消息摘要数字签名处理实现
+ * @author liangruisen
+ *
+ */
+public class HmacDigestSignHandler extends DigestSignHandler {
+
+ public HmacDigestSignHandler() {
+ super("HmacSHA1", null);
+ }
+
+ public HmacDigestSignHandler(String secret) {
+ super("HmacSHA1", secret);
+ }
+
+ public HmacDigestSignHandler(String algorithm, String secret) {
+ super(algorithm, secret);
+ }
+
+ /**
+ * 产生签名
+ * @see com.rop.client.sign.DigestSignHandler#sign(java.util.Map, java.util.Collection)
+ */
+ @Override
+ public String sign(Map paramValues, Collection ignore) {
+ try {
+ String signContent = RopUtils.getSignContent(paramValues, ignore);
+ byte[] sha1Digest = getDigest(signContent);
+ return byte2hex(sha1Digest);
+ } catch (IOException e) {
+ throw new RopException(e);
+ }
+ }
+
+ /**
+ * 获取消息摘要
+ * @param data
+ * @return
+ */
+ protected byte[] getDigest(String data) throws IOException {
+ byte[] bytes = null;
+ try {
+ SecretKey secretKey = new SecretKeySpec(secret.getBytes(), algorithm);
+ Mac mac = Mac.getInstance(secretKey.getAlgorithm());
+ mac.init(secretKey);
+ bytes = mac.doFinal(data.getBytes());
+ } catch (GeneralSecurityException gse) {
+ throw new IOException(gse.toString());
+ }
+ return bytes;
+ }
+}
diff --git a/rop-client/src/test/java/com/rop/client/DefaultRopClientTest.java b/rop-client/src/test/java/com/rop/client/DefaultRopClientTest.java
new file mode 100644
index 0000000..224f803
--- /dev/null
+++ b/rop-client/src/test/java/com/rop/client/DefaultRopClientTest.java
@@ -0,0 +1,43 @@
+/*
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.client;
+
+import org.junit.Test;
+
+import com.rop.client.sign.DigestSignHandler;
+import com.rop.response.CommonRopResponse;
+
+/**
+ *
+ * 功能说明：
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public class DefaultRopClientTest {
+
+ private RopClient ropClient = new DefaultRopClient("http://localhost:8088/router", "00001");
+
+ @Test
+ public void testPostWithSession() throws Exception {
+ ropClient.setSignHandler(new DigestSignHandler("SHA-1", "abcdeabcdeabcdeabcdeabcde"));
+ ClientRequest request = ropClient.buildClientRequest();
+ CompositeResponse response = request.get(CommonRopResponse.class, "logout", "1.0");
+ response.isSuccessful();
+ }
+}
+
diff --git a/rop-core/.gitignore b/rop-core/.gitignore
new file mode 100644
index 0000000..f675857
--- /dev/null
+++ b/rop-core/.gitignore
@@ -0,0 +1,2 @@
+/target/
+/.settings/
\ No newline at end of file
diff --git a/rop-core/pom.xml b/rop-core/pom.xml
new file mode 100644
index 0000000..c0913a6
--- /dev/null
+++ b/rop-core/pom.xml
@@ -0,0 +1,149 @@
+
+
+ 4.0.0
+
+
+ com.rop
+ rop-parent
+ 2.0-SNAPSHOT
+
+
+ rop-core
+ rop core api
+ jar
+ rest open platform
+
+ http://www.github.com
+
+
+
+ The Apache Software License, Version 2.0
+ http://www.apache.org/licenses/LICENSE-2.0.txt
+ repo
+
+
+
+
+ scm:git:git@github.com:itstamen/rop.git
+ scm:git:git@github.com:itstamen/rop.git
+ git@github.com:itstamen/rop.git
+
+
+
+
+ stamen
+ stamen
+ itstamen@qq.com
+
+
+
+
+
+ junit
+ junit
+ ${junit.version}
+ test
+
+
+ org.slf4j
+ slf4j-api
+ ${slf4j.version}
+
+
+ commons-lang
+ commons-lang
+ ${commonslang.version}
+
+
+ com.fasterxml.jackson.dataformat
+ jackson-dataformat-xml
+ ${jackson.version}
+ test
+
+
+ commons-io
+ commons-io
+ ${commonsio.version}
+
+
+ commons-codec
+ commons-codec
+ ${commonscodec.version}
+
+
+ com.alibaba
+ fastjson
+ ${fastjson.version}
+ test
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-source-plugin
+ 2.1.2
+
+
+ attach-sources
+ verify
+
+ jar-no-fork
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-javadoc-plugin
+ 2.7
+
+ ${file.encoding}
+ ${file.encoding}
+ ${file.encoding}
+
+
+
+ attach-javadocs
+
+ jar
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.1
+
+ ${java.version}
+ ${java.version}
+ ${file.encoding}
+
+
+
+
+ org.apache.maven.plugins
+ maven-resources-plugin
+ 2.6
+
+ ${file.encoding}
+
+
+
+
+
+
+ UTF-8
+ 1.6
+ 2.4.4
+ 1.6.1
+ 2.4
+ 2.4
+ 1.9
+ 4.12
+ 1.2.4
+
+
\ No newline at end of file
diff --git a/rop-core/src/main/java/com/rop/CommonConstant.java b/rop-core/src/main/java/com/rop/CommonConstant.java
new file mode 100644
index 0000000..c5401b2
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/CommonConstant.java
@@ -0,0 +1,31 @@
+/*
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop;
+
+/**
+ * @author : chenxh(quickselect@163.com)
+ * @date: 13-11-1
+ */
+public class CommonConstant {
+
+ private CommonConstant(){
+ super();
+ }
+
+ public static final String ERROR_TOKEN = "@@$-ERROR_TOKEN$-@@";
+
+ public static final String SESSION_CHANGED = "@@SESSION_CHANGED__";
+}
diff --git a/rop-core/src/main/java/com/rop/MessageFormat.java b/rop-core/src/main/java/com/rop/MessageFormat.java
new file mode 100644
index 0000000..c48dc82
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/MessageFormat.java
@@ -0,0 +1,55 @@
+/*
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop;
+
+import org.apache.commons.lang.StringUtils;
+import org.slf4j.LoggerFactory;
+
+/**
+ * 支持的响应的格式类型
+ */
+public enum MessageFormat {
+
+ XML, JSON, STREAM;
+
+ public static MessageFormat getFormat(String value) {
+ if (StringUtils.isBlank(value)) {
+ return XML;
+ } else {
+ try {
+ return MessageFormat.valueOf(value.toUpperCase());
+ } catch (IllegalArgumentException e) {
+ LoggerFactory.getLogger(MessageFormat.class).debug(e.getMessage(), e);
+ return XML;
+ }
+ }
+ }
+
+ public static boolean isValidFormat(String value) {
+ if (StringUtils.isBlank(value)) {
+ return true;
+ }else{
+ try {
+ MessageFormat.valueOf(value.toUpperCase());
+ return true;
+ } catch (IllegalArgumentException e) {
+ LoggerFactory.getLogger(MessageFormat.class).debug(e.getMessage(), e);
+ return false;
+ }
+ }
+ }
+
+}
diff --git a/rop-core/src/main/java/com/rop/RopException.java b/rop-core/src/main/java/com/rop/RopException.java
new file mode 100644
index 0000000..2e2eb51
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/RopException.java
@@ -0,0 +1,44 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop;
+
+/**
+ *
+ * ROP的异常。
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public class RopException extends RuntimeException {
+ private static final long serialVersionUID = -5980800274047243722L;
+
+ public RopException() {
+ }
+
+ public RopException(String message) {
+ super(message);
+ }
+
+ public RopException(String message, Throwable cause) {
+ super(message, cause);
+ }
+
+ public RopException(Throwable cause) {
+ super(cause);
+ }
+}
+
diff --git a/rop-core/src/main/java/com/rop/RopMarshaller.java b/rop-core/src/main/java/com/rop/RopMarshaller.java
new file mode 100644
index 0000000..6795b92
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/RopMarshaller.java
@@ -0,0 +1,32 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+/**
+ *
+ * 负责将请求方法返回的响应对应流化为相应格式的内容。
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public interface RopMarshaller {
+ void marshaller(Object object, OutputStream outputStream) throws IOException;
+}
+
diff --git a/rop-core/src/main/java/com/rop/RopUnmarshaller.java b/rop-core/src/main/java/com/rop/RopUnmarshaller.java
new file mode 100644
index 0000000..b949df0
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/RopUnmarshaller.java
@@ -0,0 +1,38 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop;
+
+/**
+ *
+ * 对响应进行反流化
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public interface RopUnmarshaller {
+
+ /**
+ * 将字符串反序列化为相应的对象
+ *
+ * @param content
+ * @param objectType
+ * @param
+ * @return
+ */
+ T unmarshaller(String content, Class objectType);
+}
+
diff --git a/rop-core/src/main/java/com/rop/annotation/IgnoreSign.java b/rop-core/src/main/java/com/rop/annotation/IgnoreSign.java
new file mode 100644
index 0000000..d1cb230
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/annotation/IgnoreSign.java
@@ -0,0 +1,34 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.annotation;
+
+
+import java.lang.annotation.*;
+
+/**
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+@Target({ElementType.FIELD,ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface IgnoreSign {
+}
diff --git a/rop-core/src/main/java/com/rop/annotation/IgnoreSignType.java b/rop-core/src/main/java/com/rop/annotation/IgnoreSignType.java
new file mode 100644
index 0000000..fc51c32
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/annotation/IgnoreSignType.java
@@ -0,0 +1,38 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.annotation;
+
+/**
+ *
public class MyRopRequest implements RopRequest{
- *
- *
private String field1;
- *
- *
@Temporary
- *
private String field2;
}
- *
- *
- * @author 陈雄华
- * @version 1.0
- */
-@Target({ElementType.FIELD})
-@Retention(RetentionPolicy.RUNTIME)
-@Documented
-public @interface Temporary {
-
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.annotation;
+
+import java.lang.annotation.*;
+
+/**
+ * 默认情况下，请求对象的所有field都会作为请求参数提交，如果希望某个field不作为参数提交，可以打上{@Temporary}注解，如下所示：
+ *
+ *
public class MyRopRequest implements RopRequest{
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-public class SystemParameterNames {
-
- private static final String JSONP = "callback";
-
- //方法的默认参数名
- private static final String METHOD = "method";
-
- //格式化默认参数名
- private static final String FORMAT = "format";
-
- //本地化默认参数名
- private static final String LOCALE = "locale";
-
- //会话id默认参数名
- private static final String SESSION_ID = "sessionId";
-
- //应用键的默认参数名 ;
- private static final String APP_KEY = "appKey";
-
- //服务版本号的默认参数名
- private static final String VERSION = "v";
-
- //签名的默认参数名
- private static final String SIGN = "sign";
-
- private static String method = METHOD;
-
- private static String format = FORMAT;
-
- private static String locale = LOCALE;
- private static String sessionId = SESSION_ID;
-
- private static String appKey = APP_KEY;
-
- private static String version = VERSION;
-
- private static String sign = SIGN;
-
- private static String jsonp = JSONP;
-
- public static String getMethod() {
- return method;
- }
-
- public static void setMethod(String method) {
- SystemParameterNames.method = method;
- }
-
- public static String getFormat() {
- return format;
- }
-
- public static void setFormat(String format) {
- SystemParameterNames.format = format;
- }
-
- public static String getLocale() {
- return locale;
- }
-
- public static void setLocale(String locale) {
- SystemParameterNames.locale = locale;
- }
-
- public static String getSessionId() {
- return sessionId;
- }
-
- public static void setSessionId(String sessionId) {
- SystemParameterNames.sessionId = sessionId;
- }
-
- public static String getAppKey() {
- return appKey;
- }
-
- public static void setAppKey(String appKey) {
- SystemParameterNames.appKey = appKey;
- }
-
- public static String getVersion() {
- return version;
- }
-
- public static void setVersion(String version) {
- SystemParameterNames.version = version;
- }
-
- public static String getSign() {
- return sign;
- }
-
- public static void setSign(String sign) {
- SystemParameterNames.sign = sign;
- }
-
- public static String getJsonp() {
- return jsonp;
- }
-
- public static void setJsonp(String jsonp) {
- SystemParameterNames.jsonp = jsonp;
- }
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.config;
+
+import java.util.List;
+
+/**
+ *
+ * 系统级参数的名称
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public class SystemParameterNames {
+
+ private static final String JSONP = "callback";
+
+ //方法的默认参数名
+ private static final String METHOD = "method";
+
+ //格式化默认参数名
+ private static final String FORMAT = "format";
+
+ //本地化默认参数名
+ private static final String LOCALE = "locale";
+
+ //会话id默认参数名
+ private static final String SESSION_ID = "sessionId";
+
+ //应用键的默认参数名 ;
+ private static final String APP_KEY = "appKey";
+
+ //服务版本号的默认参数名
+ private static final String VERSION = "v";
+
+ //签名的默认参数名
+ private static final String SIGN = "sign";
+
+ private static String method = METHOD;
+
+ private static String format = FORMAT;
+
+ private static String locale = LOCALE;
+ private static String sessionId = SESSION_ID;
+
+ private static String appKey = APP_KEY;
+
+ private static String version = VERSION;
+
+ private static String sign = SIGN;
+
+ private static String jsonp = JSONP;
+
+ //默认忽略签名的参数列表
+ private static List ignoreSignFieldNames;
+
+ public static String getMethod() {
+ return method;
+ }
+
+ public static void setMethod(String method) {
+ SystemParameterNames.method = method;
+ }
+
+ public static String getFormat() {
+ return format;
+ }
+
+ public static void setFormat(String format) {
+ SystemParameterNames.format = format;
+ }
+
+ public static String getLocale() {
+ return locale;
+ }
+
+ public static void setLocale(String locale) {
+ SystemParameterNames.locale = locale;
+ }
+
+ public static String getSessionId() {
+ return sessionId;
+ }
+
+ public static void setSessionId(String sessionId) {
+ SystemParameterNames.sessionId = sessionId;
+ }
+
+ public static String getAppKey() {
+ return appKey;
+ }
+
+ public static void setAppKey(String appKey) {
+ SystemParameterNames.appKey = appKey;
+ }
+
+ public static String getVersion() {
+ return version;
+ }
+
+ public static void setVersion(String version) {
+ SystemParameterNames.version = version;
+ }
+
+ public static String getSign() {
+ return sign;
+ }
+
+ public static void setSign(String sign) {
+ SystemParameterNames.sign = sign;
+ }
+
+ public static String getJsonp() {
+ return jsonp;
+ }
+
+ public static void setJsonp(String jsonp) {
+ SystemParameterNames.jsonp = jsonp;
+ }
+
+ public static List getIgnoreSignFieldNames() {
+ return ignoreSignFieldNames;
+ }
+
+ public static void setIgnoreSignFieldNames(List ignoreSignFieldNames) {
+ SystemParameterNames.ignoreSignFieldNames = ignoreSignFieldNames;
+ }
+}
+
diff --git a/rop-core/src/main/java/com/rop/converter/IllegalUploadFileFormatException.java b/rop-core/src/main/java/com/rop/converter/IllegalUploadFileFormatException.java
new file mode 100644
index 0000000..cc5414c
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/converter/IllegalUploadFileFormatException.java
@@ -0,0 +1,46 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.converter;
+
+/**
+ *
+ * 上传文件字符串转换时发生错误
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public class IllegalUploadFileFormatException extends IllegalArgumentException {
+
+ private static final long serialVersionUID = 1L;
+
+ public IllegalUploadFileFormatException() {
+ super();
+ }
+
+ public IllegalUploadFileFormatException(String s) {
+ super(s);
+ }
+
+ public IllegalUploadFileFormatException(String message, Throwable cause) {
+ super(message, cause);
+ }
+
+ public IllegalUploadFileFormatException(Throwable cause) {
+ super(cause);
+ }
+}
+
diff --git a/rop-core/src/main/java/com/rop/converter/RopConverter.java b/rop-core/src/main/java/com/rop/converter/RopConverter.java
new file mode 100644
index 0000000..152364b
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/converter/RopConverter.java
@@ -0,0 +1,54 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.converter;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-@IgnoreSign
-public class UploadFile {
-
- private String fileType;
-
- private byte[] content;
-
- /**
- * 根据文件内容构造
- *
- * @param content
- */
- public UploadFile(String fileType, byte[] content) {
- this.content = content;
- this.fileType = fileType;
- }
-
- /**
- * 根据文件构造
- * @param file
- */
- public UploadFile(File file) {
- try {
- this.content = FileCopyUtils.copyToByteArray(file);
- this.fileType = file.getName().substring(file.getName().lastIndexOf('.')+1);
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
- }
-
- public String getFileType() {
- return fileType;
- }
-
- public byte[] getContent() {
- return content;
- }
-}
-
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.converter;
+
+import com.rop.annotation.IgnoreSign;
+
+import java.io.File;
+import java.io.IOException;
+
+import org.apache.commons.io.FileUtils;
+
+/**
+ *
+ * 上传的文件
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+@IgnoreSign
+public class UploadFile {
+
+ private String fileType;
+
+ private byte[] content;
+
+ /**
+ * 根据文件内容构造
+ *
+ * @param content
+ */
+ public UploadFile(String fileType, byte[] content) {
+ this.content = content;
+ this.fileType = fileType;
+ }
+
+ /**
+ * 根据文件构造
+ * @param file
+ */
+ public UploadFile(File file) {
+ try {
+ this.content = FileUtils.readFileToByteArray(file);
+ this.fileType = file.getName().substring(file.getName().lastIndexOf('.')+1);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ public String getFileType() {
+ return fileType;
+ }
+
+ public byte[] getContent() {
+ return content;
+ }
+}
+
+
diff --git a/rop-core/src/main/java/com/rop/converter/UploadFileConverter.java b/rop-core/src/main/java/com/rop/converter/UploadFileConverter.java
new file mode 100644
index 0000000..cd4ef7f
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/converter/UploadFileConverter.java
@@ -0,0 +1,50 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.converter;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-public class UploadFileUtils {
-
- public static final char SPERATOR = '@';
-
- /**
- * 获取文件的类型
- *
- * @param encodeFile
- * @return
- */
- public static final String getFileType(String encodeFile) {
- int speratorIndex = encodeFile.indexOf(SPERATOR);
- if (speratorIndex > -1) {
- String fileType = encodeFile.substring(0, speratorIndex);
- return fileType.toLowerCase();
- } else {
- throw new IllegalUploadFileFormatException("文件格式不对，正确格式为：<文件格式>@<文件内容>");
- }
- }
-
- /**
- * 获取文件的字节数组
- *
- * @param encodeFile
- * @return
- */
- public static final byte[] decode(String encodeFile) {
- int speratorIndex = encodeFile.indexOf(SPERATOR);
- if (speratorIndex > -1) {
- String content = encodeFile.substring(speratorIndex + 1);
- return Base64.decodeBase64(content);
- } else {
- throw new IllegalUploadFileFormatException("文件格式不对，正确格式为：<文件格式>@<文件内容>");
- }
- }
-
- /**
- * 将文件编码为BASE64的字符串
- *
- * @param bytes
- * @return
- */
- public static final String encode(byte[] bytes) {
- return Base64.encodeBase64String(bytes);
- }
-
- /**
- * 将文件编码为一个字符串
- * @param uploadFile
- * @return
- */
- public static final String encode(UploadFile uploadFile){
- StringBuilder sb = new StringBuilder();
- sb.append(uploadFile.getFileType());
- sb.append(SPERATOR);
- sb.append(encode(uploadFile.getContent()));
- return sb.toString();
- }
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.converter;
+
+import org.apache.commons.codec.binary.Base64;
+
+/**
+ *
+ * Rop的上传文件编码格式为：
+ * fileType@BASE64编码的文件内容
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public class UploadFileUtils {
+
+ public static final char SPERATOR = '@';
+
+ /**
+ * 获取文件的类型
+ *
+ * @param encodeFile
+ * @return
+ */
+ public static final String getFileType(String encodeFile) {
+ int speratorIndex = encodeFile.indexOf(SPERATOR);
+ if (speratorIndex > -1) {
+ String fileType = encodeFile.substring(0, speratorIndex);
+ return fileType.toLowerCase();
+ } else {
+ throw new IllegalUploadFileFormatException("文件格式不对，正确格式为：<文件格式>@<文件内容>");
+ }
+ }
+
+ /**
+ * 获取文件的字节数组
+ *
+ * @param encodeFile
+ * @return
+ */
+ public static final byte[] decode(String encodeFile) {
+ int speratorIndex = encodeFile.indexOf(SPERATOR);
+ if (speratorIndex > -1) {
+ String content = encodeFile.substring(speratorIndex + 1);
+ return Base64.decodeBase64(content);
+ } else {
+ throw new IllegalUploadFileFormatException("文件格式不对，正确格式为：<文件格式>@<文件内容>");
+ }
+ }
+
+ /**
+ * 将文件编码为BASE64的字符串
+ *
+ * @param bytes
+ * @return
+ */
+ public static final String encode(byte[] bytes) {
+ return Base64.encodeBase64String(bytes);
+ }
+
+ /**
+ * 将文件编码为一个字符串
+ * @param uploadFile
+ * @return
+ */
+ public static final String encode(UploadFile uploadFile){
+ StringBuilder sb = new StringBuilder();
+ sb.append(uploadFile.getFileType());
+ sb.append(SPERATOR);
+ sb.append(encode(uploadFile.getContent()));
+ return sb.toString();
+ }
+}
+
diff --git a/rop-core/src/main/java/com/rop/marshaller/FastjsonRopMarshaller.java b/rop-core/src/main/java/com/rop/marshaller/FastjsonRopMarshaller.java
new file mode 100644
index 0000000..1ed7819
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/marshaller/FastjsonRopMarshaller.java
@@ -0,0 +1,32 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.marshaller;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+import com.alibaba.fastjson.JSON;
+import com.rop.RopMarshaller;
+
+/**
+ * 使用fastjson进行json数据转换
+ */
+public class FastjsonRopMarshaller implements RopMarshaller {
+
+ public void marshaller(Object object, OutputStream outputStream) throws IOException {
+ outputStream.write(JSON.toJSONBytes(object));
+ }
+}
diff --git a/rop-core/src/main/java/com/rop/marshaller/JacksonJsonRopMarshaller.java b/rop-core/src/main/java/com/rop/marshaller/JacksonJsonRopMarshaller.java
new file mode 100644
index 0000000..61984c1
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/marshaller/JacksonJsonRopMarshaller.java
@@ -0,0 +1,55 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.marshaller;
+
+import com.fasterxml.jackson.core.JsonEncoding;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.rop.RopMarshaller;
+import com.rop.utils.ObjectMapperUtils;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-public class JaxbXmlRopMarshaller implements RopMarshaller {
-
- private static Map jaxbContextHashMap = new ConcurrentHashMap();
-
- public void marshaller(Object object, OutputStream outputStream) {
- try {
- Marshaller m = buildMarshaller(object.getClass());
- m.marshal(object, outputStream);
- } catch (JAXBException e) {
- throw new RopException(e);
- }
- }
-
-
- private Marshaller buildMarshaller(Class objectType) throws JAXBException {
- if (!jaxbContextHashMap.containsKey(objectType)) {
- JAXBContext context = JAXBContext.newInstance(objectType);
- jaxbContextHashMap.put(objectType, context);
- }
- JAXBContext context = jaxbContextHashMap.get(objectType);
- Marshaller marshaller = context.createMarshaller();
- marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
- marshaller.setProperty(Marshaller.JAXB_ENCODING, "utf-8");
- return marshaller;
- }
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.marshaller;
+
+import com.rop.RopException;
+import com.rop.RopMarshaller;
+
+import javax.xml.bind.JAXBContext;
+import javax.xml.bind.JAXBException;
+import javax.xml.bind.Marshaller;
+import java.io.OutputStream;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-@XmlAccessorType(XmlAccessType.FIELD)
-@XmlRootElement(name = "response")
-public class CommonRopResponse{
-
- @XmlAttribute
- private boolean successful = false;
-
- public static final CommonRopResponse SUCCESSFUL_RESPONSE = new CommonRopResponse(true);
- public static final CommonRopResponse FAILURE_RESPONSE = new CommonRopResponse(false);
-
- public CommonRopResponse() {
- }
-
- private CommonRopResponse(boolean successful) {
- this.successful = successful;
- }
-
- public boolean isSuccessful() {
- return successful;
- }
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.response;
+
+
+import javax.xml.bind.annotation.XmlAccessType;
+import javax.xml.bind.annotation.XmlAccessorType;
+import javax.xml.bind.annotation.XmlAttribute;
+import javax.xml.bind.annotation.XmlRootElement;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-@XmlAccessorType(XmlAccessType.FIELD)
-@XmlRootElement(name = "subError")
-public class SubError {
-
- @XmlAttribute
- private String code;
-
- @XmlElement
- private String message;
-
- public SubError() {
- }
-
- public SubError(String code, String message) {
- this.code = code;
- this.message = message;
- }
-
- public String getCode() {
- return code;
- }
-
- public void setCode(String code) {
- this.code = code;
- }
-
- public String getMessage() {
- return message;
- }
-
- public void setMessage(String message) {
- this.message = message;
- }
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.response;
+
+
+import javax.xml.bind.annotation.*;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-public enum SubErrorType {
- ISP_SERVICE_UNAVAILABLE,
- ISP_SERVICE_TIMEOUT,
-
- ISV_NOT_EXIST,
- ISV_INVALID_PERMISSION,
- ISV_MISSING_PARAMETER,
- ISV_INVALID_PARAMETE,
- ISV_PARAMETERS_MISMATCH;
-
- private static EnumMap errorKeyMap = new EnumMap(SubErrorType.class);
-
- static {
- errorKeyMap.put(SubErrorType.ISP_SERVICE_UNAVAILABLE, "isp.xxx-service-unavailable");
- errorKeyMap.put(SubErrorType.ISP_SERVICE_TIMEOUT, "isp.xxx-service-timeout");
-
- errorKeyMap.put(SubErrorType.ISV_NOT_EXIST, "isv.xxx-not-exist:invalid-yyy");
- errorKeyMap.put(SubErrorType.ISV_MISSING_PARAMETER, "isv.missing-parameter:xxx");
- errorKeyMap.put(SubErrorType.ISV_INVALID_PARAMETE, "isv.invalid-paramete:xxx");
- errorKeyMap.put(SubErrorType.ISV_INVALID_PERMISSION, "isv.invalid-permission");
- errorKeyMap.put(SubErrorType.ISV_PARAMETERS_MISMATCH, "isv.parameters-mismatch:xxx-and-yyy");
- }
-
- public String value() {
- return errorKeyMap.get(this);
- }
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.response;
+
+import java.util.EnumMap;
+
+/**
+ *
+ * 功能说明：
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public enum SubErrorType {
+ ISP_SERVICE_UNAVAILABLE,
+ ISP_SERVICE_TIMEOUT,
+
+ ISV_NOT_EXIST,
+ ISV_INVALID_PERMISSION,
+ ISV_MISSING_PARAMETER,
+ ISV_INVALID_PARAMETE,
+ ISV_PARAMETERS_MISMATCH;
+
+ private static EnumMap errorKeyMap = new EnumMap(SubErrorType.class);
+
+ static {
+ errorKeyMap.put(SubErrorType.ISP_SERVICE_UNAVAILABLE, "isp.xxx-service-unavailable");
+ errorKeyMap.put(SubErrorType.ISP_SERVICE_TIMEOUT, "isp.xxx-service-timeout");
+
+ errorKeyMap.put(SubErrorType.ISV_NOT_EXIST, "isv.xxx-not-exist:invalid-yyy");
+ errorKeyMap.put(SubErrorType.ISV_MISSING_PARAMETER, "isv.missing-parameter:xxx");
+ errorKeyMap.put(SubErrorType.ISV_INVALID_PARAMETE, "isv.invalid-paramete:xxx");
+ errorKeyMap.put(SubErrorType.ISV_INVALID_PERMISSION, "isv.invalid-permission");
+ errorKeyMap.put(SubErrorType.ISV_PARAMETERS_MISMATCH, "isv.parameters-mismatch:xxx-and-yyy");
+ }
+
+ public String value() {
+ return errorKeyMap.get(this);
+ }
+}
+
diff --git a/rop-core/src/main/java/com/rop/sign/SignHandler.java b/rop-core/src/main/java/com/rop/sign/SignHandler.java
new file mode 100644
index 0000000..418fc6a
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/sign/SignHandler.java
@@ -0,0 +1,57 @@
+/**
+ * Copyright 2012-2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.sign;
+
+import java.util.Collection;
+import java.util.Map;
+
+/**
+ * 数字签名处理接口
+ * @author liangruisen
+ */
+public interface SignHandler {
+
+ /**
+ * 产生签名
+ * @param paramMap
+ * @return 签名字符串
+ */
+ String sign(Map paramMap);
+
+ /**
+ * 产生签名
+ * @param paramMap
+ * @return 签名字符串
+ */
+ String sign(Map paramMap, Collection ignore);
+
+ /**
+ * 检查签名是否正确
+ * @param sign
+ * @param paramMap
+ * @param ignore
+ * @return boolean
+ */
+ boolean signCheck(String sign, Map paramMap, Collection ignore);
+
+ /**
+ * 检查签名是否正确
+ * @param sign
+ * @param paramMap
+ * @return boolean
+ */
+ boolean signCheck(String sign, Map paramMap);
+}
diff --git a/rop-core/src/main/java/com/rop/unmarshaller/FastjsonRopUnmarshaller.java b/rop-core/src/main/java/com/rop/unmarshaller/FastjsonRopUnmarshaller.java
new file mode 100644
index 0000000..cc68cd8
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/unmarshaller/FastjsonRopUnmarshaller.java
@@ -0,0 +1,29 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.unmarshaller;
+
+import com.alibaba.fastjson.JSON;
+import com.rop.RopUnmarshaller;
+
+/**
+ * 使用fastjson将json数据转换成java对象
+ */
+public class FastjsonRopUnmarshaller implements RopUnmarshaller {
+
+ public T unmarshaller(String content, Class objectType) {
+ return JSON.parseObject(content, objectType);
+ }
+}
diff --git a/rop-core/src/main/java/com/rop/unmarshaller/JacksonJsonRopUnmarshaller.java b/rop-core/src/main/java/com/rop/unmarshaller/JacksonJsonRopUnmarshaller.java
new file mode 100644
index 0000000..b79db84
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/unmarshaller/JacksonJsonRopUnmarshaller.java
@@ -0,0 +1,56 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.unmarshaller;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.rop.RopException;
+import com.rop.RopUnmarshaller;
+import com.rop.utils.ObjectMapperUtils;
+
+import java.io.IOException;
+
+/**
+ *
- *
- * @author 陈雄华
- * @version 1.0
- */
-public class JaxbXmlRopUnmarshaller implements RopUnmarshaller {
-
- private static Map jaxbContextHashMap = new ConcurrentHashMap();
-
-
- public T unmarshaller(String content, Class objectType) {
- try {
- Unmarshaller unmarshaller = buildUnmarshaller(objectType);
- StringReader reader = new StringReader(content);
- new InputSource(reader);
- return (T) unmarshaller.unmarshal(reader);
- } catch (JAXBException e) {
- throw new RopException(e);
- }
-
- }
-
- private Unmarshaller buildUnmarshaller(Class objectType) throws JAXBException {
- if (!jaxbContextHashMap.containsKey(objectType)) {
- JAXBContext context = JAXBContext.newInstance(objectType);
- jaxbContextHashMap.put(objectType, context);
- }
- JAXBContext context = jaxbContextHashMap.get(objectType);
- Unmarshaller unmarshaller = context.createUnmarshaller();
-// unmarshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
-// unmarshaller.setProperty(Marshaller.JAXB_ENCODING, "utf-8");
- return unmarshaller;
- }
-}
-
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.unmarshaller;
+
+import com.rop.RopException;
+import com.rop.RopUnmarshaller;
+
+import org.xml.sax.InputSource;
+
+import javax.xml.bind.JAXBContext;
+import javax.xml.bind.JAXBException;
+import javax.xml.bind.Unmarshaller;
+
+import java.io.StringReader;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ *
+ * 功能说明：使用Jaxb将xml数据转换成java对象
+ *
+ *
+ * @author 陈雄华
+ * @version 1.0
+ */
+public class JaxbXmlRopUnmarshaller implements RopUnmarshaller {
+
+ private static Map, JAXBContext> jaxbContextHashMap = new ConcurrentHashMap, JAXBContext>();
+
+
+ public T unmarshaller(String content, Class objectType) {
+ try {
+ Unmarshaller unmarshaller = buildUnmarshaller(objectType);
+ StringReader reader = new StringReader(content);
+ new InputSource(reader);
+ return objectType.cast(unmarshaller.unmarshal(reader));
+ } catch (JAXBException e) {
+ throw new RopException(e);
+ }
+ }
+
+ private Unmarshaller buildUnmarshaller(Class objectType) throws JAXBException {
+ if (!jaxbContextHashMap.containsKey(objectType)) {
+ JAXBContext context = JAXBContext.newInstance(objectType);
+ jaxbContextHashMap.put(objectType, context);
+ }
+ JAXBContext context = jaxbContextHashMap.get(objectType);
+ Unmarshaller unmarshaller = context.createUnmarshaller();
+ return unmarshaller;
+ }
+}
+
diff --git a/rop-core/src/main/java/com/rop/utils/AnnotationUtils.java b/rop-core/src/main/java/com/rop/utils/AnnotationUtils.java
new file mode 100644
index 0000000..8789120
--- /dev/null
+++ b/rop-core/src/main/java/com/rop/utils/AnnotationUtils.java
@@ -0,0 +1,191 @@
+/*
+ * Copyright 2012-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.rop.utils;
+
+import java.lang.annotation.Annotation;
+import java.lang.reflect.AnnotatedElement;
+import java.lang.reflect.Method;
+import java.util.HashSet;
+import java.util.Set;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * General utility methods for working with annotations, handling bridge methods
+ * (which the compiler generates for generic declarations) as well as super methods
+ * (for optional "annotation inheritance"). Note that none of this is
+ * provided by the JDK's introspection facilities themselves.
+ *
+ *
As a general rule for runtime-retained annotations (e.g. for transaction
+ * control, authorization, or service exposure), always use the lookup methods
+ * on this class (e.g., {@link #findAnnotation(Method, Class)},
+ * {@link #getAnnotation(Method, Class)}, and {@link #getAnnotations(Method)})
+ * instead of the plain annotation lookup methods in the JDK. You can still
+ * explicitly choose between a get lookup on the given class level only
+ * ({@link #getAnnotation(Method, Class)}) and a find lookup in the entire
+ * inheritance hierarchy of the given method ({@link #findAnnotation(Method, Class)}).
+ *
+ * @author Rob Harrop
+ * @author Juergen Hoeller
+ * @author Sam Brannen
+ * @author Mark Fisher
+ * @author Chris Beams
+ * @author Phillip Webb
+ * @since 2.0
+ * @see java.lang.reflect.Method#getAnnotations()
+ * @see java.lang.reflect.Method#getAnnotation(Class)
+ */
+public abstract class AnnotationUtils {
+
+ private static transient Logger logger;
+
+ /**
+ * Find a single {@link Annotation} of {@code annotationType} on the
+ * supplied {@link Class}, traversing its interfaces, annotations, and
+ * superclasses if the annotation is not present on the given class
+ * itself.
+ *
This method explicitly handles class-level annotations which are not
+ * declared as {@link java.lang.annotation.Inherited inherited} as well
+ * as meta-annotations and annotations on interfaces.
+ *
The algorithm operates as follows:
+ *
+ *
Search for the annotation on the given class and return it if found.
+ *
Recursively search through all interfaces that the given class declares.
+ *
Recursively search through all annotations that the given class declares.
+ *
Recursively search through the superclass hierarchy of the given class.
+ *