1_项目搭建

1_项目搭建数据库父工程1、建Module:supergo_parent2、改pom<?xmlversion=”1.0″encoding=”UTF-8″?><projectxmlns=”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.

大家好,又见面了,我是你们的朋友全栈君。

数据库

在这里插入图片描述


父工程

1、建 Module:supergo_parent

2、改 pom

<?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>
    <groupId>com.supergo</groupId>
    <artifactId>supergo_parent</artifactId>
    <version>1.0-SNAPSHOT</version>
    
    <!--声明为父项目-->
    <packaging>pom</packaging>
    
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <!--管理子工程: 1,锁定坐标版本 2,管理子工程(统一打包,部署) -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.RC1</spring-cloud.version>
        <mybatis.starter.version>1.3.2</mybatis.starter.version>
        <mapper.starter.version>2.0.2</mapper.starter.version>
        <druid.starter.version>1.1.10</druid.starter.version>
        <mysql.version>5.1.32</mysql.version>
        <pageHelper.starter.version>1.2.3</pageHelper.starter.version>
        <fastDFS.client.version>1.27.0.0</fastDFS.client.version>
        <jaxb.version>2.3.0</jaxb.version>
        <activation>1.1.1</activation>
        <springfox>2.2.2</springfox>
        <lambok>1.16.20</lambok>
        <fastjson>1.2.9</fastjson>
        <json-token>0.9.0</json-token>
        <joda-time>2.9.7</joda-time>
        <comment-lang>3.9</comment-lang>
        <aliyun-dayu-core>3.3.1</aliyun-dayu-core>
        <aliyun-dayu-sdk>1.0.0</aliyun-dayu-sdk>
        <swagger-boot>1.9.0.RELEASE</swagger-boot>
        <wxpay.version>0.0.3</wxpay.version>
        <lcn.last.version>4.1.0</lcn.last.version>
        <httpclient.version>4.5.3</httpclient.version>
        <codingapi.txlcn.version>5.0.2.RELEASE</codingapi.txlcn.version>
    </properties>
    
    <!--管理坐标-->
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>net.oschina.zcx7878</groupId>
                <artifactId>fastdfs-client-java</artifactId>
                <version>${fastDFS.client.version}</version>
            </dependency>
            <dependency>
                <groupId>com.aliyun</groupId>
                <artifactId>aliyun-java-sdk-core</artifactId>
                <version>${aliyun-dayu-core}</version>
            </dependency>
            <dependency>
                <groupId>com.aliyun</groupId>
                <artifactId>aliyun-java-sdk-dysmsapi</artifactId>
                <version>${aliyun-dayu-sdk}</version>
            </dependency>
            <dependency>
                <groupId>io.jsonwebtoken</groupId>
                <artifactId>jjwt</artifactId>
                <version>${json-token}</version>
            </dependency>
            <dependency>
                <groupId>joda-time</groupId>
                <artifactId>joda-time</artifactId>
                <version>${joda-time}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-lang3</artifactId>
                <version>${comment-lang}</version>
            </dependency>

            <!-- springCloud -->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <!-- mybatis启动器 -->
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>${mybatis.starter.version}</version>
            </dependency>

            <!-- 通用Mapper启动器 -->
            <dependency>
                <groupId>tk.mybatis</groupId>
                <artifactId>mapper-spring-boot-starter</artifactId>
                <version>${mapper.starter.version}</version>
            </dependency>

            <dependency>
                <groupId>com.github.pagehelper</groupId>
                <artifactId>pagehelper-spring-boot-starter</artifactId>
                <version>${pageHelper.starter.version}</version>
            </dependency>

            <!-- druid启动器 -->
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>${druid.starter.version}</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>${mysql.version}</version>
            </dependency>
            <dependency>
                <groupId>javax.xml.bind</groupId>
                <artifactId>jaxb-api</artifactId>
                <version>${jaxb.version}</version>
            </dependency>
            <dependency>
                <groupId>com.sun.xml.bind</groupId>
                <artifactId>jaxb-core</artifactId>
                <version>${jaxb.version}</version>
            </dependency>
            <dependency>
                <groupId>com.sun.xml.bind</groupId>
                <artifactId>jaxb-impl</artifactId>
                <version>${jaxb.version}</version>
            </dependency>
            <dependency>
                <groupId>javax.activation</groupId>
                <artifactId>activation</artifactId>
                <version>${activation}</version>
            </dependency>
            <dependency>
                <groupId>io.springfox</groupId>
                <artifactId>springfox-swagger2</artifactId>
                <version>${springfox}</version>
            </dependency>
            <dependency>
                <groupId>io.springfox</groupId>
                <artifactId>springfox-swagger-ui</artifactId>
                <version>${springfox}</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>${lambok}</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>${fastjson}</version>
            </dependency>

            <!--微信支付-->
            <dependency>
                <groupId>com.github.wxpay</groupId>
                <artifactId>wxpay-sdk</artifactId>
                <version>${wxpay.version}</version>
            </dependency>

            <!--httpclient-->
            <dependency>
                <groupId>org.apache.httpcomponents</groupId>
                <artifactId>httpclient</artifactId>
                <version>${httpclient.version}</version>
            </dependency>

        </dependencies>
    </dependencyManagement>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
    </repositories>
