DUBBO-402 开源http协议

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@1816 1a56cb94-b969-4eaa-88fa-be21384802f2

dubbo-rpc/dubbo-rpc-http/pom.xml

@@ -34,11 +34,14 @@
 			<artifactId>dubbo-rpc-api</artifactId>
 			<version>${project.parent.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>dubbo-remoting-http</artifactId>
+			<version>${project.parent.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework</groupId>
 			<artifactId>spring</artifactId>
-			<scope>provided</scope>
-			<optional>true</optional>
 		</dependency>
 	</dependencies>
 </project>
\ No newline at end of file

dubbo-rpc/dubbo-rpc-http/src/main/java/com/alibaba/dubbo/rpc/protocol/http/HttpProtocol.java

+/*
+ * Copyright 1999-2012 Alibaba Group.
+ *  
+ * 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 pehttpssions and
+ * limitations under the License.
+ */
+package com.alibaba.dubbo.rpc.protocol.http;
+
+import java.io.IOException;
+import java.net.SocketTimeoutException;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.springframework.remoting.RemoteAccessException;
+import org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean;
+import org.springframework.remoting.httpinvoker.HttpInvokerServiceExporter;
+
+import com.alibaba.dubbo.common.URL;
+import com.alibaba.dubbo.remoting.http.HttpBinder;
+import com.alibaba.dubbo.remoting.http.HttpHandler;
+import com.alibaba.dubbo.remoting.http.HttpServer;
+import com.alibaba.dubbo.rpc.RpcContext;
+import com.alibaba.dubbo.rpc.RpcException;
+import com.alibaba.dubbo.rpc.protocol.AbstractProxyProtocol;
+
+/**
+ * HttpProtocol
+ * 
+ * @author william.liangf
+ */
+public class HttpProtocol extends AbstractProxyProtocol {
+
+    public static final int              DEFAULT_PORT = 80;
+
+    private final Map<String, HttpServer> serverMap = new ConcurrentHashMap<String, HttpServer>();
+
+    private final Map<String, HttpInvokerServiceExporter> skeletonMap = new ConcurrentHashMap<String, HttpInvokerServiceExporter>();
+
+    private HttpBinder httpBinder;
+    
+    public HttpProtocol() {
+        super(IOException.class);
+    }
+
+    public void setHttpBinder(HttpBinder httpBinder) {
+        this.httpBinder = httpBinder;
+    }
+
+    public int getDefaultPort() {
+        return DEFAULT_PORT;
+    }
+
+    private class InternalHandler implements HttpHandler {
+        
+        public void handle(HttpServletRequest request, HttpServletResponse response)
+                throws IOException, ServletException {
+            String uri = request.getRequestURI();
+            HttpInvokerServiceExporter skeleton = skeletonMap.get(uri);
+            if (! request.getMethod().equalsIgnoreCase("POST")) {
+                response.setStatus(500);
+            } else {
+                RpcContext.getContext().setRemoteAddress(request.getRemoteAddr(), request.getRemotePort());
+                try {
+                    skeleton.handleRequest(request, response);
+                } catch (Throwable e) {
+                    throw new ServletException(e);
+                }
+            }
+        }
+        
+    }
+
+    protected <T> Runnable doExport(final T impl, Class<T> type, URL url) throws RpcException {
+        String addr = url.getIp() + ":" + url.getPort();
+        HttpServer server = serverMap.get(addr);
+        if (server == null) {
+            server = httpBinder.bind(url, new InternalHandler());
+            serverMap.put(addr, server);
+        }
+        final HttpInvokerServiceExporter httpServiceExporter = new HttpInvokerServiceExporter();
+        httpServiceExporter.setServiceInterface(type);
+        httpServiceExporter.setService(impl);
+        try {
+            httpServiceExporter.afterPropertiesSet();
+        } catch (Exception e) {
+            throw new RpcException(e.getMessage(), e);
+        }
+        final String path = url.getAbsolutePath();
+        skeletonMap.put(path, httpServiceExporter);
+        return new Runnable() {
+            public void run() {
+                skeletonMap.remove(path);
+            }
+        };
+    }
+
+    @SuppressWarnings("unchecked")
+    protected <T> T doRefer(final Class<T> serviceType, final URL url) throws RpcException {
+        final HttpInvokerProxyFactoryBean httpProxyFactoryBean = new HttpInvokerProxyFactoryBean();
+        httpProxyFactoryBean.setServiceUrl(url.toIdentityString());
+        httpProxyFactoryBean.setServiceInterface(serviceType);
+        httpProxyFactoryBean.afterPropertiesSet();
+        return (T) httpProxyFactoryBean.getObject();
+    }
+
+    protected int getErrorCode(Throwable e) {
+        if (e instanceof RemoteAccessException) {
+            e = e.getCause();
+        }
+        if (e != null && e.getCause() != null) {
+            Class<?> cls = e.getCause().getClass();
+            // 是根据测试Case发现的问题，对RpcException.setCode进行设置
+            if (SocketTimeoutException.class.equals(cls)) {
+                return RpcException.TIMEOUT_EXCEPTION;
+            } else if (IOException.class.isAssignableFrom(cls)) {
+                return RpcException.NETWORK_EXCEPTION;
+            } else if (ClassNotFoundException.class.isAssignableFrom(cls)) {
+                return RpcException.SERIALIZATION_EXCEPTION;
+            }
+        }
+        return super.getErrorCode(e);
+    }
+
+}
\ No newline at end of file

dubbo-rpc/dubbo-rpc-http/src/main/resources/META-INF/dubbo/com.alibaba.dubbo.rpc.Protocol

+com.alibaba.dubbo.rpc.protocol.http.HttpProtocol
\ No newline at end of file