缘起本项目是基于之前学习的一个Dubbo+SSM分布式项目进行升级,基于此项目对前后端分离项目、微服务项目进一步深入学习。之前学习了vue、springBoot、springCloud后,没有进行更多实战练习,借助此机会,整合之前所学知识,搭建一套微服务电商系统。本项目纯属个人学习总结,如有错误之处,还希望大家能指出,共同讨论学习。 正文1、项目依赖环境 工具:idea+vsCode 数据库:mysql 缓存:redis 消息中间件:ActiveMq 2、项目架构图(暂时留个位置) 3、整体框架结构 -parent 聚合工程 -api 各模块提供服务的接口 -eurekaserver 服务注册中心 -pojo 通用实体类层 -dao 通用数据访问层 -common 通用方法 -xxxxx-interface 某服务层接口 -xxxxx-service 某服务层实现 -xxxxx-web 某web工程 4、数据库表 (后期上传) 一、搭建框架1、创建父工程 至于如何创建聚合工程,此处不在详细说明,网上有更多详细的教程。 创建Maven工程pinyougou-parent (POM) ,groupId 为com.pinyougou ,artifactId 为pinyougou-parent 。 添加依赖(后期根据需求有所变更) <dependencies> <!--安全框架--> <!--<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-security</artifactId> </dependency>--> <!-- springboot整合activemq --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency> <!-- springboot整合amqp --> <!--<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>--> <!--数据库jdbc连接池--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency> <!-- 集成web--> <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>2.0.0</version> </dependency> <!--集成springCloud--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-zuul</artifactId> </dependency> <!--集成热部署--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <scope>runtime</scope> </dependency> <!--mysql连接驱动--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <!-- 集成lombok 框架 --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <!--springBoot测试--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <!-- 集成redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <!-- jedis客户端 --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency> <!-- spring2.X集成redis所需common-pool2,使用jedis必须依赖它--> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> <version>2.5.0</version> </dependency> <!-- 集成aop --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-aop</artifactId> </dependency> <!-- 集成commons工具类 --> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.4</version> </dependency> <!-- 集成发送邮件--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-mail</artifactId> </dependency> <!-- 阿里巴巴数据源 --> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.1.14</version> </dependency> <!-- httpclient --> <dependency> <groupId>commons-httpclient</groupId> <artifactId>commons-httpclient</artifactId> <version>3.1</version> </dependency> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.30</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> </dependency> <dependency> <groupId>commons-net</groupId> <artifactId>commons-net</artifactId> <version>3.3</version> </dependency> <!--<dependency> <groupId>org.springframework.security</groupId> <artifactId>spring-security-test</artifactId> <scope>test</scope> </dependency>--> </dependencies> 2、服务注册中心模块 创建服务注册中心模块-pinyougou-eurekaserver 配置注册中心,端口号设置为8761 server: port: 8761eureka: instance: hostname: localhost # eureka实例的主机名 client: register-with-eureka: false #不把自己注册到eureka上 fetch-registry: false #不从eureka上来获取服务的注册信息 service-url: defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #服务的注册地址 添加启动类,开启Eureka Server服务 @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class}) @EnableEurekaServer //开启Eureka Serverpublic class EurekaServerApplication {public static void main(String[] args){ SpringApplication.run(EurekaServerApplication.class,args); } } 测试:启动Eureka Server服务,浏览器输入http://localhost:8761/, 能访问springEureka说明服务注册中心配置成功. 3、通用实体类模块 创建通用实体类模块-pinyougou-pojo Pojo:数据库实体类 Entity:统一返回数据实体类 Pojogroup:封装的实体类数据 4、通用数据访问模块 创建通用数据访问模块pinyougou-dao .添加依赖pinyougou-pojo 新建包com.pinyougou.mapper,写需要的mapper接口,注意:需要在加注释@Mapper 在resource下,写mapper映射文件 5、通用工具类模块 创建通用工具类模块pinyougou-common 6、商家商品服务接口模块 创建模块pinyougou-sellergoods-interface,添加依赖pinyougou-pojo 新建包com.pinyougou.sellergoods.service,写service层接口 7、服务接口提供模块 创建pinyougou-api(pom) 说明:该模块提供各模块所需提供的接口,为api父工程,各模块需要提供接口服务时,在该父工程下新建各自的子模块. 本项目实现流程:该模块提供的接口,在对应service模块编写逻辑,调用方调用服务的时候,继承api提供的接口,使用@FeignClient(‘service模块的名称’)注解调用服务. 8、商品服务api 创建pinyougou-sellergoods-api模块,依赖pinyougou-pojo 创建包com.pinyougou.pojo.TbBrand,编写一个测试类: @RequestMapping("/brand")public interface BrandApiService { @RequestMapping("/findAll")public List<TbBrand> findAll(); } 9、商家商品服务模块 创建pinyougou-sellergoods-service, 添加依赖pinyougou-sellergoods-interface,pinyougou-dao,pinyougou-sellergoods-api 配置文件: server: port: 9001eureka: client: service-url: defaultZone: http://localhost:8761/eureka/spring: application: name: sellergoods datasource: name: pinyougoudb #?useUnicode=true&characterEncoding=utf8 url: jdbc:mysql://localhost:3306/pinyougoudb?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC username: root password: root # 使用druid数据源 type: com.alibaba.druid.pool.DruidDataSource driver-class-name: com.mysql.cj.jdbc.Driver # 数据源其他配置 initialSize: 5minIdle: 5maxActive: 20maxWait: 60000timeBetweenEvictionRunsMillis: 60000minEvictableIdleTimeMillis: 300000validationQuery: SELECT 1 FROM DUAL testWhileIdle: truetestOnBorrow: falsetestOnReturn: falsepoolPreparedStatements: true# 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙 filters: stat,wall,log4j maxPoolPreparedStatementPerConnectionSize: 20useGlobalDataSourceStat: trueconnectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500mybatis: # 指定全局配置文件位置 #config-location: classpath:mybatis/mybatis-config.xml mapper-locations: classpath*:/mapper/*Mapper.xml #实体扫描,多个package用逗号或者分号分隔 type-aliases-package: com.pinyougou.pojo configuration: #配置返回数据库(column下划线命名&&返回java实体是驼峰命名),自动匹配无需as(没开启这个,SQL需要写as: select user_id as userId) map-underscore-to-camel-case: true #配置JdbcTypeForNull, oracle数据库必须配置 jdbc-type-for-null: 'null' 编写启动类,添加扫描mapper类的注解,将服务注册到注册中心 @MapperScan(value = "com.pinyougou.mapper") @SpringBootApplication @EnableEurekaClientpublic class SellerGoodsServiceApplication {public static void main(String[] args) { SpringApplication.run(SellerGoodsServiceApplication.class, args); } } 创建包com.pinyougou.sellergoods.service.impl,作用:实现interface模块,编写数据访问层业务逻辑.注意:该类上要加@Service注解. 创建包com.pinyougou.sellergoods.api.service.impl,作用:实现服务提供者api接口,编写暴露接口的业务逻辑,注意:该类上要添加@RestController注解. 10、运营商管理后台 创建包pinyougou-manager-web,依赖pinyougou-sellergoods-api 在resources下创建配置文件: server: port: 9101eureka: client: service-url: defaultZone: http://localhost:8761/eureka/spring: freemarker: suffix: .html templateLoaderPath: classpath:/templates/cache: false #禁用模板缓存,正式环境取消 application: name: managerweb main: allow-bean-definition-overriding: true 创建包com.pinyougou.manager.feign,用于服务的调用 @FeignClient("sellergoods") //写service层的名称public interface BrandFeign extends BrandApiService { } 此时,就可以使用BrandFeign调用BrandApiService的接口 创建包com.pinyougou.manager.controller,进行测试 @RestController @RequestMapping("/brands")public class BrandController { @Autowiredprivate BrandFeign brandFeign; @RequestMapping("/findAll")public List<TbBrand> findAll(){ List<TbBrand> lists=null; lists=brandFeign.findAll();return lists; } } 启动服务: 启动pinyougou-eurekaserver 启动pinyougou-sellergoods-service 启动pinyougou-manager-web 在浏览器输入:http://localhost:9101/brands/findAll,如果能获取到数据库数据,说明服务调用成功. 此时,浏览器中输入http://localhost:8761/,能看到刚启动的两个服务已经注册到Eureka注册中心了. 目前的项目框架如下: |
|