</project>

3、删除 src目录


搭建 Eureka 注册中心

1、建 Module :supergo_eureka7001

2、改 pom

<?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">
    <parent>
        <artifactId>supergo_parent</artifactId>
        <groupId>com.supergo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>supergo_eureka10086</artifactId>

    <!--注册中心: 服务端-->
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>

</project>

3、建 yml

# 端口
server:
  port: 7001
eureka:
  instance:
    # 单机版【hostname: 127.0.0.1 # Eureka 服务端的实例名称】
    # 集群
    hostname: eureka7001.com
  client:
    register-with-eureka: false # 表示不向注册中心注册自己
    fetch-registry: false # 表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
    service-url:
      # 设置与eureka server 交互的地址查询和注册服务都需要依赖这个地址】
      # 单机版【defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
      defaultZone: http://${ 
   eureka.instance.hostname}:${ 
   server.port}/eureka/
      # 集群:需要去守望另外一台注册中心
      # defaultZone: http://eureka7002.com:7002/eureka/
  # 注册中心的自我保护机制【默认是开启的】
  server:
    enable-self-preservation: false # 关闭自我保护机制,保证不可用的服务及时删除
    eviction-interval-timer-in-ms: 2000 # 改变时间间隔[失效服务剔除]

4、启动类

package com.xj0927;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@SpringBootApplication
@EnableEurekaServer  //发现 Eureka
public class Eureka7001 { 
   
    public static void main(String[] args) { 
   
        SpringApplication.run(Eureka7001.class, args);
    }
}

添加基础模块

这些基础模块是可重用的,不仅是本项目,其它项目也可使用

涉及到的基础模块:

  • supergo-common
  • supergo-mapper
  • supergo-pojo
  • supergo-base-service

supergo-common

该模块主要是工具类和通用类,基类等

比如:

package com.supergo.http;

import java.io.Serializable;

/** * HTTP结果封装:如果请求处理正常就调用ok方法,如果有数据返回就将数据封装返回; 如果请求出错,就调用error方法,返回出错状态码+信息 */
public class HttpResult implements Serializable{ 
   

	private int code = 200;
	private String msg;
	private Object data;
	
	public static HttpResult error() { 
   
		return error(HttpStatus.SC_INTERNAL_SERVER_ERROR, "未知异常,请联系管理员");
	}
	
	public static HttpResult error(String msg) { 
   
		return error(HttpStatus.SC_INTERNAL_SERVER_ERROR, msg);
	}
	
	public static HttpResult error(int code, String msg) { 
   
		HttpResult r = new HttpResult();
		r.setCode(code);
		r.setMsg(msg);
		return r;
	}

	public static HttpResult ok(String msg) { 
   
		HttpResult r = new HttpResult();
		r.setMsg(msg);
		return r;
	}
	
	public static HttpResult ok(Object data) { 
   
		HttpResult r = new HttpResult();
		r.setData(data);
		return r;
	}
	
	public static HttpResult ok() { 
   
		return new HttpResult();
	}

	.....
	
}

分页请求实体类:

package com.supergo.page;

import java.io.Serializable;

/** * @Description: 封装分页的请求参数 * @Author: xj0927 * @Date Created in 2020/12/23 12:56 */
public class PageRequest implements Serializable{ 
   

