当前位置:主页 > 查看内容

javaweb-青橙项目-1-76

发布时间:2021-08-02 00:00| 位朋友查看

简介:文章目录 1.项目预计 1.1小项目特点 1.2大项目特点 1.3 主要电商模式 2. 青橙-需求分析与系统设计 2.1 需求分析 2.2 系统设计 2.2.1 数据库分库设计 2.2.3 系统架构图 3. 通用mapper 3.1 通用mapper简介 3.2 通用mapper快速入门 3.2.1 通用mapper与Spring集……

1.项目预计

序列1-地址:https://github.com/Jonekaka/javaweb-qingcheng-1-76/tree/master/qingchengcode/qingchengcode

1.1小项目特点

对于一些小项目ssm就够了,但是对于高并发的大项目
需要更多新技术的融合与赋能

1.2大项目特点

技术新,技术范围广-技术
分布式、集群、高并发、负载均衡、高可用-设备压力分担
海量数据-数据
业务复杂-业务
系统安全-安全
将多个小设备虚拟为一个超算

1.3 主要电商模式

B2B ( Business to Business)是指进行电子商务交易的供需双方都是商家(或企
业、公司),她(他)们使用了互联网的技术或各种商务网络平台,完成商务交易的
过程。电子商务是现代 B2B marketing的一种具体主要的表现形式。
案例:阿里巴巴、慧聪网

C2C即 Customer(Consumer) to Customer(Consumer),意思就是消费者个
人间的电子商务行为。比如一个消费者有一台电脑,通过网络进行交易,把它出售给
另外一个消费者,此种交易类型就称为C2C电子商务。
案例:淘宝、易趣、瓜子二手车

B2C是Business-to-Customer的缩写,而其中文简称为“商对客”。“商对客”是电子商
务的一种模式,也就是通常说的直接面向消费者销售产品和服务商业零售模式。这种
形式的电子商务一般以网络零售业为主,主要借助于互联网开展在线销售活动。B2C
即企业通过互联网为消费者提供一个新型的购物环境——网上商店,消费者通过网络
在网上购物、网上支付等消费行为。
注:本项目采用B2C模式

案例:唯品会、乐蜂网B2B2C是一种电子商务类型的网络购物商业模式,B是BUSINESS的简称,C是
CUSTOMER的简称,第一个B指的是商品或服务的供应商,第二个B指的是从事电子
商务的企业,C则是表示消费者。
案例:京东商城、天猫商城

C2B(Consumer to Business,即消费者到企业),是互联网经济时代新的商业模
式。这一模式改变了原有生产者(企业和机构)和消费者的关系,是一种消费者贡献
价值(Create Value), 企业和机构消费价值(Consume Value)。
C2B模式和我们熟知的供需模式(DSM, Demand SupplyModel)恰恰相反,真正的
C2B 应该先有消费者需求产生而后有企业生产,即先有消费者提出需求,后有生产
企业按需求组织生产。通常情况为消费者根据自身需求定制产品和价格,或主动参与
产品设计、生产和定价,产品、价格等彰显消费者的个性化需求,生产企业进行定制
化生产。
案例:海尔商城、 尚品宅配

O2O即Online To Offline(在线离线/线上到线下),是指将线下的商务机会与互联
网结合,让互联网成为线下交易的平台,这个概念最早来源于美国。O2O的概念非
常广泛,既可涉及到线上,又可涉及到线下,可以通称为O2O。主流商业管理课程均
对O2O这种新型的商业模式有所介绍及关注。
案例:美团、饿了吗

F2C指的是Factory to customer,即从厂商到消费者的电子商务模式。

2. 青橙-需求分析与系统设计

2.1 需求分析

《青橙》是一个全品类B2C电商平台(单品类就是只卖一类,比如衣服,化妆品),包含网站前台和管理后台两大部分。网站前台
包含主站频道(首页、搜索、购物车及支付)、用户中心、秒杀、优惠券等频道。管理
后台包含商品、订单、库存、用户、运营、统计、财务、设置等功能
后台
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

前台
在这里插入图片描述
在这里插入图片描述
等等,商品详情页,登录页,评论页

2.2 系统设计

2.2.1 数据库分库设计

(1)商品库 qingcheng_goods
(2)订单库 qingcheng_order
(3)基础设置库 qingcheng_config
(4)运营库 qingcheng_business
(5)用户库 qingcheng_user
(6)系统库qingcheng_system
(7)支付库 qingcheng_pay
(8)短信库 qingcheng_sms
2.2.2 技术选型
主框架技术:SSM(通用mapper,比mybatis使用更加简单)+Dubbo(分布式框架)
前端技术: 网站后台 Vue.js+ElementUI(ui库) 网站前台采用Vue.js 和模板技术 thymeleaf
消息中间件技术: RabbitMQ
搜索中间件技术: elasticsearch
缓存中间件技术: redis
报表插件: echars
安全框架:SpringSecurity
单点登录中间件 :CAS

