springboot中优雅实现异常拦截和返回统一结构数据

做前后端分离的项目，为了方便前端处理数据，都会将返回的数据封装到统一的结构下，这样前端拿到数据可以根据指定的字段做不同的业务逻辑处理。

1、异常信息统一拦截

项目开发中，难免会发生异常，如果不做拦截，当项目发生异常时会把异常的堆栈信息返回给前端，这样不仅对前端没有意义，而且会把服务器的相关信息暴露给外部用户造成信息的泄露，在springboot中，可以通过 @RestControllerAdvice 注解实现对异常信息的拦截处理，拦截到异常后给前端返回友好的提示，实现逻辑如下：

  1. 定义一个异常信息拦截类，接口调用中抛出的异常都会被拦截到，拦截到的异常会进入不同的处理方法，将处理后的数据返回给请求端：
import org.example.pojo.ApiResult;
import org.example.pojo.StatusCode;
import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
import org.springframework.http.HttpStatus;
import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;
import org.springframework.validation.BindException;
import org.springframework.validation.FieldError;
import org.springframework.web.HttpRequestMethodNotSupportedException;
import org.springframework.web.bind.MethodArgumentNotValidException;
import org.springframework.web.bind.MissingServletRequestParameterException;
import org.springframework.web.bind.UnsatisfiedServletRequestParameterException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import org.springframework.web.method.annotation.MethodArgumentTypeMismatchException;
import org.springframework.web.multipart.support.MissingServletRequestPartException;
import org.springframework.web.servlet.NoHandlerFoundException;import java.util.List;
import java.util.StringJoiner;/*** 统一异常处理** @Author xingo* @Date 2023/12/7*/
@RestControllerAdvice
@ConditionalOnWebApplication
public class RestControllerExceptionHandler {/*** 自定义异常处理*/@ExceptionHandler(BusinessException.class)public ApiResult businessExceptionHandler(BusinessException e) {return ApiResult.fail(e.getCode(), e.getMessage());}/*** 参数错误异常处理*/@ResponseStatus(HttpStatus.BAD_REQUEST)@ExceptionHandler(IllegalArgumentException.class)public ApiResult illegalArgumentExceptionHandler(IllegalArgumentException e) {e.printStackTrace();return ApiResult.fail(StatusCode.C_10004);}/*** 参数校验异常处理*/@ExceptionHandler(BindException.class)public ApiResult bindExceptionHandler(BindException e) {List<FieldError> errors = e.getBindingResult().getFieldErrors();if(errors != null && !errors.isEmpty()) {return ApiResult.fail(StatusCode.C_10004).setMessage(errors.get(0).getDefaultMessage());}return ApiResult.fail(StatusCode.C_10004);}/*** 参数校验异常处理*/@ExceptionHandler(MethodArgumentNotValidException.class)public ApiResult methodArgumentNotValidExceptionHandler(MethodArgumentNotValidException e) {List<FieldError> errors = e.getBindingResult().getFieldErrors();StringBuilder builder = new StringBuilder();if(null != errors) {for(FieldError error : errors) {builder.append(",").append(error.getField()).append(":").append(error.getDefaultMessage());}return ApiResult.fail(HttpStatus.BAD_REQUEST.value(), "参数校验失败-[" + builder.substring(1) + "]");}return ApiResult.fail(StatusCode.C_10004);}/*** 不支持的请求方法*/@ExceptionHandler(HttpRequestMethodNotSupportedException.class)public ApiResult<Object> httpRequestMethodNotSupportedExceptionHandler(HttpRequestMethodNotSupportedException e) {e.printStackTrace();return ApiResult.fail(HttpStatus.METHOD_NOT_ALLOWED.value(), "不支持的请求方法");}/*** 请求参数缺失*/@ExceptionHandler(MissingServletRequestParameterException.class)public ApiResult<Object> missingServletRequestParameterExceptionHandler(MissingServletRequestParameterException e) {e.printStackTrace();return ApiResult.fail(HttpStatus.BAD_REQUEST.value(), "请求参数" + e.getParameterName() + "缺失，数据类型：" + e.getParameterType());}/*** 请求参数类型错误*/@ExceptionHandler(MethodArgumentTypeMismatchException.class)public ApiResult<Object> methodArgumentTypeMismatchExceptionHandler(MethodArgumentTypeMismatchException e) {e.printStackTrace();return ApiResult.fail(HttpStatus.BAD_REQUEST.value(), "请求参数类型错误");}/*** 请求地址不存在*/@ExceptionHandler(NoHandlerFoundException.class)public ApiResult<Object> handleNoFoundException(NoHandlerFoundException e) {e.printStackTrace();return ApiResult.fail(HttpStatus.NOT_FOUND.value(), "请求地址不存在");}/*** 必须的请求参数不能为空*/@ExceptionHandler(MissingServletRequestPartException.class)public ApiResult<Object> missingServletRequestPartExceptionHandler(MissingServletRequestPartException e) {e.printStackTrace();return ApiResult.fail(HttpStatus.BAD_REQUEST.value(), "必须的请求参数" + e.getRequestPartName() + "不能为空");}/*** 400 - Bad Request*/@ResponseStatus(HttpStatus.BAD_REQUEST)@ExceptionHandler(UnsatisfiedServletRequestParameterException.class)public ApiResult<Object> unsatisfiedServletRequestParameterExceptionHandler(UnsatisfiedServletRequestParameterException e) {String conditions = StringUtils.arrayToDelimitedString(e.getParamConditions(), ",");StringJoiner params = new StringJoiner(",");e.getActualParams().forEach((k, v) -> params.add(k.concat("=").concat(ObjectUtils.nullSafeToString(v))));e.printStackTrace();return ApiResult.fail(HttpStatus.BAD_REQUEST.value(), "请求参数异常：" + conditions + "|" + params);}/*** 未捕获的异常* @param e* @return*/@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)@ExceptionHandler(Exception.class)public ApiResult exceptionHandler(Exception e) {e.printStackTrace();return ApiResult.fail(StatusCode.C_ERROR);}
}
  1. 自定义了一个异常类，当业务逻辑处理时不符合要求可以抛出下面的异常：