    private Integer currentPage=1;
    private Integer pageSize=10;
	....
}

分页结果实体类

package com.supergo.page;

import java.io.Serializable;
import java.util.List;

/** * @Description: 封装分页的结果 * @Author: xj0927 * @Date Created in 2020/12/23 12:56 */
public class PageResult implements Serializable { 
   

    private Long total;

    private int page=1;

    private List<?> rows;

    private int pageSize=10;

    public PageResult() { 
   
    }

    public PageResult(Long total, List<?> rows) { 
   
        this.total = total;
        this.rows = rows;
    }

    public PageResult(Long total, List<?> rows,int page) { 
   
        this.total = total;
        this.rows = rows;
        this.page = page;
    }

   ......
}

全部工具类:

在这里插入图片描述


spergo-mapper

存放生成的 Mapper 接口和 映射文件,而实体类抽取出来放在另一个模块 supergo-pojo 中,然后引入到该模块中使用

本项目使用的是 tk-mybatis,如何使用插件反向生成接口、实体类和映射文件,可参照:https://blog.csdn.net/XJ0927/article/details/111590559

贴一下该模块使用到的 pom 依赖:

<?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">
    <parent>
        <artifactId>supergo_parent</artifactId>
        <groupId>com.supergo</groupId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../pom.xml</relativePath>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>supergo-mapper</artifactId>

    <dependencies>
        <!--引入pojo:主要是实体类-->
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo-pojo</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!--数据库相关东西-->
        <dependency>
            <groupId>com.github.pagehelper</groupId>
            <artifactId>pagehelper-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>tk.mybatis</groupId>
            <artifactId>mapper-spring-boot-starter</artifactId>
            <version>2.0.2</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

    <!--tk-mybatis 反向生成所需要的的插件-->
    <build>
        <plugins>
            <plugin>
                <groupId>org.mybatis.generator</groupId>
                <artifactId>mybatis-generator-maven-plugin</artifactId>
                <version>1.3.7</version>
                <configuration>
                    <verbose>true</verbose>
                    <overwrite>true</overwrite>
                </configuration>
                <dependencies>
                    <dependency>
                        <groupId>tk.mybatis</groupId>
                        <artifactId>mapper</artifactId>
                        <version>4.1.5</version>
                    </dependency>
                    <dependency>
                        <groupId>mysql</groupId>
                        <artifactId>mysql-connector-java</artifactId>
                        <version>8.0.19</version>
                    </dependency>
                    <dependency>
                        <groupId>com.github.misterchangray.mybatis.generator.plugins</groupId>
                        <artifactId>myBatisGeneratorPlugins</artifactId>
                        <version>1.2</version>
                    </dependency>
                </dependencies>
            </plugin>
        </plugins>
    </build>

</project>

在这里插入图片描述


supergo-pojo

用于存放实体类

在这里插入图片描述


supergo-base-service

存放 service 层的接口和实现类的通用基类,通过它我们具体的 service 就不用了在写 crud 操作了,类比 mybatis plus 中的 Service 和 ServiceImpl 这两个类

引入 pom

<?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">
    <parent>
        <artifactId>supergo_parent</artifactId>
        <groupId>com.supergo</groupId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../pom.xml</relativePath>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>supergo-base-service</artifactId>

    <dependencies>
        <!--存放的映射文件和接口,因为该模块引入了实体模块,所以也间接引入了实体类-->
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo-mapper</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>

接口规范

package com.supergo.service.base;

import com.supergo.page.PageResult;
import com.supergo.http.HttpResult;
import java.io.Serializable;
import java.util.List;

/** * 功能描述:增删改查通用service */
public interface BaseService<T> { 
   

    /** * 根据主键查询 * * @param id 主键 * @return 实体对象 */
    public T findOne(Serializable id);

    /** * 查询全部 * * @return 实体对象集合 */
    public HttpResult findAll();

    /** * 根据条件查询列表 * * @param t 查询条件对象 * @return */
    public List<T> findByWhere(T t);

    /** * 分页查询列表 * * @param page 页号 * @param rows 页大小 * @return 分页实体对象 */
   public PageResult findPage(Integer page, Integer rows);