2.2.3 系统架构

在这里插入图片描述

3. 通用mapper

3.1 通用mapper简介

对mybatis进行了进一步封装,解决mybatis存在的问题
通用 Mapper 是一个可以实现任意 MyBatis 通用方法的框架,项目提供了常规的增
删改查操作以及Example相关的单表操作。为什么要用通用mapper?我们这里列举一下
原生Mybatis的痛点:
1、mapper.xml文件里有大量的sql,当数据库表字段变动,配置文件就要修改
2、需要自己实现sql分页,select * from table where . . . limit 1,3
自己手写分页,除了传参page、pageSize,还需要返回条目总数count。
3、数据库可移植性差:如果项目更换数据库,比如oracle–>mysql,mapper.xml中的
sql要重新写,因为Oracle的PLSQL 和mysql 支持的函数是不同的。
4、生成的代码量过大。
5、批量操作,批量插入,批量更新,需要自写。
而这些,通过通用mapper就可以很轻松的解决了。

3.2 通用mapper快速入门

在线官方文档:https://gitee.com/free/Mapper/wikis/Home

3.2.1 通用mapper与Spring集成

官方的文档中介绍了通用mapper的三种使用方式 ,纯java使用方式、与Spring集成方
式、与SpringBoot集成方式。这里给大家介绍的是与Spring集成方式。

如果对语句抽象化,自动生成,自然能够避免表不同,数据库语法不同而带来的修改问题
同时也可以实现扩展功能,比如自动分页
也可以批量完成
实现数据库接口crud调用mapper提供的功能接口即可

(1)引入依赖
正常情况下,Spring 和 MyBatis 的集成环境中,应该已经存在下面的依赖:

<dependency>
        <groupId>org.mybatis</groupId>
        <artifactId>mybatis</artifactId>
        <version>版本号</version>
    </dependency>
    <dependency>
        <groupId>org.mybatis</groupId>
        <artifactId>mybatis‐spring</artifactId>
        <version>版本号</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring‐context</artifactId>
        <version>版本号</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring‐tx</artifactId>
        <version>版本号</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring‐jdbc</artifactId>
        <version>版本号</version>
    </dependency>

集成通用 Mapper 在上面的基础上添加下面的依赖:

  <dependency>
        <groupId>tk.mybatis</groupId>
        <artifactId>mapper</artifactId>
        <version>最新版本</version>
    </dependency>

(2)与spring集成
和通用 Mapper 以前版本一样,可以直接使用 tk.mybatis 提供
的 tk.mybatis.spring.mapper.MapperScannerConfigurer 进行配置,这个配置和
MyBatis 官方提供的 org.mybatis.spring.mapper.MapperScannerConfigurer 区别只是
第一层的包名, tk 和 org 。所以使用这种方式时,如果你项目已经使用 org. 进行了
配置,只需要改成 tk. 即可。

<bean class="tk.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="扫描包名"/>
    </bean>

项目中采用的是这种xml的配置方式,通用mapper还提供了注解方式的配置,

3.2.2 实体类映射

实体类映射类似下列形式

@Table(name="tb_brand")
    public class Brand implements Serializable{
    @Id
    private Integer id;
    private String name;
    //getter and setter ....
    }

@Table是指定实体类对应的数据库表 @Id指的是主键映射。经过上面简单的配置后,相
当于就有了 MyBatis 中的关系映射了

3.2.3 创建Mapper接口

 public interface BrandMapper extends Mapper<Brand> {
    }

这里继承了 tk.mybatis.mapper.common.Mapper 接口,在接口上指定了泛型类
型 Brand 。当你继承了 Mapper 接口后,此时就已经有了针对 Brand 的大量方法,方
法如下:
在这里插入图片描述
等等》》》
这些方法中和 MBG 生成的大部分方法都一致,还有一部分 MBG 之外的常用方法。

基础接口select
List select(T record)
根据T对象中的属性名称查询,类似于select * from table where t.name=#{name} and
t.password = #{password}

T selectOne(T record)
根据实体中的属性进行查询,只能有一个返回值,有多个结果是抛出异常,查询条件使用等号
T selectByPrimaryKey(Object key)
根据主键查询 说明:根据主键字段进行查询,方法参数必须包含完整的主键属性,查询条
件使用等号
int selectCount(T record);
说明:根据实体中的属性查询总数,查询条件使用等号基础接口insert
int insert(T record);
说明:保存一个实体,null的属性也会保存,不会使用数据库默认值
int insertSelective(T record);
说明:保存一个实体,null的属性不会保存,会使用数据库默认值

基础接口Update
int updateByPrimaryKey(T record);
说明:根据主键更新实体全部字段,null值会被更新
int updateByPrimaryKeySelective(T record);
说明:根据主键更新属性不为null的值