import org.example.pojo.StatusCode;/*** 自定义业务异常** @Author xingo* @Date 2023/12/7*/
public class BusinessException extends RuntimeException {private int code;public BusinessException(int code, String message) {super(message);this.code = code;}public static BusinessException fail(int code, String message) {return new BusinessException(code, message);}public static BusinessException fail(StatusCode statusCode) {return new BusinessException(statusCode.getCode(), statusCode.getMessage());}public int getCode() {return code;}
}
  1. 接口统一返回的数据实体类，它的定义如下：
import java.io.Serializable;/*** @Author xingo* @Date 2023/10/27*/
public class ApiResult<T> implements Serializable {/*** 响应状态码：200-成功；其他-失败*/private int code;/*** 响应数据*/private T data;/*** 响应结果描述*/private String message = "";/*** 响应耗时：毫秒*/private long time;public ApiResult() {}public ApiResult(T data) {this.data = data;}public ApiResult(int code, T data, String message) {this.code = code;this.data = data;this.message = message;}public int getCode() {return code;}public ApiResult setCode(int code) {this.code = code;return this;}public String getMessage() {return message;}public ApiResult setMessage(String message) {this.message = message;return this;}public T getData() {return data;}public ApiResult setData(T data) {this.data = data;return this;}public long getTime() {return this.time;}public ApiResult setTime(long time) {this.time = time;return this;}/*** 成功** @return*/public static ApiResult success() {ApiResult result = new ApiResult(StatusCode.C_200.getCode(), null, StatusCode.C_200.getMessage());return result;}/*** 成功** @param data* @param <T>* @return*/public static <T> ApiResult success(T data) {ApiResult result = new ApiResult(StatusCode.C_200.getCode(), data, StatusCode.C_200.getMessage());return result;}/*** 失败** @param statusCode* @return*/public static ApiResult fail(StatusCode statusCode) {return new ApiResult().setCode(statusCode.getCode()).setMessage(statusCode.getMessage());}/*** 失败** @param code* @param message* @return*/public static ApiResult fail(int code, String message) {return new ApiResult().setCode(code).setMessage(message);}/*** 异常** @return*/public static ApiResult error() {return new ApiResult().setCode(StatusCode.C_ERROR.getCode()).setMessage(StatusCode.C_ERROR.getMessage());}/*** 判断响应是否为成功响应** @return*/public boolean isSuccess() {if (this.code != 200) {return false;}return true;}public static ApiResult copyCodeAndMessage(ApiResult result) {return new ApiResult().setCode(result.getCode()).setMessage(result.getMessage());}
}