    /** * 根据条件分页查询列表 * * @param page 页号 * @param rows 页大小 * @param t 查询条件对象 * @return 分页实体对象 */
   public PageResult findPage(Integer page, Integer rows, T t);

    /** * 新增 * * @param t 实体对象 */
    public void add(T t);

    /** * 根据主键更新 * * @param t 实体对象 */
    public void update(T t);

    /** * 批量删除 * * @param ids 主键集合 */
    public void deleteByIds(Serializable[] ids);

}

实现类

package com.supergo.service.base.impl;

import java.io.Serializable;
import java.util.List;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.supergo.service.base.BaseService;
import com.supergo.page.PageResult;
import com.supergo.http.HttpResult;
import org.springframework.beans.factory.annotation.Autowired;
import tk.mybatis.mapper.common.Mapper;

/** * 功能描述:增删改查通用service实现类 */
public abstract class BaseServiceImpl<T> implements BaseService<T> { 
   

    //spring 4.x 版本之后引入的泛型依赖注入
    //通过该mapper,传入泛型,作用类似于xxxMapper
    @Autowired
    private Mapper<T> mapper;

    @Override
    public T findOne(Serializable id) { 
   
        return mapper.selectByPrimaryKey(id);
    }

    @Override
    public HttpResult findAll() { 
   
        return HttpResult.ok(mapper.selectAll());
    }

    @Override
    public List<T> findByWhere(T t) { 
   
        return mapper.select(t);
    }

   @Override
    public PageResult findPage(Integer page, Integer rows) { 
   
        PageHelper.startPage(page, rows);
        List<T> list = mapper.selectAll();
        PageInfo<T> pageInfo = new PageInfo<>(list);
        return new PageResult(pageInfo.getTotal(),
                pageInfo.getList(),page);
    }

  //分页方法:使用的是PageHelper进行分页
  //可以增加限制条件进行分页
  @Override
    public PageResult findPage(Integer page, Integer rows, T t) { 
   
        PageHelper.startPage(page, rows);
        List<T> list = mapper.select(t);
        PageInfo<T> pageInfo = new PageInfo<>(list);
        return new PageResult(pageInfo.getTotal(),
                pageInfo.getList(),page);
    }

    @Override
    public void add(T t) { 
   
        mapper.insertSelective(t);
    }

    @Override
    public void update(T t) { 
   
        mapper.updateByPrimaryKeySelective(t);
    }

    @Override
    public void deleteByIds(Serializable[] ids) { 
   
        if (ids != null && ids.length > 0) { 
   
            for (Serializable id : ids) { 
   
                mapper.deleteByPrimaryKey(id);
            }
        }
    }
}

搭建品牌微服务提供者

这里加了一层 feign 进行调用:

  • supergo_manager_service8001:包含我们的实际业务逻辑
  • supergo_manager_feign:客户端 Feign 调用的接口定义

在这里插入图片描述


supergo_manager 父模块

1、建父 Module:supergo_manager

2、改 pom

<?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">
    <parent>
        <artifactId>supergo_parent</artifactId>
        <groupId>com.supergo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>supergo_manager</artifactId>

    <!--声明为父项目-->
    <packaging>pom</packaging>
    <!--子模块-->
    <modules>
        <module>supergo_manager_service8001</module>
        <module>supergo_manager_feign</module>
    </modules>

</project>

supergo_manager_service8001 业务模块

实现品牌、商品等管理的微服务工程

1、建 Module:supergo_manager_service8001

2、改 pom

<?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">
    <parent>
        <artifactId>supergo_manager</artifactId>
        <groupId>com.supergo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>supergo_manager_service</artifactId>
    <dependencies>
        <!--web 与 actuator监控-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <!--hystrix 熔断器-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>

        <!--eureka 客户端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <!--公用service模块-->
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo-base-service</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!--公用 mapper模块-->
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo-mapper</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

3、建 yml

# 端口
server:
  port: 8001