基础接口delete
int delete(T record);
说明:根据实体属性作为条件进行删除,查询条件使用等号
int deleteByPrimaryKey(Object key);
说明:根据主键字段进行删除,方法参数必须包含完整的主键属性

  1. 青橙-工程搭建
    4.1 准备工作
    先进行环境准备
    (1)配置maven本地仓库
    (2)创建数据库表
    (3)注册中心zookeeper
    4.2 模块依赖关系图
    我们的工程有三种模块:(1)公共模块(解决模块的重复问题,这里主要是服务层与web层的重复问题,以及模块重复带来的复杂性-面向对象的思想) (2)服务层模块 (3)web层模块。
    公共模块主要由公共配置和公共类构成。模块依赖关系入下图:
    在这里插入图片描述

4.3 工程搭建

4.3.1 父工程与公共模块

(1)创建父工程qingcheng_parent pom.xml
父工程没有代码,删掉src文件夹

<?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.qingcheng</groupId>
    <artifactId>qingcheng_parent</artifactId>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>qingcheng_common</module>
        <module>qingcheng_common_service</module>
        <module>qingcheng_common_web</module>
        <module>qingcheng_pojo</module>
        <module>qingcheng_interface</module>
        <module>qingcheng_service_goods</module>
        <module>qingcheng_web_manager</module>
    </modules>
    <packaging>pom</packaging>
    <!-- 集中定义依赖版本号 -->
    <properties>
        <junit.version>4.12</junit.version>
        <spring.version>5.0.5.RELEASE</spring.version>
        <pagehelper.version>4.1.4</pagehelper.version>
        <servlet-api.version>2.5</servlet-api.version>
        <dubbo.version>2.6.0</dubbo.version>
        <zookeeper.version>3.4.7</zookeeper.version>
        <zkclient.version>0.1</zkclient.version>
        <mybatis.version>3.4.5</mybatis.version>
        <mybatis.spring.version>1.3.1</mybatis.spring.version>
        <mybatis.paginator.version>1.2.15</mybatis.paginator.version>
        <mysql.version>5.1.32</mysql.version>
        <druid.version>1.0.9</druid.version>
        <commons-fileupload.version>1.3.1</commons-fileupload.version>
        <spring.security.version>5.0.5.RELEASE</spring.security.version>
        <jackson.version>2.9.4</jackson.version>
    </properties>
    <!-- 依赖管理标签  必须加 -->
    <dependencyManagement>
        <dependencies>
            <!-- Spring -->
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-beans</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-web</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-webmvc</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jdbc</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-aspects</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jms</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context-support</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-test</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <!-- dubbo相关 -->
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>${zookeeper.version}</version>
            </dependency>
            <dependency>
                <groupId>com.github.sgroschupf</groupId>
                <artifactId>zkclient</artifactId>
                <version>${zkclient.version}</version>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>1.2.47</version>
            </dependency>
            <dependency>
                <groupId>javassist</groupId>
                <artifactId>javassist</artifactId>
                <version>3.12.1.GA</version>
            </dependency>
            <dependency>
                <groupId>commons-codec</groupId>
                <artifactId>commons-codec</artifactId>
                <version>1.10</version>
            </dependency>
            <dependency>
                <groupId>com.github.pagehelper</groupId>
                <artifactId>pagehelper</artifactId>
                <version>${pagehelper.version}</version>
            </dependency>
            <!-- Mybatis -->
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis</artifactId>
                <version>${mybatis.version}</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis-spring</artifactId>
                <version>${mybatis.spring.version}</version>
            </dependency>
            <dependency>
                <groupId>com.github.miemiedev</groupId>
                <artifactId>mybatis-paginator</artifactId>
                <version>${mybatis.paginator.version}</version>
            </dependency>
            <!-- MySql -->
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>${mysql.version}</version>
            </dependency>
            <!-- 连接池 -->
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>${druid.version}</version>
            </dependency>
            <!-- 文件上传组件 -->
            <dependency>
                <groupId>commons-fileupload</groupId>
                <artifactId>commons-fileupload</artifactId>
                <version>${commons-fileupload.version}</version>
            </dependency>
            <!-- 安全框架 -->
            <dependency>
                <groupId>org.springframework.security</groupId>
                <artifactId>spring-security-web</artifactId>
                <version>${spring.security.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.security</groupId>
                <artifactId>spring-security-config</artifactId>
                <version>${spring.security.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.security</groupId>
                <artifactId>spring-security-taglibs</artifactId>
                <version>${spring.security.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.security</groupId>
                <artifactId>spring-security-cas</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>com.github.penggle</groupId>
                <artifactId>kaptcha</artifactId>
                <version>2.3.2</version>
                <exclusions>
                    <exclusion>
                        <groupId>javax.servlet</groupId>
                        <artifactId>javax.servlet-api</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>dom4j</groupId>
                <artifactId>dom4j</artifactId>
                <version>1.6.1</version>
            </dependency>
            <dependency>
                <groupId>xml-apis</groupId>
                <artifactId>xml-apis</artifactId>
                <version>1.4.01</version>
            </dependency>
            <!-- 缓存 -->
            <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>2.9.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.data</groupId>
                <artifactId>spring-data-redis</artifactId>
                <version>2.0.5.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-core</artifactId>
                <version>${jackson.version}</version>
            </dependency>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-databind</artifactId>
                <version>${jackson.version}</version>
            </dependency>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-annotations</artifactId>
                <version>${jackson.version}</version>
            </dependency>
            <!--通用Mapper-->
            <dependency>
                <groupId>tk.mybatis</groupId>
                <artifactId>mapper</artifactId>
                <version>4.1.4</version>
            </dependency>
            <dependency>
                <groupId>org.apache.httpcomponents</groupId>
                <artifactId>httpclient</artifactId>
                <version>4.5.7</version>
            </dependency>
            <dependency>
                <groupId>com.aliyun.oss</groupId>
                <artifactId>aliyun-sdk-oss</artifactId>
                <version>2.8.2</version>
            </dependency>
            <dependency>
                <groupId>org.elasticsearch.client</groupId>
                <artifactId>elasticsearch-rest-high-level-client</artifactId>
                <version>6.2.1</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.amqp</groupId>
                <artifactId>spring-rabbit</artifactId>
                <version>2.1.4.RELEASE</version>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>servlet-api</artifactId>
            <version>${servlet-api.version}</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>
    <!--为了使用jdk1.8新特性,引入。-->
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>8</source>
                    <target>8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

上面为父
(2)创建公共模块qingcheng_common,pom.xm
搭建公共模块,从最顶层开始搭建
提供基础参数

resources下创建applicationContext-common.xml

<!--用来加载所有文件名末尾属性为properties的文件-->
	<context:property-placeholder location="classpath*:*.properties" />

resources下创建zk.properties
zk.properties

#配置zk连接地址地址
zk.address=127.0.0.1:2181

resources下创建log4j.properties
配置日志参数

(3)创建qingcheng_common_service ,pom.xml
搭建服务公共模块

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

    <artifactId>qingcheng_common_service</artifactId>
    <!--引入common依赖,传递依赖,-->
    <dependencies>
        <dependency>
            <groupId>com.qingcheng</groupId>
            <artifactId>qingcheng_common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!-- Mybatis -->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
        </dependency>
        <dependency>
            <groupId>com.github.miemiedev</groupId>
            <artifactId>mybatis-paginator</artifactId>
        </dependency>
        <!-- MySql -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!-- 连接池 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
        </dependency>
        <dependency>
            <groupId>commons-fileupload</groupId>
            <artifactId>commons-fileupload</artifactId>
        </dependency>
        <!--通用Mapper-->
        <dependency>
            <groupId>tk.mybatis</groupId>
            <artifactId>mapper</artifactId>
        </dependency>
        <!-- 缓存 -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
        </dependency>

        <dependency>
            <groupId>com.github.pagehelper</groupId>
            <artifactId>pagehelper</artifactId>
            <version>4.1.6</version>
        </dependency>
    </dependencies>

</project>

resources下创建applicationContext-dao.xml,mybatis的

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
	http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
<!--数据源的一些配置-->
	<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
		destroy-method="close">
		<property name="url" value="${jdbc.url}" />
		<property name="username" value="${jdbc.username}" />
		<property name="password" value="${jdbc.password}" />
		<property name="driverClassName" value="${jdbc.driver}" />
		<property name="maxActive" value="10" />
		<property name="minIdle" value="5" />
	</bean>
	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSource" />
		<property name="plugins">
			<!--mybatis的插件,分页-->
			<array>
				<bean class="com.github.pagehelper.PageHelper">
					<property name="properties">
						<value>
							dialect=mysql
						</value>
					</property>
				</bean>
			</array>
		</property>
	</bean>
	<!--包扫描-->
	<bean class="tk.mybatis.spring.mapper.MapperScannerConfigurer">
		<property name="basePackage" value="com.qingcheng.dao" />
	</bean>

	<!-- 事务管理器  -->
	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource" />
	</bean>
	<!--
        开启事务控制的注解支持
        注意:此处必须加入proxy-target-class="true",
              需要进行事务控制,会由Spring框架产生代理对象,Dubbo需要将Service发布为服务,要求必须使用cglib创建代理对象。
    -->
	<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

</beans>

resources下创建applicationContext-dubbo.xml,dubbo的

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:mvc="http://www.springframework.org/schema/mvc"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
	<!--指定暴露服务的端口,如果不指定默认为20880-->
	<dubbo:protocol name="dubbo" port="${dubbo.port}"/>
	<dubbo:application name="${dubbo.application}" />
	<!--zk地址为common而来-->
	<dubbo:registry protocol="zookeeper" address="${zk.address}" />
	<dubbo:annotation package="com.qingcheng.service" />
	<!--<context:annotation-config/>-->

	<dubbo:provider timeout="10000" threadpool="fixed" threads="100" accepts="1000"/>
</beans>

redis的

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:cache="http://www.springframework.org/schema/cache"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/cache http://www.springframework.org/schema/beans/spring-cache.xsd">

   <!-- redis 相关配置 --> 
   <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">  
     <property name="maxIdle" value="${redis.maxIdle}" />   
     <property name="maxWaitMillis" value="${redis.maxWait}" />  
     <property name="testOnBorrow" value="${redis.testOnBorrow}" />  
   </bean>  
  <!--spring data redis的配置,使用中会用到配置文件,已经添加-->
   <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
       p:host-name="${redis.host}" p:port="${redis.port}" p:password="${redis.pass}" p:pool-config-ref="poolConfig"/>  
   
   <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">  
    	<property name="connectionFactory" ref="jedisConnectionFactory" />
   </bean>


</beans>  

(4)创建qingcheng_common_web模块,pom.xml

<?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>qingcheng_parent</artifactId>
        <groupId>com.qingcheng</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
<!--传递依赖-->
    <artifactId>qingcheng_common_web</artifactId>
    <dependencies>
        <dependency>
            <groupId>com.qingcheng</groupId>
            <artifactId>qingcheng_common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.qingcheng</groupId>
            <artifactId>qingcheng_pojo</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!--文件上传相关依赖-->
        <dependency>
            <groupId>commons-fileupload</groupId>
            <artifactId>commons-fileupload</artifactId>
        </dependency>
        <!--spring安全依赖-->
        <dependency>
            <groupId>org.springframework.security</groupId>
            <artifactId>spring-security-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.security</groupId>
            <artifactId>spring-security-config</artifactId>
        </dependency>
<!--阿里提供的存储对象依赖-->
        <dependency>
            <groupId>com.aliyun.oss</groupId>
            <artifactId>aliyun-sdk-oss</artifactId>
        </dependency>

    </dependencies>

</project>

resources下创建applicationContext-json.xml

<mvc:annotation‐driven>
<mvc:message‐converters register‐defaults="true">
<bean
        class="com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter">
    <property name="supportedMediaTypes" value="application/json"/>
    <property name="features">
        <list>
            <value>WriteMapNullValue</value>
            <value>WriteDateUseDateFormat</value>
        </list>
    </property>
</bean>
</mvc:message‐converters>
</mvc:annotation‐driven>

resources下创建applicationContext-dubbo.xml

<!-- 引用dubbo 服务,为工程起名字 -->
	<dubbo:application name="${dubbo.application}" />
	<!--对zk地址配置-->
	<dubbo:registry protocol="zookeeper" address="${zk.address}"/>
	<!--扫描所有控制器的类-->
	<dubbo:annotation package="com.qingcheng.controller" />

下面两个模块也会被其他模块所引用,也可以归类为公共模块
(5)创建实体层模块qingcheng_pojo,pom.xml

<dependency>
<groupId>javax.persistence</groupId>
<artifactId>persistence‐api</artifactId>
<version>1.0</version>
<scope>compile</scope>
</dependency>

(6)创建服务接口层模块 qingcheng_interface ,pom.xml

<!--jpa注解-->
<dependency>
<groupId>com.qingcheng</groupId>
<artifactId>qingcheng_pojo</artifactId>
<version>1.0‐SNAPSHOT</version>
</dependency>

4.3.2 服务层模块(商品)

在这里插入图片描述
其中一个为例子,其他一样
商品服务
(1)创建qingcheng_service_goods模块,pom.xml

<dependencies>
    <dependency>
        <groupId>com.qingcheng</groupId>
        <artifactId>qingcheng_interface</artifactId>
        <version>1.0‐SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>com.qingcheng</groupId>
        <artifactId>qingcheng_common_service</artifactId>
        <version>1.0‐SNAPSHOT</version>
    </dependency>
</dependencies>
<!--指定各个服务的端口,创建各自的服务器。从9001开始-->
<build>
    <plugins>
        <plugin>
            <groupId>org.apache.tomcat.maven</groupId>
            <artifactId>tomcat7‐maven‐plugin</artifactId>
            <configuration>
                <!‐‐ 指定端口 ‐‐>
                <port>9001</port>
                <!‐‐ 请求路径 ‐‐>
                <path>/</path>
            </configuration>
        </plugin>
    </plugins>
</build>

(2)创建webapp/WEB-INF/web.xml

<!DOCTYPE web‐app PUBLIC
"‐//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
"http://java.sun.com/dtd/web‐app_2_3.dtd" >
<web‐app>
<display‐name>Archetype Created Web Application</display‐name>
<!‐‐ 加载spring容器 ‐‐>
<context‐param>
<param‐name>contextConfigLocation</param‐name>
<param‐value>classpath*:applicationContext*.xml</param‐value>
</context‐param>
<listener>
<listener‐
class>org.springframework.web.context.ContextLoaderListener</listener‐
class>
</listener>
</web‐app>

(3)resources下创建dubbo.properties
配置功能区的端口与名字

dubbo.port=20881
dubbo.application=goods

(4)resources下创建db.properties
配置数据库连接信息

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/qingcheng_goods?
characterEncoding=utf‐8
jdbc.username=root
jdbc.password=123456

4.3.3 web层(管理后台)

(1)创建qingcheng_web_manager模块,pom.xml

<dependencies>
    <dependency>
        <groupId>com.qingcheng</groupId>
        <artifactId>qingcheng_interface</artifactId>
        <version>1.0‐SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>com.qingcheng</groupId>
        <artifactId>qingcheng_common_web</artifactId>
        <version>1.0‐SNAPSHOT</version>
    </dependency>
</dependencies>
<build>
    <plugins>
        <plugin>
            <groupId>org.apache.tomcat.maven</groupId>
            <artifactId>tomcat7‐maven‐plugin</artifactId>
            <configuration>
                <!‐‐ 指定端口 ‐‐>
                <port>9101</port>
                <!‐‐ 请求路径 ‐‐>
                <path>/</path>
            </configuration>
        </plugin>
    </plugins>
</build>

(2)创建webapp/WEB-INF/web.xml

<!DOCTYPE web-app PUBLIC
 "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
 "http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>
  <display-name>Archetype Created Web Application</display-name>
  <!-- 解决post乱码 -->
  <filter>
    <filter-name>CharacterEncodingFilter</filter-name>
    <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
    <init-param>
      <param-name>encoding</param-name>
      <param-value>utf-8</param-value>
    </init-param>
    <init-param>
      <param-name>forceEncoding</param-name>
      <param-value>true</param-value>
    </init-param>
  </filter>
  <filter-mapping>
    <filter-name>CharacterEncodingFilter</filter-name>
    <url-pattern>/*</url-pattern>
  </filter-mapping>
  <!--安全框架的过滤器,暂时不用-->
<!--
  <filter>
    <filter-name>springSecurityFilterChain</filter-name>
    <filter-class>org.springframework.web.filter.DelegatingFilterProxy</filter-class>
  </filter>
  <filter-mapping>
    <filter-name>springSecurityFilterChain</filter-name>
    <url-pattern>/*</url-pattern>
  </filter-mapping>
-->
  <servlet>
    <servlet-name>springmvc</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <!-- 指定加载的配置文件 ,通过参数contextConfigLocation加载,除了本身的,它所依赖的也能找到 -->
    <init-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>classpath*:applicationContext*.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>springmvc</servlet-name>
    <url-pattern>*.do</url-pattern>
  </servlet-mapping>
</web-app>

(3)resources下创建dubbo.properties

dubbo.application=manager

5. 青橙管理后台-品牌管理后端

5.1 需求分析

实现对品牌的基本操作(增删改查),只完成后端代码部分,并通过浏览器等工具完成
测试。

5.2 表结构分析

tb_brand 品牌表
就是品牌类别,图片地址时品牌的logo
在这里插入图片描述

5.3 代码实现

5.3.1 品牌列表

url
/brand/findAll.do
http请求方式
GET
返回格式

[{
"id": 品牌id,
"name": 品牌名称,
"image": 品牌图片地址,
"letter": 品牌的首字母,
"seq": 排序,
},
.......
]

代码实现:
(1)在qingcheng_pojo工程创建com.qingcheng.pojo包,包下创建实体类

@Table(name="tb_brand")
public class Brand implements Serializable{
    @Id
    private Integer id;//品牌id
    private String name;//品牌名称
    private String image;//品牌图片地址
    private String letter;//品牌的首字母
    private Integer seq;//排序
// getter and setter ......
}

(2)qingcheng_service_goods工程创建com.qingcheng.dao,包下创建数据访问层接

/*数据访问层,dao*/
public interface BrandMapper extends Mapper<Brand> {
}

(3)qingcheng_interface工程创建com.qingcheng.service.goods包,包下创建业务接

/**
 * 品牌业务逻辑层
 */
public interface BrandService {
    public List<Brand> findAll();
}

(4)qingcheng_service_goods工程创建com.qingcheng.service.impl包,包下创建类

@Service
public class BrandServiceImpl implements BrandService {
    @Autowired
    private BrandMapper brandMapper;
    public List<Brand> findAll() {
        return brandMapper.selectAll();
    }
}

(5)qingcheng_web_manager工程创建com.qingcheng.controller.goods 包,包下创
建类

@RestController
@RequestMapping("/brand")
public class BrandController {
    @Reference
    /*注入远程的业务接口*/
    private BrandService brandService;
    @GetMapping("/findAll")
    public List<Brand> findAll(){
        return brandService.findAll();
    }
}

测试

开启,可以在虚拟机中,也可以本机,zk
在这里插入图片描述
安装inferface,pojo
如果变化也要重新安装

开启service的tomcat7 run,开启,开启manager的tomcat7
在这里插入图片描述

浏览器输入:http://localhost:9101/brand/findAll.do
数据库返回数据,调用成功
在这里插入图片描述

5.3.2 品牌分页列表

接口定义:
url
/brand/findPage.do
http请求方式
GET
请求参数
在这里插入图片描述
例子:
GET /brand/findPage.do?page=1&size=10
返回格式

{rows:[{
        "id": 品牌id,
        "name": 品牌名称,
        "image": 品牌图片地址,
        "letter": 品牌的首字母,
        "seq": 排序,
        },
        .......
        ],
        total:100}

pojo是和数据库对应的类,entity是自己封装的类,实现自定义数据模块
创建类pojo,创建功能接口interface,创建实现manager,分步实现
代码实现:
(1)qingcheng_pojo创建com.qingcheng.entity包,包下创建类
用来承载分页查询的对象

/**
 * 分页结果
 * @param <T>
 */
public class PageResult<T> implements Serializable {
    private Long total;//记录数
    private List<T> rows;//结果集
    public PageResult(Long total, List<T> rows) {
        this.total = total;
        this.rows = rows;
    }
    public PageResult() {
    }
    public Long getTotal() {
        return total;
    }
    public List<T> getRows() {
        return rows;
    }
    public void setRows(List<T> rows) {
        this.rows = rows;
    }
    public void setTotal(Long total) {
        this.total = total;
    }
}

(2)qingcheng_interface工程BrandService接口新增方法

public PageResult<Brand> findPage(int page, int size);

(3)qingcheng_service_goods工程BrandServiceImpl新增方法

/**
 * 分页查询
 * @param page 页码
 * @param size 每页记录数
 * @return 分页结果
 */
public PageResult<Brand> findPage(int page, int size) {
        PageHelper.startPage(page,size);
        Page<Brand> brands = (Page<Brand>) brandMapper.selectAll();
        return new PageResult<Brand>
(brands.getTotal(),brands.getResult());
        }

(4)qingcheng_web_manager工程BrandController新增方法

@GetMapping("/findPage")
public PageResult<Brand> findPage(int page, int size){
        return brandService.findPage(page, size);
        }

因为更新了interface与pojo,所以需要重新安装
启动工程,浏览器测试:http://localhost:9101/brand/findPage.do?page=1&size=10
在这里插入图片描述

5.3.3 品牌条件查询

url
/brand/findList.do
http请求方式
POST
请求参数
在这里插入图片描述
例子:

POST /brand/findList.do
        {
        "name": 品牌名称,
        "letter": 品牌的首字母
        }

返回格式

[{
        "id": 品牌id,
        "name": 品牌名称,
        "image": 品牌图片地址,
        "letter": 品牌的首字母,
        "seq": 排序,
        },
        .......
        ]

代码实现:
(1)qingcheng_interface工程BrandService接口新增方法

public List<Brand> findList(Map<String, Object> searchMap);

(2)qingcheng_service_goods工程BrandServiceImpl新增方法

/**
 * 条件查询
 * @param searchMap 查询条件
 * @return
 */
public List<Brand> findList(Map<String, Object> searchMap) {
        Example example = createExample(searchMap);
        return brandMapper.selectByExample(example);
        }
/**
 * 构建查询条件
 * @param searchMap
 * @return
 */
private Example createExample(Map<String, Object> searchMap){
        Example example=new Example(Brand.class);
        Example.Criteria criteria = example.createCriteria();
        if(searchMap!=null){
//名称条件
        if(searchMap.get("name")!=null &&
        !"".equals(searchMap.get("name"))){
        criteria.andLike("name","%"+
        (String)searchMap.get("name")+"%");
        }
//首字母
        if(searchMap.get("letter")!=null &&
        !"".equals(searchMap.get("letter"))){
        criteria.andEqualTo("letter",
        (String)searchMap.get("letter"));
        }
        }
        return example;
        }

(3)qingcheng_web_manager工程BrandController新增方法

 @PostMapping("/findList")
    /*加入注解,分解请求得到的json数据*/
    /*之前都是get请求的,输入条件参数,现在post请求*/
    public List<Brand> findList( @RequestBody Map searchMap){
        return brandService.findList(searchMap);
    }

/之前都是get请求的,输入条件参数,现在post请求/
使用postman
在这里插入图片描述
以json方式请求,
在这里插入图片描述
多个条件加逗号即可

5.3.4 品牌条件+分页查询

写一个功能函数囊括以上两个功能即可
url
/brand/findPage.do
http请求方式
POST
请求参数

在这里插入图片描述
例子:

POST /brand/findPage.do?page=1&size=10
        {
        "name": 品牌名称,
        "letter": 品牌的首字母
        }

返回格式:

{rows:[{
        "id": 品牌id,
        "name": 品牌名称,
        "image": 品牌图片地址,
        "letter": 品牌的首字母,
        "seq": 排序
        },
        .......
        ],
        total:100}

代码实现:
(1)qingcheng_interface工程BrandService接口新增方法

public PageResult<Brand> findPage(Map<String,Object> searchMap,int page,
        int size);

(2)qingcheng_service_goods工程BrandServiceImpl新增方法

/**
 * 分页+条件查询
 * @param searchMap
 * @param page
 * @param size
 * @return
 */
public PageResult<Brand> findPage(Map<String, Object> searchMap, int
        page, int size) {
        PageHelper.startPage(page,size);
        Example example = createExample(searchMap);
        Page<Brand> brands = (Page<Brand>)
        brandMapper.selectByExample(example);
        return new PageResult<Brand>
(brands.getTotal(),brands.getResult());
        }

(3)qingcheng_web_manager工程BrandController新增方法

@PostMapping("/findPage")
public PageResult<Brand> findPage(@RequestBody Map<String,Object>
searchMap,int page, int size){
        return brandService.findPage(searchMap,page,size);
        }

使用了多态,将findPage执行了分页与条件的多次编写
在这里插入图片描述

5.3.5 根据ID查询品牌

url
/brand/findById.do
http请求方式
GET
请求参数
在这里插入图片描述

代码实现:
(1)qingcheng_interface工程BrandService接口新增方法

public Brand findById(Integer id);

(2)qingcheng_service_goods工程BrandServiceImpl新增方法
接口,实现,网址映射

/**
 * 根据Id查询
 * @param id
 * @return
 */
public Brand findById(Integer id) {
        return brandMapper.selectByPrimaryKey(id);
        }

(3)qingcheng_web_manager工程BrandController新增方法

@GetMapping("/findById")
public Brand findById(Integer id){
        return brandService.findById(id);
        }

在这里插入图片描述

5.3.6 品牌新增

(1)qingcheng_pojo 新增类

/**
 * 返回前端的消息封装,正确错误都有信息了
 */
public class Result implements Serializable {
    private Integer code;//返回的业务码 0:成功执行 1:发生错误
    private String message;//信息
    public Result(Integer code, String message) {
        this.code = code;
        this.message = message;
    }
    public Result() {
        this.code=0;
        this.message = "执行成功";
    }
    public Integer getCode() {
        return code;
    }
    public void setCode(Integer code) {
        this.code = code;
    }
    public String getMessage() {
        return message;
    }
    public void setMessage(String message) {
        this.message = message;
    }
}

(2)qingcheng_interface工程BrandService接口新增方法

public void add(Brand brand);

(3)qingcheng_service_goods工程BrandServiceImpl新增方法

/**
 * 新增
 * @param brand
 */
public void add(Brand brand) {
        brandMapper.insert(brand);
        }

(4)qingcheng_web_manager工程BrandController新增方法

@PostMapping("/add")
public Result add(@RequestBody Brand brand){
        brandService.add(brand);
        return new Result();
        }

在这里插入图片描述

5.3.7 品牌修改

对于修改的方法,
第一个根据条件更新,第二个是如果有null值会被忽略,如果包含null值会被覆盖还是忽略,第四个为忽略,更加实用,不覆盖该数据库原来的数据
在这里插入图片描述

(1)qingcheng_interface工程BrandService接口新增方法

public void update(Brand brand);

(2)qingcheng_service_goods工程BrandServiceImpl新增方法

/**
 * 修改
 * @param brand
 */
public void update(Brand brand) {
        brandMapper.updateByPrimaryKeySelective(brand);
        }

(3)qingcheng_web_manager工程BrandController新增方法

@PostMapping("/update")
public Result update(@RequestBody Brand brand){
        brandService.update(brand);
        return new Result();
        }

5.3.8 品牌删除

url
/brand/delete.do
http请求方式
GET
请求参数
在这里插入图片描述

例子:

GET /brand/delete.do?id=1

返回格式:

{
        code:0,
        message:""
        }

code为0表示成功,为1表示失败
代码实现:
(1)qingcheng_interface工程BrandService接口新增方法

public void delete(Integer id);

(2)qingcheng_service_goods工程BrandServiceImpl新增方法

/**
 * 删除
 * @param id
 */
public void delete(Integer id) {
        brandMapper.deleteByPrimaryKey(id);
        }

(3)qingcheng_web_manager工程BrandController新增方法

@GetMapping("/delete")
public Result delete(Integer id){
        brandService.delete(id);
        return new Result();
        }

以上主要是为了尝试,通用mapper的方法

6. 公共异常处理

应该将项目所有的异常,进行统一管理
qingcheng_common_web工程创建com.qingcheng.controller包,包下创建类

/**
 * 统一异常处理类
 */
@ControllerAdvice
public class BaseExceptionHandler {
    @ExceptionHandler(Exception.class)
    @ResponseBody
    public Result error(Exception e) {
        e.printStackTrace();
        System.out.println("调用了公共异常处理类");
        return new Result(1,e.getMessage());
    }
}

注意回顾系统架构图,所有的都是围绕其展开

;原文链接:https://blog.csdn.net/lidashent/article/details/115659185
本站部分内容转载于网络,版权归原作者所有,转载之目的在于传播更多优秀技术内容,如有侵权请联系QQ/微信:153890879删除,谢谢!

推荐图文


随机推荐