专栏首页编程坑太多『互联网架构』软件架构-Spring boot集成三方中间件(88)

『互联网架构』软件架构-Spring boot集成三方中间件(88)

继续说集成三方中间件的,主要说说统异常处理,集成Mybatis,集成redis,集成RabbitMQ。

(一)统一异常处理

创建全局异常处理类:通过使用@ControllerAdvice定义统一的异常处理类,@ExceptionHandler用来定义针对的异常类型。

1.创建统一异常Controller

@ControllerAdviceclass GlobalExceptionHandler {    @ExceptionHandler(value = Exception.class)    public ModelAndView defaultErrorHandler(HttpServletRequest req, Exception e)        throws Exception {        ModelAndView mav = new ModelAndView();        mav.addObject("msg", "异常咯...");        mav.setViewName("error");        return mav;    }}

2.增加Controller方法,抛出异常

    @RequestMapping("/exception")    public String hello() throws Exception {        throw new Exception("发生错误");    }

3.src/main/resources/templates增加error.html

<!DOCTYPE html><html xmlns:th="http://www.w3.org/1999/xhtml"><head lang="en">    <meta charset="UTF-8" />    <title>统一异常处理</title></head><body><h1>Error</h1><div th:text="${msg}"></div></body></html>

`

(二)集成Mybatis

1.修改pom.xml,增加依赖

<dependency>      <groupId>org.mybatis.spring.boot</groupId>      <artifactId>mybatis-spring-boot-starter</artifactId>      <version>1.1.1</version><!-- 版本号必须需要 -->    </dependency>    <dependency>      <groupId>mysql</groupId>      <artifactId>mysql-connector-java</artifactId>    </dependency>

2.mysql的连接配置 application.properties:

spring.datasource.url=jdbc:mysql://localhost:3306/springspring.datasource.username=rootspring.datasource.password=rootspring.datasource.driver-class-name=com.mysql.jdbc.Driver

3.创建表t_user

CREATE TABLE `t_user` (  `id` int(11) NOT NULL AUTO_INCREMENT,  `name` varchar(40) DEFAULT NULL,  `age` int(11) DEFAULT NULL,  `address` varchar(100) DEFAULT NULL,  `phone` varchar(40) DEFAULT NULL,  PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

4.创建User.java文件 包名为:com.idig8.springboot.bean

package com.idig8.springboot.bean;
/** * @program: springboot3d * @description: ${description} * @author: LiMing * @create: 2019-06-10 11:07 **/public class User {    private Integer id;    private String name;    private Integer age;    private String address;    private String phone;
    public Integer getId() {        return id;    }
    public void setId(Integer id) {        this.id = id;    }
    public String getName() {        return name;    }
    public void setName(String name) {        this.name = name;    }
    public Integer getAge() {        return age;    }
    public void setAge(Integer age) {        this.age = age;    }
    public String getAddress() {        return address;    }
    public void setAddress(String address) {        this.address = address;    }
    public String getPhone() {        return phone;    }
    public void setPhone(String phone) {        this.phone = phone;    }}

5.创建UserMapper.java接口文件 包名为:com.idig8.springboot.mybatis

package com.idig8.springboot.mybatis;
import com.idig8.springboot.bean.User;import org.apache.ibatis.annotations.Insert;import org.apache.ibatis.annotations.Mapper;import org.apache.ibatis.annotations.Param;import org.apache.ibatis.annotations.Select;
/** * @program: springboot3d * @description: ${description} * @author: LiMing * @create: 2019-06-10 11:09 **/@Mapperpublic interface UserMapper {    /**根据id查询用户*/    @Select("SELECT * FROM T_USER WHERE ID = #{id}")    User findById(@Param("id") String id);    /**新增用户*/    @Insert("INSERT INTO T_USER(NAME, AGE, ADDRESS, PHONE) VALUES(#{name}, #{age}, #{address}, #{phone})")    int insert(@Param("name") String name, @Param("age") Integer age,@Param("address") String address,@Param("phone") String phone);}

6.测试

@RunWith(SpringJUnit4ClassRunner.class)@SpringBootTest(classes = Example.class)public class MybatisTest {    @Autowired    private UserMapper userMapper;    @Test    public void testInsert() throws Exception {        int num = userMapper.insert("zhangsan222", 20,"长沙","13100000000");        TestCase.assertEquals(num,1);    }    @Test    public void testFindById() throws Exception {        User u = userMapper.findById("6");        TestCase.assertNotNull(u);        System.out.println(u.getName());    }

(三)集成Mybatis

1.修改pom.xml,增加依赖

<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-data-redis</artifactId></dependency>

注意:旧版本spring boot中集成的redis starter为:spring-boot-starter-redis 2.redis连接配置 注意:spring.redis.database的配置通常使用0即可,Redis在配置的时候可以设置数据库数量,默认为16,可以理解为数据库的schema。

# REDIS (RedisProperties)# Redis数据库索引(默认为0)spring.redis.database=0# Redis服务器地址spring.redis.host=127.0.0.1# Redis服务器连接端口spring.redis.port=6379# Redis服务器连接密码(默认为空)spring.redis.password=# 连接池最大连接数(使用负值表示没有限制)spring.redis.pool.max-active=8# 连接池最大阻塞等待时间(使用负值表示没有限制)spring.redis.pool.max-wait=-1# 连接池中的最大空闲连接spring.redis.pool.max-idle=8# 连接池中的最小空闲连接spring.redis.pool.min-idle=0# 连接超时时间(毫秒)spring.redis.timeout=0

3.测试redis 注意:redis中存储对象,需要我们自己实现RedisSerializer接口来对传入对象进行序列化和反序列化

@RunWith(SpringJUnit4ClassRunner.class)@SpringBootTest(classes = SpringBootMain.class)public class SpringRedisTest {@Autowiredprivate RedisTemplate<String,String> redisTemplate;@Testpublic void testRedis() throws Exception {ValueOperations<String, String> ops = redisTemplate.opsForValue();ops.set("name", "zhangsan");String value = ops.get("name");System.out.println(value);TestCase.assertEquals("zhangsan", value);    }}

(四)集成RabbitMQ

RabbitMQ是以AMQP协议实现的一种消息中间件产品, AMQP是Advanced Message Queuing Protocol的简称,它是一个面向消息中间件的开放式标准应用层协议。 AMQP中定义了以下标准特性:1.消息方向 2.消息队列 3.消息路由(包括:点到点模式和发布-订阅模式) 4.可靠性 5.安全性 关于AMQP 、RabbitMQ的详细内容不再这里过多介绍,本次课主要讲怎么与Spring boot集成。

  • 安装RabbitMQ

官网:https://www.rabbitmq.com/download.html windows安装不在说了,都是傻瓜试的。linux可能比较麻烦自行百度吧。

打开浏览器并访问:http://localhost:15672/,并使用默认用户guest登录,密码也为guest,即可进入管理界面 新增管理用户并设置权限 username:springboot password:123456

切换到springboot用户登陆,在All users中,点击Name为springboot, 进入权限设置页面

在权限设置页面,进入Permissions页面,点击“Set permission"

  • Spring Boot整合修改pom.xml,增加依赖支持
<dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-amqp</artifactId>    </dependency>
  • rabbit mq连接配置
spring.rabbitmq.host=localhostspring.rabbitmq.port=5672spring.rabbitmq.username=springbootspring.rabbitmq.password=123456
  • 创建Rabbit配置类

配置类主要用来配置队列、交换器、路由等高级信息

import org.springframework.amqp.core.Queue;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configurationpublic class RabbitConfig {    @Bean    public Queue firstQueue() {      // 创建一个队列,名称为:first        return new Queue("first");    }}
  • 创建消息产生者类

说明:通过注入AmqpTemplate接口的实例来实现消息的发送,AmqpTemplate接口定义了一套针对AMQP协议的基础操作。

@Componentpublic class Sender {    @Autowired    private AmqpTemplate rabbitTemplate;    public void send() {        rabbitTemplate.convertAndSend("first", "test rabbitmq message !!!");    }}
  • 创建消息消费者

说明:@RabbitListener注解:定义该类需要监听的队列 @RabbitHandler注解:指定对消息的处理

@Component@RabbitListener(queues = "first")public class Receiver {    @RabbitHandler    public void process(String msg) {        System.out.println("receive msg : " + msg);    }}
  • 创建测试类
@RunWith(SpringJUnit4ClassRunner.class)@SpringBootTest(classes = SpringBootMain.class)public class RabbitmqTest {    @Autowired    private Sender sender;    @Test    public void testRabbitmq() throws Exception {        sender.send();    }}
  • 启动主程序:SpringBootMain

控制台如果出现以下信息,则说明rabbitmq连接成功 Created new connection: rabbitConnectionFactory#29102d45:0/SimpleConnection@1dcfb5ba [delegate=amqp://springboot@127.0.0.1:5672/, localPort= 55088]

  • 运行Junit测试类
控制台输出:receive msg : test rabbitmq message !!!
集成Rabbit MQ完毕!

PS:mq和redis之前在别的专题都说过多次了,这里就不详细的截图了。下次咱们一起说说 日志方面。

本文分享自微信公众号 - 编程坑太多(idig88),作者:诸葛阿明

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-06-22

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 『互联网架构』软件架构-解密电商系统-Spring boot快速开始及核心功能介绍(下)(86)

    至于哪个具体的配置文件会被加载,需要在application.properties文件中通过spring.profiles.active属性来设置,其值对应{p...

    IT故事会
  • springboot (12) druid

    IT故事会
  • Lambda表达式概述

    IT故事会
  • Spring --- 你真的明白Spring上下文之间的关系吗?

    WebApplicationContext 是MVC Context的父上下文,是否可以互相注入对方的bean? WebApplicationContext中...

    十毛
  • 领域驱动设计-划分界限上下文

    用户1910585
  • 上下文系列小讲堂(一)

    “度量值”和“计算列”的区别,令很多初学新人纠结不已。毕竟大部份人是从EXCEL里绕过来的,遇到问题,习惯拉起公式添加列,操作近乎条件反射,毕竟添加的计算列实实...

    公众号PowerBI大师
  • 如何一步一步用DDD设计一个电商网站(六)—— 给购物车加点料,集成售价上下文

      前几篇已经实现了一个最简单的购买过程,这次开始往这个过程中增加一些东西。比如促销、会员价等,在我们的第一篇文章(如何一步一步用DDD设计一个电商网站(一)—...

    Zachary_ZF
  • Power Pivot概念(5)—理解上下文

    行上下文也会涉及到关系。例如在多端引用1端数据是使用Related,则会默认当前行关联的数据。

    逍遥之
  • ACL 2018 | 神经语言模型如何利用上下文信息:长距离上下文的词序并不重要

    机器之心
  • 实战使用Axure设计App,使用WebStorm开发(4) – 实现页面UI

    系列文章 实战使用Axure设计App,使用WebStorm开发(1) – 用Axure描述需求 实战使用Axure设计App,使用WebStorm开发(2)...

    葡萄城控件

扫码关注云+社区

领取腾讯云代金券