Merge pull request #2 from coderqianlq/dev

Dev

Author: coderqianlq

README.md

@@ -3,7 +3,7 @@
 	<br/>
 
   [![Build Status](https://travis-ci.org/coderqianlq/dubbo-spring-boot-cli.svg?branch=master)](https://travis-ci.org/coderqianlq/dubbo-spring-boot-cli)
-  [![License](https://img.shields.io/badge/license-MIT-blue.svg)](https://github.com/coderqianlq/spring-boot-dubbo-cli/blob/master/LICENSE)
+  [![License](https://img.shields.io/badge/license-MIT-blue.svg)](https://github.com/coderqianlq/dubbo-spring-boot-cli/blob/master/LICENSE)
 </div>
 
 **快速开始**

dubbo-api/pom.xml

@@ -9,7 +9,7 @@
 
 	<parent>
 		<groupId>com.coderqian</groupId>
-		<artifactId>spring-boot-dubbo-cli</artifactId>
+		<artifactId>dubbo-spring-boot-cli</artifactId>
 		<version>1.0-SNAPSHOT</version>
 	</parent>
 
@@ -24,14 +24,14 @@
 
 	<dependencies>
 		<dependency>
-			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-web</artifactId>
+			<groupId>com.coderqian</groupId>
+			<artifactId>dubbo-core</artifactId>
+			<version>0.0.1-SNAPSHOT</version>
 		</dependency>
 
 		<dependency>
-			<groupId>io.swagger</groupId>
-			<artifactId>swagger-annotations</artifactId>
-			<version>1.5.20</version>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
 	</dependencies>
 

dubbo-api/src/main/java/com/coderqian/dubboapi/service/TestService.java

@@ -1,5 +1,9 @@
 package com.coderqian.dubboapi.service;
 
+import com.coderqian.dubbocore.model.entity.UserEntity;
+
+import java.util.List;
+
 /**
  * @author qianliqing
  * @date 2018/11/29 1:55 PM
@@ -15,4 +19,12 @@ public interface TestService {
      * @return String
      */
     String test(String text);
+
+    /**
+     * 测试接口
+     *
+     * @param text 测试数据
+     * @return String
+     */
+    List<UserEntity> testMybatis(String text);
 }

dubbo-api/src/main/resources/application.properties

@@ -6,6 +6,4 @@ dubbo.application.id=dubbo-api
 # 当前dubbo应用名称
 dubbo.application.name=dubbo-api
 # 注册中心
-dubbo.registry.address=zookeeper://127.0.0.1:2181
-
-logging.config=classpath:log4j2.xml
+dubbo.registry.address=zookeeper://127.0.0.1:2181

dubbo-consumer/pom.xml

@@ -9,7 +9,7 @@
 
     <parent>
         <groupId>com.coderqian</groupId>
-        <artifactId>spring-boot-dubbo-cli</artifactId>
+        <artifactId>dubbo-spring-boot-cli</artifactId>
         <version>1.0-SNAPSHOT</version>
     </parent>
 

dubbo-consumer/src/main/java/com/coderqian/dubboconsumer/controller/TestController.java

@@ -2,19 +2,22 @@
 
 import com.alibaba.dubbo.config.annotation.Reference;
 import com.coderqian.dubboapi.service.TestService;
+import com.coderqian.dubbocore.model.entity.UserEntity;
 import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+
 /**
  * @author qianliqing
  * @date 2018/11/29 1:52 PM
  * email: qianlq0824@gmail.com
  */
 
 @RestController
-@RequestMapping("/customer")
+@RequestMapping("/test")
 public class TestController {
 
     @Reference
@@ -29,4 +32,9 @@ public String test(String text) {
     private String testError(String text) {
         return "失败" + text;
     }
+
+    @RequestMapping(value = "/mybatis", method = RequestMethod.GET)
+    public List<UserEntity> testMybatis(String text) {
+        return testService.testMybatis(text);
+    }
 }

dubbo-core/pom.xml

@@ -0,0 +1,71 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+
+	<artifactId>dubbo-core</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<packaging>jar</packaging>
+
+	<parent>
+		<groupId>com.coderqian</groupId>
+		<artifactId>dubbo-spring-boot-cli</artifactId>
+		<version>1.0-SNAPSHOT</version>
+	</parent>
+
+	<name>dubbo-core</name>
+	<description>Demo project for Spring Boot</description>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+		<java.version>1.8</java.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+
+		<!-- 引入Mybatis依赖 -->
+		<dependency>
+			<groupId>org.mybatis.spring.boot</groupId>
+			<artifactId>mybatis-spring-boot-starter</artifactId>
+			<version>1.3.2</version>
+		</dependency>
+
+		<!-- 引入Druid依赖 -->
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>druid-spring-boot-starter</artifactId>
+			<version>1.1.10</version>
+		</dependency>
+
+		<!-- 引入MySQL连接依赖 -->
+		<dependency>
+			<groupId>mysql</groupId>
+			<artifactId>mysql-connector-java</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+			<version>1.18.0</version>
+			<scope>provided</scope>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+				<configuration>
+					<classifier>exec</classifier>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>

dubbo-core/src/main/java/com/coderqian/dubbocore/DubboCoreApplication.java

@@ -0,0 +1,16 @@
+package com.coderqian.dubbocore;
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+@MapperScan("com.coderqian.dubbocore.mapper")
+public class DubboCoreApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(DubboCoreApplication.class, args);
+	}
+
+}
+

dubbo-core/src/main/java/com/coderqian/dubbocore/configuration/config/DruidDBConfig.java

@@ -0,0 +1,54 @@
+package com.coderqian.dubbocore.configuration.config;
+
+import com.alibaba.druid.pool.DruidDataSource;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+
+import javax.sql.DataSource;
+
+/**
+ * @author qianliqing
+ * @date 2019/1/18 6:52 PM
+ * email: qianlq0824@gmail.com
+ */
+
+@Configuration
+public class DruidDBConfig {
+
+    @Value("${spring.datasource.url}")
+    private String dbUrl;
+
+    @Value("${spring.datasource.username}")
+    private String username;
+
+    @Value("${spring.datasource.password}")
+    private String password;
+
+    @Value("${spring.datasource.driver-class-name}")
+    private String driverClassName;
+
+    @Value("${spring.datasource.initialSize}")
+    private int initialSize;
+
+    @Value("${spring.datasource.minIdle}")
+    private int minIdle;
+
+    @Value("${spring.datasource.maxActive}")
+    private int maxActive;
+
+    @Bean
+    @Primary
+    public DataSource dataSource() {
+        DruidDataSource datasource = new DruidDataSource();
+        datasource.setUrl(dbUrl);
+        datasource.setUsername(username);
+        datasource.setPassword(password);
+        datasource.setDriverClassName(driverClassName);
+        datasource.setInitialSize(initialSize);
+        datasource.setMinIdle(minIdle);
+        datasource.setMaxActive(maxActive);
+        return datasource;
+    }
+}

dubbo-core/src/main/java/com/coderqian/dubbocore/configuration/filter/DruidStatFilter.java

@@ -0,0 +1,21 @@
+package com.coderqian.dubbocore.configuration.filter;
+
+import com.alibaba.druid.support.http.WebStatFilter;
+
+import javax.servlet.annotation.WebFilter;
+import javax.servlet.annotation.WebInitParam;
+
+/**
+ * @author qianliqing
+ * @date 2019-01-18 6:37 PM
+ * mail: qianlq0824@gmail.com
+ * <p>
+ * 配置druid监控统计功能和过滤器
+ */
+@WebFilter(filterName = "druidWebStatFilter", urlPatterns = "/*",
+        initParams = {
+                @WebInitParam(name = "exclusions", value = "*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*")// 忽略资源
+        }
+)
+public class DruidStatFilter extends WebStatFilter {
+}