# 名字
spring:
  application:
    name: supergo-manager # 代表的就是我以什么样的名字入驻进的注册中心
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型
    driver-class-name: com.mysql.jdbc.Driver # mysql驱动类
    url: jdbc:mysql://127.0.0.1:3306/supergo?useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQueries=true
    username: root
    password: 123456

    # druid 专属配置
    druid:
      initial-size: 5
      min-idle: 5
      max-active: 20
      max-wait: 1000
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
      validation-query: select 'x'
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      pool-prepared-statements: true
      max-open-prepared-statements: 50
      max-pool-prepared-statement-per-connection-size: 20

      # stat是统计,wall是SQL防火墙,防SQL注入的,log4j是用来输出统计数据的
# filters: stat,wall,log4j,config
      ##是否启用StatFilter默认值true: 排除一些不必要的url
      web-stat-filter:
        enabled: true
        exclusions: '*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*'
      #是否启用StatViewServlet默认值true
      stat-view-servlet:
        allow: 127.0.0.1 #IP 白名单
        url-pattern: /druid/* #监控地址,默认 /druid/*
        login-username: admin
        login-password: admin #
  # deny:IP #黑名单

  # 最大请求文件的大小
  servlet:
    multipart:
      max-request-size: 5MB


mybatis:
  type-aliases-package: com.supergo.pojo #所有别名类所在的包

eureka:
  client:
    register-with-eureka: true # 表示将自己注册到 eureka server ,默认为 true
    fetch-registry: true # 表示是否从eureka server 抓取已有的注册信息,默认为true。单节点为所谓,集群必须为 true,才能配合ribbon使用负载均衡
    service-url:
      # 单机版:只用注册进一个服务中心【defaultZone: http://127.0.0.1:7001/eureka/】
      defaultZone: http://eureka7001.com:7001/eureka/
      # 集群版:需要同时注册进每个注册中心
  # defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com/eureka/
  # 显示的服务主机名称
  instance:
    prefer-ip-address: true # 访问路径显示 ip【统一:方便调试】
    ip-address: 127.0.0.1
    instance-id: ${ 
   eureka.instance.ip-address}.${ 
   server.port}
    lease-renewal-interval-in-seconds: 3
    lease-expiration-duration-in-seconds: 10
    #网关设置了根路径,默认监控路径发生了变化
    health-check-url-path: /api/actuator/health

#actuator服务监控与管理
management:
  endpoint:
    #开启端点
    shutdown:
      enabled: true
    health:
      show-details: always
  # 加载所有的端点
  endpoints:
    web:
      exposure:
        include: "*"

4、启动类

package com.supergo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import tk.mybatis.spring.annotation.MapperScan;

@SpringBootApplication
@EnableEurekaClient //注册进注册中心
@MapperScan("com.supergo.mapper") //扫描引入的公用即接口包
public class ManagerService8001 { 
   
    public static void main(String[] args) { 
   
        SpringApplication.run(ManagerService8001.class, args);
    }
}

5、service 层

接口:

package com.supergo.service;

import com.supergo.pojo.Brand;
import com.supergo.service.base.BaseService;

/** * @Author: xj0927 * @Description: * @Date Created in 2020-12-23 18:40 * @Modified By: */
public interface BrandService extends BaseService<Brand> { 
   
}

实现类:

package com.supergo.service.imp;

import com.supergo.pojo.Brand;
import com.supergo.service.base.impl.BaseServiceImpl;

import com.supergo.service.BrandService;
import org.springframework.stereotype.Service;


/** * @Author: xj0927 * @Description: * @Date Created in 2020-12-23 18:41 * @Modified By: */
@Service
public class BrandServiceImpl extends BaseServiceImpl<Brand> implements BrandService { 
   

}

6、controller 层

package com.supergo.controller;

import com.supergo.pojo.Brand;
import com.supergo.http.HttpResult;
import com.supergo.page.PageResult;
import com.supergo.service.BrandService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

/** * @Author: xj0927 * @Description: * @Date Created in 2020-12-23 19:25 * @Modified By: */
@RestController
@RequestMapping("/brand")
public class BrandController { 
   

    @Autowired
    private BrandService brandService;

    //分页查询
    @PostMapping("/query/{page}/{rows}")
    public HttpResult findPage(@RequestBody Brand brand, @PathVariable Integer page, @PathVariable Integer rows) { 
   
        try { 
   
            PageResult result = brandService.findPage(page, rows, brand);
            //查询成功
            return HttpResult.ok(result);
        } catch (Exception e) { 
   
            e.printStackTrace();
            //查询异常
            return HttpResult.error();
        }
    }
}