/*** 状态枚举*/
public enum StatusCode {/*** 正常*/C_200(200, "success"),/*** 系统繁忙*/C_ERROR(-1, "系统繁忙"),/*** 特殊错误信息*/C_10000(10000, "特殊错误信息"),/*** 用户未登录*/C_10001(10001, "用户未登录"),/*** 用户无访问权限*/C_10002(10002, "用户无访问权限"),/*** 用户身份验证失败*/C_10003(10003, "用户身份验证失败"),/*** 请求参数错误*/C_10004(10004, "请求参数错误"),/*** 请求信息不存在*/C_10005(10005, "请求信息不存在"),/*** 更新数据失败*/C_10006(10006, "更新数据失败"),;private Integer code;private String message;StatusCode(int code, String message) {this.code = code;this.message = message;}public Integer getCode() {return code;}public String getMessage() {return message;}public static StatusCode getByCode(int code) {StatusCode[] values = StatusCode.values();for (StatusCode value : values) {if (code == value.code) {return value;}}return StatusCode.C_ERROR;}
}
  1. 写一个测试接口，在方法中抛出异常，会发现返回的信息不是异常的堆栈内容，而是一个友好的提示内容：
import org.example.handler.BusinessException;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;/*** @Author xingo* @Date 2023/12/7*/
@RestController
public class DemoController {@GetMapping("/demo1")public Object demo1() {int i = 1, j = 0;return i / j;}@GetMapping("/demo2")public Object demo2() {if(System.currentTimeMillis() > 1) {throw BusinessException.fail(88888, "业务数据不合法");}return System.currentTimeMillis();}
}
2、返回统一数据结构

如果接口返回的数据格式不统一，接口请求端处理数据就会非常麻烦，在接口交互中，可以定义好一个数据结构，接口服务端和请求端根据这个结构封装数据，这样处理数据就会变得容易，假设现在统一的数据结构是ApiResult这个结构，规定code=200时表示成功，其他的code都是失败并且定义好code的值表示的失败含义。要达到统一数据结构返回，需要借助springboot中的ResponseBodyAdvice接口，它的主要作用是：拦截Controller方法的返回值，统一处理返回值/响应体，一般用来统一返回格式，加解密，签名等等。只要借助这个接口里面的两个方法：supports()和beforeBodyWrite()就可以实现我们想要的功能：

