临时提交

Author: qianlq

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

@@ -15,4 +15,12 @@ public interface TestService {
      * @return String
      */
     String test(String text);
+
+    /**
+     * 测试接口
+     *
+     * @param text 测试数据
+     * @return String
+     */
+    String testMybatis(String text);
 }

dubbo-provider/pom.xml

@@ -35,13 +35,33 @@
             <artifactId>spring-boot-starter-actuator</artifactId>
         </dependency>
 
-        <!-- Hystrix依赖 -->
+        <!-- 引入Hystrix依赖 -->
         <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
             <version>2.0.1.RELEASE</version>
         </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.apache.zookeeper</groupId>
             <artifactId>zookeeper</artifactId>
@@ -77,6 +97,13 @@
                 </exclusion>
             </exclusions>
         </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.0</version>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
 
     <dependencyManagement>

dubbo-provider/src/main/java/com/coderqian/dubboprovider/DubboProviderApplication.java

@@ -1,13 +1,15 @@
 package com.coderqian.dubboprovider;
 
 import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
+import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 
 @EnableDubbo
 @EnableHystrix
 @SpringBootApplication
+@MapperScan("com.coderqian.dubboprovider.mapper")
 //@ImportResource({"classpath:dubbo/dubbo-provider.xml"})
 public class DubboProviderApplication {
 

dubbo-provider/src/main/java/com/coderqian/dubboprovider/configuration/config/DruidDBConfig.java

@@ -0,0 +1,54 @@
+package com.coderqian.dubboprovider.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-provider/src/main/java/com/coderqian/dubboprovider/configuration/filter/DruidStatFilter.java

@@ -0,0 +1,19 @@
+package com.coderqian.dubboprovider.configuration.filter;
+
+import com.alibaba.druid.support.http.WebStatFilter;
+
+import javax.servlet.annotation.WebFilter;
+import javax.servlet.annotation.WebInitParam;
+
+/**
+ * Created by superlee on 2017/11/6.
+ * 配置druid监控统计功能
+ * Druid过滤器
+ */
+@WebFilter(filterName = "druidWebStatFilter", urlPatterns = "/*",
+        initParams = {
+                @WebInitParam(name = "exclusions", value = "*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*")// 忽略资源
+        }
+)
+public class DruidStatFilter extends WebStatFilter {
+}

dubbo-provider/src/main/java/com/coderqian/dubboprovider/configuration/servlet/DruidStatViewServlet.java

@@ -0,0 +1,26 @@
+package com.coderqian.dubboprovider.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-provider/src/main/java/com/coderqian/dubboprovider/mapper/UserMapper.java

@@ -0,0 +1,23 @@
+package com.coderqian.dubboprovider.mapper;
+
+import com.coderqian.dubboprovider.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-provider/src/main/java/com/coderqian/dubboprovider/model/entity/BaseEntity.java

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

dubbo-provider/src/main/java/com/coderqian/dubboprovider/model/entity/UserEntity.java

@@ -0,0 +1,19 @@
+package com.coderqian.dubboprovider.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-provider/src/main/java/com/coderqian/dubboprovider/service/impl/TestServiceImpl.java

@@ -23,4 +23,9 @@ public class TestServiceImpl implements TestService {
     public String test(@ApiParam(value = "测试数据", required = true) String text) {
         return text;
     }
+
+    @Override
+    public String testMybatis(String text) {
+        return null;
+    }
 }