7、测试

使用 postman 测试

在这里插入图片描述
在这里插入图片描述

至此,表示服务提供者提供的服务没有问题


supergo_manager_feign调用模块

1、建 Moduel:supergo_manager_feign

2、改 pom

<?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">
    <parent>
        <artifactId>supergo_manager</artifactId>
        <groupId>com.supergo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>supergo_manager_feign</artifactId>

    <dependencies>
        <!--服务调用openfeign-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!--工具类-->
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!--实体类-->
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo-pojo</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>

</project>

3、调用接口

package com.supergo;

import com.supergo.pojo.Brand;
import com.supergo.http.HttpResult;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;

/** * @Author: xj0927 * @Description: * @Date Created in 2020-12-23 21:24 * @Modified By: */
@FeignClient(value = "supergo-manager")//发现服务提供者
public interface ApiBrandFeign { 
   
    //分页查询
    @PostMapping("/brand/query/{page}/{rows}")
    public HttpResult findPage(@RequestBody Brand brand, @PathVariable Integer page, @PathVariable Integer rows);
}

4、使用

其他模块,需要使用该服务时,便可以通过该接口进行服务调用


搭建品牌微服务调用者

1、建 Module:supergo_manager_web9001

2、改 pom

<?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">
    <parent>
        <artifactId>supergo_parent</artifactId>
        <groupId>com.supergo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>supergo_manager_web9002</artifactId>
    <dependencies>
        <!--eureka 客户端依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--监控依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <!--hystrix熔断依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!--在feign模块使用了tk-mybatis进行数据库的访问, 这里引入feign,会间接引入tk-mybatis 需要排除tk-mybatis,不然会要求进行数据库配置 -->
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo_manager_feign</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>tk.mybatis</groupId>
                    <artifactId>mapper-spring-boot-starter</artifactId>
                </exclusion>
            </exclusions>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!-- swagger -->
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger2</artifactId>
            <version>2.8.0</version>
        </dependency>
        <!-- 工具类 -->
        <dependency>
            <groupId>com.supergo</groupId>
            <artifactId>supergo-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

3、建 yml

# 端口号【openfeign 也是使用在客户端,集成了ribbon】
server:
  port: 9001
spring:
  application:
    name: supergo-manager-web9001
eureka:
  client:
    register-with-eureka: true # 注册进注册中心
    service-url:
      # 集群版
      # defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
      # 单机版
       defaultZone: http://eureka7001.com:7001/eureka/
    # 显示的服务主机名称
  instance:
    prefer-ip-address: true # 访问路径显示 ip【统一:方便调试】
    ip-address: 127.0.0.1
    instance-id: ${ 
   eureka.instance.ip-address}.${ 
   server.port}
    lease-renewal-interval-in-seconds: 3
    lease-expiration-duration-in-seconds: 10

#actuator服务监控与管理
management:
  endpoint:
    #开启端点
    shutdown:
      enabled: true
    health:
      show-details: always
  # 加载所有的端点
  endpoints:
    web:
      exposure:
        include: "*"

# 设置feign客户端超时时间(OpenFeign默认支持ribbon)
ribbon:
  # 指的是建立连接所用的时间,适用于网络状态正常的情况下,两端连接所用的时间
  ReadTimeout: 5000
  # 指的是建立连接后从服务器读取到可用资源所用的时间
  ConnectTimeout: 5000
logging:
  level:
    # feign日志以什么级别监控哪个接口
    com.supergo.ApiBrandFeign: debug

4、启动类

package com.supergo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableEurekaClient //注册进注册中心
@EnableFeignClients //发现feign服务
public class ManagerWeb9001 { 
   
    public static void main(String[] args) { 
   
        SpringApplication.run(ManagerWeb9001.class, args);
    }
}

5、controller层

package com.supergo.controller;

import com.supergo.ApiBrandFeign;
import com.supergo.http.HttpResult;
import com.supergo.pojo.Brand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

/** * @Author: xj0927 * @Description: feign服务调用者 * @Date Created in 2020-12-23 22:01 * @Modified By: */
@RestController
@RequestMapping("/brand")
public class BrandController { 
   

    //feigm服务api接口
    @Autowired
    private ApiBrandFeign brandFeign;