import org.example.pojo.ApiResult;
import org.springframework.core.MethodParameter;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.AnnotatedElementUtils;
import org.springframework.http.MediaType;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyAdvice;import java.lang.annotation.Annotation;
import java.util.Objects;/*** @Author xingo* @Date 2023/12/7*/
@RestControllerAdvice
public class ApiResultResponseBodyAdvice implements ResponseBodyAdvice<Object>, Ordered {private static final Class<? extends Annotation> ANNOTATION_TYPE = ResponseBody.class;/*** 判断类或者方法是否使用了 @ResponseBody 注解*/@Overridepublic boolean supports(MethodParameter returnType, Class<? extends HttpMessageConverter<?>> converterType) {return !ApiResult.class.isAssignableFrom(returnType.getParameterType())&& (AnnotatedElementUtils.hasAnnotation(returnType.getContainingClass(), ANNOTATION_TYPE)|| returnType.hasMethodAnnotation(ANNOTATION_TYPE));}/*** 当写入body之前调用这个方法*/@Overridepublic Object beforeBodyWrite(Object body, MethodParameter returnType, MediaType selectedContentType,Class<? extends HttpMessageConverter<?>> selectedConverterType,ServerHttpRequest request, ServerHttpResponse response) {// String类型的返回值要单独处理否则会报错：将数据写入data字段然后再序列化为json字符串Class<?> returnClass = returnType.getMethod().getReturnType();if(body instanceof String || Objects.equals(returnClass, String.class)) {return JacksonUtils.toJSONString(ApiResult.success(body));}// 已经是目标数据类型不处理if(body instanceof ApiResult) {return body;}// 封装统一对象return ApiResult.success(body);}@Overridepublic int getOrder() {return Integer.MIN_VALUE + 1;}
}

这里面用到了json序列化，使用jackson封装了一个json处理类对实体类进行序列化操作：

import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalTimeDeserializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateSerializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalTimeSerializer;import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.format.DateTimeFormatter;
import java.util.List;
import java.util.Locale;
import java.util.TimeZone;/*** @Author xingo* @Date 2023/12/7*/
public class JacksonUtils {private static final ObjectMapper mapper = new ObjectMapper();static {JavaTimeModule module = new JavaTimeModule();// 序列化时对Long类型进行处理，避免前端js处理数据时精度缺失module.addSerializer(Long.class, ToStringSerializer.instance);module.addSerializer(Long.TYPE, ToStringSerializer.instance);// java8日期处理module.addSerializer(LocalDateTime.class,new LocalDateTimeSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));module.addSerializer(LocalDate.class,new LocalDateSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));module.addSerializer(LocalTime.class,new LocalTimeSerializer(DateTimeFormatter.ofPattern("HH:mm:ss")));module.addDeserializer(LocalDateTime.class,new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));module.addDeserializer(LocalDate.class,new LocalDateDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));module.addDeserializer(LocalTime.class,new LocalTimeDeserializer(DateTimeFormatter.ofPattern("HH:mm:ss")));mapper.registerModules(module);// 反序列化的时候如果多了其他属性,不抛出异常mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);// 如果是空对象的时候,不抛异常mapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);// 空对象不序列化mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);// 日期格式化mapper.setDateFormat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));// 设置时区mapper.setTimeZone(TimeZone.getTimeZone("GMT+8"));// 驼峰转下划线
//        mapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE);// 语言mapper.setLocale(Locale.SIMPLIFIED_CHINESE);}/*** 反序列化* @param json      json字符串* @param clazz     发序列化类型* @return* @param <T>*/public static <T> T parseObject(String json, Class<T> clazz) {try {return mapper.readValue(json, clazz);} catch (JsonProcessingException e) {e.printStackTrace();}return null;}/*** 反序列化列表* @param json* @return* @param <T>*/public static <T> List<T> parseArray(String json) {try {TypeReference<List<T>> type = new TypeReference<List<T>>(){};return mapper.readValue(json, type);} catch (JsonProcessingException e) {e.printStackTrace();}return null;}/*** 写为json串* @param obj   对象* @return*/public static String toJSONString(Object obj) {try {return mapper.writeValueAsString(obj);} catch (JsonProcessingException e) {e.printStackTrace();}return null;}
}

通过上面的封装处理，只要接口返回的数据不是ApiResult类型，都会封装成该类型返回，达到统一数据类型的目的。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/204903.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Vue的Nuxt项目部署在服务器，pm2动态部署和npm run build静态部署

Vue的Nuxt项目部署在服务器，pm2动态部署和npm run build静态部署

Nuxt项目的部署有两种方式&#xff0c;一种是静态部署&#xff0c;一种是动态部署 静态部署需要关闭项目的ssr功能&#xff0c;动态部署则不需关闭&#xff0c;所以怎么部署项目就看你用不用ssr功能了 。 1.静态部署 先说静态部署&#xff0c;很简单&#xff0c;只需要在nuxt…
阅读更多...
【C语言】程序设计加密解密

【C语言】程序设计加密解密

&#x1f6a9;write in front&#x1f6a9; &#x1f50e; 介绍&#xff1a;"謓泽"正在路上朝着"攻城狮"方向"前进四" &#x1f50e;&#x1f3c5; 荣誉&#xff1a;2021|2022年度博客之星物联网与嵌入式开发TOP5|TOP4、2021|2222年获评百大博…
阅读更多...
对目前想法有帮助的论文

对目前想法有帮助的论文

《Enabling DeepSpikingNeuralNetworks with Hybrid conversion and SpikeTimingDependent Backpropagation》 - 知乎
阅读更多...
黛姿秘语，匠心之作，严谨工艺铸就完美肌肤

黛姿秘语，匠心之作，严谨工艺铸就完美肌肤

在喧嚣的都市中&#xff0c;我们每个人都渴望找到一款可以信赖长期使用的护肤品&#xff0c;让匹配的肌肤重新焕发光彩&#xff0c;找到更加年轻的自己&#xff0c;但是目前市面上的产品让人眼花缭乱&#xff0c;作为普通的消费者&#xff0c;无法去辨别什么产品好&#xff0c;…
阅读更多...
idea连接Hbase卡住，没有输出

idea连接Hbase卡住，没有输出

1.项目场景 &#xff08;idea连接hbase) 先检查hadoop,zookeeper&#xff0c;hbase启动没有 idea连接hbase,创建命名空间&#xff0c;idea一直卡住在日志&#xff0c;没有输出 package com.wf.hbase;import org.apache.hadoop.hbase.NamespaceDescriptor; import org.apache.…
阅读更多...
npm 更换镜像

npm 更换镜像

有时候npm install 安装时太慢了&#xff0c;可以试试设置淘宝镜像 1、更换镜像 npm config set registry https://registry.npm.taobao.org 2、查看镜像 npm config get registry 如果返回 https://registry.npm.taobao.org/&#xff0c;说明配置的是淘宝镜像。 3、还原镜像…
阅读更多...
北京市经信局局长姜广智带队调研三六零 强调大模型应与行业结合

北京市经信局局长姜广智带队调研三六零 强调大模型应与行业结合

12月6日&#xff0c;北京市经济和信息化局局长姜广智、副局长王磊带队走访调研三六零集团&#xff0c;就共促城市级数字安全基础设施项目落地&#xff0c;打造引领行业发展标杆项目&#xff0c;推动大模型落地应用赋能产业、行业发展等话题进行交流。360集团创始人周鸿祎接待来…
阅读更多...
形态学操作—凸壳

形态学操作—凸壳

图像形态学是图像处理领域的重要概念&#xff0c;而凸壳&#xff08;Convex Hull&#xff09;是其中的一个常用操作。它可以用数学的角度解释为一个闭合区域&#xff0c;该区域包围了给定点集的最小凸多边形。 凸壳的原理&#xff1a; 凸壳是一个凸多边形&#xff0c;它包围了…
阅读更多...
要求CHATGPT高质量回答的艺术：提示工程技术的完整指南—第 24 章：文本分类提示

要求CHATGPT高质量回答的艺术：提示工程技术的完整指南—第 24 章：文本分类提示

要求CHATGPT高质量回答的艺术&#xff1a;提示工程技术的完整指南—第 24 章&#xff1a;文本分类提示 文本分类是一种允许模型将文本归入不同类别的技术。这种技术对于自然语言处理、文本分析和情感分析等任务非常有用。 值得注意的是&#xff0c;文本分类不同于情感分析。情…
阅读更多...
（十五）Flask覆写wsgi_app函数实现自定义中间件

（十五）Flask覆写wsgi_app函数实现自定义中间件

中间件 一、剖析&#xff1a; 在前面讲session部分提到过&#xff1a;请求一进来&#xff0c;Flask会自动调用应用程序对象【Flask(__name__)】的__call__方法&#xff0c;这个方法负责处理请求并返回响应&#xff08;其实如下图&#xff1a;其内部就是wsgi_app方法&#xff…
阅读更多...
UniRepLKNet：用于音频、视频、点云、时间序列和图像识别的通用感知大内核ConvNet

UniRepLKNet：用于音频、视频、点云、时间序列和图像识别的通用感知大内核ConvNet

摘要 https://arxiv.org/abs/2311.15599 大核卷积神经网络(ConvNets)最近受到了广泛的研究关注，但存在两个未解决的关键问题需要进一步研究。(1)现有大核ConvNets的架构在很大程度上遵循传统ConvNets或Transformers的设计原则，而大核ConvNets的架构设计仍未得到充分解决。(2…
阅读更多...
linux rsync 和scp区别

linux rsync 和scp区别

rsync 和 scp 都是 Linux 中用于文件复制的命令&#xff0c;但它们之间存在一些关键差异&#xff1a; 效率&#xff1a;rsync 在复制文件时&#xff0c;只会复制文件中改变的部分&#xff0c;而 scp 则会复制整个文件&#xff0c;即使文件只有一小部分发生了变化。因此&#xf…
阅读更多...
C++ 指针进阶

C++ 指针进阶

目录 一、字符指针 二、指针数组 三、数组指针 数组指针的定义 &数组名 与 数组名 数组指针的使用 四、数组参数 一维数组传参 二维数组传参 五、指针参数 一级指针传参 二级指针传参 六、函数指针 七、函数指针数组 八、指向函数指针数组的指针 九、回调函…
阅读更多...
2023-简单点-同步异步和阻塞非阻塞

2023-简单点-同步异步和阻塞非阻塞

一句话概括 区分点&#xff1a; 调用方是否等返回&#xff0c;等返回时候是什么状态&#xff1f;【如果等&#xff0c;等的时候在干什么&#xff1f;】 我调用你&#xff0c;我需不需要你立即返回&#xff0c;需要就是同步&#xff0c;不需要就是异步&#xff1b; 那如果我等…
阅读更多...
docker基本管理和概念

docker基本管理和概念

1、定义&#xff1a;一个开源的应用容器引擎&#xff0c;基于go语言开发&#xff0c;运行在liunx系统中的开源的、轻量级的“虚拟机” docker的容器技术可以在一台主机上轻松的为任何应用创建一个轻量级的、可移植的、自给自足的容器 docker的宿主机是liunx系统&#xff0c;集…
阅读更多...
在互联网项目中，为什么很多使用rabbitMQ或者是kafka或者是rocketMQ而很少使用MQTT？

在互联网项目中，为什么很多使用rabbitMQ或者是kafka或者是rocketMQ而很少使用MQTT？

老师好&#xff0c;我有一个疑问&#xff1a;在互联网项目中&#xff0c;为什么很多使用rabbitMQ或者是kafka或者是rocketMQ而很少使用MQTT&#xff1f; 答&#xff1a;在互联网项目中&#xff0c;使用 RabbitMQ、Kafka 或 RocketMQ 而不是 MQTT 的主要原因可能与以下因素有关…
阅读更多...
第二十一 网络通信

第二十一 网络通信

网络通信 21.1 网络程序设计基础 网络程序设计编写的是与其他计算机进行通信的程序。 21.1.1 局域网与互联网 实现两台计算机的通信&#xff0c;必须用一个网络线路来连接两台计算机 21.1.2 网络协议 1.ip协议 IP是Internet Protocol的简称&#xff0c;是一种网络协议 2…
阅读更多...
Vue项目使用Sortable.js实现拖拽功能

Vue项目使用Sortable.js实现拖拽功能

想了解更多-可前往 Sortable.js官网 查看组件属性及参数 安装组件&#xff08;我这里使用的是NPM安装&#xff09; npm install sortablejs --save在需要使用拖拽功能的页面中使用&#xff08;完整功能代码&#xff09; <div class"tag_box"><div class&q…
阅读更多...
使用VS Code远程开发MENJA小游戏并通过内网穿透分享本地游戏到公网

使用VS Code远程开发MENJA小游戏并通过内网穿透分享本地游戏到公网

文章目录 前言1. 编写MENJA小游戏2. 安装cpolar内网穿透3. 配置MENJA小游戏公网访问地址4. 实现公网访问MENJA小游戏5. 固定MENJA小游戏公网地址 推荐一个人工智能学习网站 点击跳转学习 前言 本篇教程&#xff0c;我们将通过VS Code实现远程开发MENJA小游戏&#xff0c;并通…
阅读更多...
centos服务器安装docker和Rabbitmq

centos服务器安装docker和Rabbitmq

centos服务器 一 centos安装docker1 安装docker所需要的依赖包2配置yum源3查看仓库中所有的docker版本4安装docker5 设置docker为开机自启6验证docker是否安装成功 二 使用docker安装RabbitMQ拉取RabbitMQ镜像创建并运行容器 一 centos安装docker 1 安装docker所需要的依赖包 …
阅读更多...
最新文章

Copyright @ 2022~2023