Dev

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 {
+}

dubbo-core/src/main/java/com/coderqian/dubbocore/configuration/servlet/DruidStatViewServlet.java

@@ -0,0 +1,26 @@
+package com.coderqian.dubbocore.configuration.servlet;
+
+import com.alibaba.druid.support.http.StatViewServlet;
+
+import javax.servlet.annotation.WebInitParam;
+import javax.servlet.annotation.WebServlet;
+
+/**
+ * @author qianliqing
+ * @date 2019-01-18 6:37 PM
+ * mail: qianlq0824@gmail.com
+ * <p>
+ * 配置druid监控统计功能
+ */
+
+@WebServlet(urlPatterns = "/druid/*",
+        initParams = {
+                @WebInitParam(name = "allow", value = "192.168.16.110,127.0.0.1"), // IP白名单 (没有配置或者为空，则允许所有访问)
+                @WebInitParam(name = "deny", value = "192.168.16.111"), // IP黑名单 (存在共同时，deny优先于allow)
+                @WebInitParam(name = "loginUsername", value = "kBEuJPHmTgcVvKlt"),// 用户名
+                @WebInitParam(name = "loginPassword", value = "zPhIJTa0jvsZ7sLj"),// 密码
+                @WebInitParam(name = "resetEnable", value = "false")// 禁用HTML页面上的“Reset All”功能
+        }
+)
+public class DruidStatViewServlet extends StatViewServlet {
+}

dubbo-core/src/main/java/com/coderqian/dubbocore/mapper/UserMapper.java

@@ -0,0 +1,23 @@
+package com.coderqian.dubbocore.mapper;
+
+import com.coderqian.dubbocore.model.entity.UserEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * @author qianliqing
+ * @date 2019/1/18 7:58 PM
+ * email: qianliqing@hyperchain.com
+ */
+
+@Mapper
+public interface UserMapper {
+
+    /**
+     * 查询所有用户
+     *
+     * @return List<UserEntity>
+     */
+    List<UserEntity> findAll();
+}

dubbo-core/src/main/java/com/coderqian/dubbocore/model/entity/BaseEntity.java

@@ -0,0 +1,13 @@
+package com.coderqian.dubbocore.model.entity;
+
+import lombok.Data;
+
+/**
+ * @author qianliqing
+ * @date 2019/1/18 6:59 PM
+ * email: qianlq0824@gmail.com
+ */
+
+@Data
+public abstract class BaseEntity {
+}

dubbo-core/src/main/java/com/coderqian/dubbocore/model/entity/UserEntity.java

@@ -0,0 +1,19 @@
+package com.coderqian.dubbocore.model.entity;
+
+import lombok.Data;
+
+/**
+ * @author qianliqing
+ * @date 2019/1/18 6:59 PM
+ * email: qianlq0824@gmail.com
+ */
+
+@Data
+public class UserEntity extends BaseEntity {
+
+    private String id;
+
+    private String name;
+
+    private String birth;
+}

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

@@ -0,0 +1,29 @@
+spring.application.name=dubbo-core
+server.port=8020
+
+# 当前dubbo应用id
+dubbo.application.id=dubbo-core
+# 当前dubbo应用名称
+dubbo.application.name=dubbo-core
+# 注册中心
+dubbo.registry.address=zookeeper://127.0.0.1:2181
+dubbo.registry.timeout=60000
+dubbo.registry.group=dubbo
+dubbo.registry.check=false
+
+dubbo.server=true
+# 生产者暴露给消费者协议
+dubbo.protocol.name=dubbo
+# 生产者暴露给消费者端口
+dubbo.protocol.port=20880
+
+logging.config=classpath:log4j2.xml
+
+spring.datasource.url=
+spring.datasource.username=
+spring.datasource.password=
+
+spring.datasource.driver-class-name=com.mysql.jdbc.Driver
+spring.datasource.initialSize=5
+spring.datasource.minIdle=5
+spring.datasource.maxActive=20