    @PostMapping("/query/{page}/{rows}")
    public HttpResult getBrandList(@RequestBody Brand brand, @PathVariable Integer page, @PathVariable Integer rows) { 
   
        //feign服务
        HttpResult result = brandFeign.findPage(brand, page, rows);
        return result;
    }
}

6、测试

使用 postman 测试

在这里插入图片描述


版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/152820.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 软件著作权申请流程_如何申请软件著作权

    软件著作权申请流程_如何申请软件著作权现在越来越多的安卓市场需要软著才能注册或者是才能上线,申请软著势在必行。最简单的方式,简单的准备资料,找第三方代理,不过这样可能花费数百毛爷爷,如果是急需加急,可能是几千。现在简单说一下自己申请的流程:首先贴出中国版权保护中心网站中国版权保护中心:http://apply.ccopyright.com.cn/cpcc/column_list_bqdj.jsp请使用IE浏览器打开一.注册

  • fiddler进行弱网测试

    使用Fiddler对手机App应用进行抓包,可以对App接口进行测试,也可以了解App传输中流量使用及请求响应情况,从而测试数据传输过程中流量使用的是否合理。抓包过程:1、Fiddler设置1)启动Fiddler->Tools->FiddlerOptions2)HTTPS选项卡中,设置如下,勾选过程中如有弹窗允许即可;Connections选项卡中,勾选Allowre…

  • 工程伦理学_笔记(复习用)「建议收藏」

    工程伦理学_笔记(复习用)「建议收藏」工程伦理学第一章工程与伦理1.1如何理解工程一、技术与工程的区别二、技术与工程的联系三、工程的定义四、工程的过程五、工程具有不确定性和探索性六、理解工程活动的7个维度1.2如何理解伦理一、道德与伦理二、不同的伦理立场三、伦理困境与伦理选择1.3工程实践中的伦理问题一、工程活动中的行动者网络(具有动态性和网络性)二、主要的工程伦理问题三、工程伦理问题的特点1.4如何处理工程实践中的伦理问题一、工程实践中伦理问题的辨识二、处理工程伦理问题的基本原则三、应对工程伦理问题的基本思路第二章工程中的风险、安

  • 小米6显示服务器出错,小米6解锁BL显示未连接手机解决办法以及各种小技巧汇总……

    小米6显示服务器出错,小米6解锁BL显示未连接手机解决办法以及各种小技巧汇总……本帖最后由为夫人而生于2017-6-2422:56编辑持续更新小米6未连接手机解决办法3:手机设置→关于手机→miui版本(一直点五次)→返回→更多设置→开发者选项→USB调试打开→手机绑定啥的解锁啥的都打开4:关机长按音量下加开机键出现兔子连接手机5:两种情况若显示连接直接解锁end;;;;;;;;;若显示没连接手机敲黑板重点来了右…

  • java事务总述_什么是先总述后详述

    java事务总述_什么是先总述后详述java事务总述一、java事务概述1.1、java事务简述1、简介事务(TRANSACTION)是作为单个逻辑工作单元执行的一系列SQL操作,这些操作作为一个整体一起向系统提交,要么都执行、要么都不执行。如果任何一个SQL操作失败,那么整个操作就都失败,所有操作都会回滚到操作前状态,或者是上一个节点。2、java事务和数据库事务的关联实际上,一个Java应用系统,如果要操作数据库,则通过JDBC来实现的。增加、修改、删除都是通过相应方法间接来实现的,事务的控制也相应转移到Java程序代码中。因

  • 罗技键盘锁了,按哪个键就开了_无线键盘自动休眠

    罗技键盘锁了,按哪个键就开了_无线键盘自动休眠在弹出的界面中查看一下系统是不是已经开启了休眠。如果没有休眠,则无需关闭,如果有这个选项,就继续看下面;然后打开开始菜单,在开始菜单的右边会有一个控制面板的选项,打开控制面板,在控制面板中,找到电源选项,然后点击打开统已经默认设定了一个电源计划,即推荐的选项,但是,系统休眠会占用许多系统空间,所以要把它给设置为关闭。点击平衡右边的蓝色的设置链接,即更改计划设置;在更改计划的设置中,点击下面的更改高…

    2022年10月10日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号