springboot 整合sentinel的示例代码

2024-04-02 19:55

短信预约 -IT技能 免费直播动态提醒

1. 安装sentinel

下载地址：https://github.com/alibaba/Sentinel/releases/tag/1.7.0 ，由于我无法下载，所以使用docker安装，

yuchunfang@yuchunfangdeMacBook-Pro ~ % docker pull bladex/sentinel-dashboard:1.7.0 
yuchunfang@yuchunfangdeMacBook-Pro ~ % docker run --name sentinel -d -p 8858:8858 bladex/sentinel-dashboard:1.7.0

登录地址，默认端口是8080，由于我的已被占用，所以使用8858，http://localhost:8858

账号密码：sentinel/sentinel,能够打开访问页面，说明安装成功。

2.客户端连接

1. 准备springboot项目，在pom中引入sentinel

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            <version>2.2.5.RELEASE</version>
        </dependency>

2.配置文件配置服务器地址信息

spring.cloud.sentinel.transport.dashboard=localhost:8858
spring.cloud.sentinel.transport.heartbeat-interval-ms=500
spring.cloud.sentinel.eager=true

3.自定义异常提示信息

package org.example.config;
 
import com.alibaba.csp.sentinel.adapter.spring.webmvc.callback.BlockExceptionHandler;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.flow.FlowException;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
 
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
@Component
public class SentinelExceptionHandler implements BlockExceptionHandler {
 
 
    @Override
    public void handle(HttpServletRequest httpServletRequest, HttpServletResponse response, BlockException e) throws Exception {
        response.setStatus(HttpStatus.TOO_MANY_REQUESTS.value());
        response.setContentType("application/json;charset=utf-8");
        response.getWriter().print("sentinel 限流。。。");
    }
}

BlockException包含很多个子类，分别对应不同的场景：