idea机器扛不住的可以这么设置一下(启动慢
mybatis-plus批量更新
1.service方式
UpdateWrapper updateWrapper = new UpdateWrapper<>();
updateWrapper.lambda()
.in(字段名, ids);
val xxxteEntity = new xxxteEntity();
xxxteEntity.set字段名(字段值);
//xxxteEntity 修改后的实体
int num= xxxMapper.update(xxxteEntity,updateWrapper); 2.mapper方式
UpdateWrapper updateWrapper = new UpdateWrapper<>();
updateWrapper.lambda()
.in(xxxEntity::getId, ids); .set(xxxEntity::字段名,修改的值);
boolean res= xxService.update(updateWrapper);
- 1
@SuppressWarnings(“PMD“) //CHECKSTYLE:OFF
过滤发包校验
feign调用
feign调用
@Component
public class CollectionShopCompareFallbackFactory implements FallbackFactory<ICollectionShopCompareRemoteService> {
@Override
public ICollectionShopCompareRemoteService create(Throwable throwable) {
return null;
}
}
@FeignClient(contextId = "collectionShopCompareRemoteService", name = "saas-collect-server",
url = "${feign.server.collect-url}", fallbackFactory = CollectionTemplateServiceFallbackFactory.class)
public interface ICollectionShopCompareRemoteService {
}
collect-url: http://localhost:31514
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
日志:切面
日志:切面 /**
-
@description: 系統操作日志切面,用户对系统操作进行记录
**/
@Slf4j
//作用是把当前类标识为一个切面供容器读取
@Aspect
@Component public class SysOperatorLogAspect extends CommonController {@Resource
private ISysOperatorLogRemoteService sysOperatorLogService;
@Resource
private EncodeDecodeService encodeDecodeService;
@Resource private Environment environment;
/**
* Advice(通知、切面): 某个连接点所采用的处理逻辑,也就是向连接点注入的代码, AOP在特定的切入点上执行的增强处理。
* @Before: 标识一个前置增强方法,相当于BeforeAdvice的功能.
* @After: final增强,不管是抛出异常或者正常退出都会执行.
* @AfterReturning: 后置增强,似于AfterReturningAdvice, 方法正常退出时执行.
* @AfterThrowing: 异常抛出增强,相当于ThrowsAdvice.
* @Around: 环绕增强,相当于MethodInterceptor.
* JointPoint(连接点):程序运行中的某个阶段点,比如方法的调用、异常的抛出等。
* Pointcut(切入点): JoinPoint的集合,是程序中需要注入Advice的位置的集合,指明Advice要在什么样的条件下才能被触发,在程序中主要体现为书写切入点表达式。
* Advisor(增强): 是PointCut和Advice的综合体,完整描述了一个advice将会在pointcut所定义的位置被触发。
* @Aspect(切面): 通常是一个类的注解,里面可以定义切入点和通知
* AOP Proxy:AOP框架创建的对象,代理就是目标对象的加强。Spring中的AOP代理可以使JDK动态代理,也可以是CGLIB代理,前者基于接口,后者基于子类。
*/
@Pointcut(value = "@annotation(com.shuwei.sscm.saas.admin.annotate.SysLogAnnotate)")
public void annotateCut() {
}
//标识一个前置增强方法,相当于BeforeAdvice的功能,相似功能的还有
@Before(value = "annotateCut()")
public void before(JoinPoint joinPoint) {
MethodSignature signature = (MethodSignature) joinPoint.getSignature();
Method method = signature.getMethod();
ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
SysLog sysOperatorLog = new SysLog();
String argsStr = Arrays.toString(joinPoint.getArgs());
if (StringUtils.isNotBlank(argsStr) && argsStr.length() > 2000) {
argsStr = argsStr.substring(0, 2000);
}
// 自定义注解
/**
* @Target({ElementType.TYPE, ElementType.METHOD})
* @Retention(RetentionPolicy.RUNTIME)
* @Inherited
* @Documented
* public @interface SysLogAnnotate {
*
* String title() default "";
*
* String action() default "";
*
* ClientEnum client() default ClientEnum.PC;
*
* }
*/
SysLogAnnotate sysLogAnnotate = method.getAnnotation(SysLogAnnotate.class);
HttpServletRequest request = attributes.getRequest();
sysOperatorLog.setTitle(sysLogAnnotate.title());
sysOperatorLog.setAction(sysLogAnnotate.action());
sysOperatorLog.setClient(sysLogAnnotate.client().getType());
sysOperatorLog.setRequestParam(argsStr);
sysOperatorLog.setRequestUri(request.getRequestURI());
sysOperatorLog.setGmtCreate(DateUtils.getNow());
String token = request.getHeader("Authorization");
// 用户信息
MchUser user = getCurrentUser();
if (null != user && StringUtils.isNotEmpty(token)) {
sysOperatorLog.setMerchantId(user.getBelongId());
sysOperatorLog.setUserId(user.getId());
sysOperatorLog.setUserName(user.getName());
String telPhone = user.getTelphone();
String env = environment.getProperty("spring.profiles.active");
String profile = "dev,local";
if (StringUtils.isNotBlank(telPhone) && env != null && !profile.contains(env)) {
telPhone = encodeDecodeService.encodeData(telPhone);
}
sysOperatorLog.setUserPhone(telPhone);
}
log.info("sysOperatorLog:{}", sysOperatorLog);
try {
sysOperatorLogService.saveSysLog(sysOperatorLog);
} catch (Exception e) {
log.error(e.getMessage(), e);
}
}
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
rocketmq关键词定义
Broker:消息中转角色,负责存储消息,转发消息。Broker是具体提供业务的服务器,单个Broker节点与所有的NameServer节点保持长连接及心跳,并会定时将Topic信息注册到NameServer,顺带一提底层的通信和连接都是基于Netty实现的。Broker负责消息存储,以Topic为纬度支持轻量级的队列,单机可以支撑上万队列规模,支持消息推拉模型。官网上有数据显示:具有上亿级消息堆积能力,同时可严格保证消息的有序性
Topic:主题!它是消息的第一级类型。比如一个电商系统可以分为:交易消息、物流消息等,一条消息必须有一个 Topic 。Topic与生产者和消费者的关系非常松散,一个 Topic 可以有0个、1个、多个生产者向其发送消息,一个生产者也可以同时向不同的 Topic 发送消息。一个 Topic 也可以被 0个、1个、多个消费者订阅。
Tag:标签!可以看作子主题,它是消息的第二级类型,用于为用户提供额外的灵活性。使用标签,同一业务模块不同目的的消息就可以用相同Topic而不同的Tag来标识。比如交易消息又可以分为:交易创建消息、交易完成消息等,一条消息可以没有Tag。标签有助于保持您的代码干净和连贯,并且还可以为RabbitMQ提供的查询系统提供帮助。
MessageQueue:一个Topic下可以设置多个消息队列,发送消息时执行该消息的Topic,RocketMQ会轮询该Topic下的所有队列将消息发出去。消息的物理管理单位。一个Topic下可以有多个Queue,Queue的引入使得消息的存储可以分布式集群化,具有了水平扩展能力。
NameServer:类似Kafka中的ZooKeeper,但NameServer集群之间是没有通信的,相对ZK来说更加轻量。它主要负责对于源数据的管理,包括了对于Topic和路由信息的管理。每个Broker在启动的时候会到NameServer注册,Producer在发送消息前会根据Topic去NameServer获取对应Broker的路由信息,Consumer也会定时获取 Topic 的路由信息。
Producer:生产者,支持三种方式发送消息:同步、异步和单向单向发送 :消息发出去后,可以继续发送下一条消息或执行业务代码,不等待服务器回应,且没有回调函数。异步发送 :消息发出去后,可以继续发送下一条消息或执行业务代码,不等待服务器回应,有回调函数。同步发送 :消息发出去后,等待服务器响应成功或失败,才能继续后面的操作。
Consumer:消费者,支持 PUSH 和 PULL 两种消费模式,支持集群消费和广播消费集群消费 :该模式下一个消费者集群共同消费一个主题的多个队列,一个队列只会被一个消费者消费,如果某个消费者挂掉,分组内其它消费者会接替挂掉的消费者继续消费。广播消费 :会发给消费者组中的每一个消费者进行消费。相当于RabbitMQ的发布订阅模式。
Group:分组,一个组可以订阅多个Topic。分为ProducerGroup,ConsumerGroup,代表某一类的生产者和消费者,一般来说同一个服务可以作为Group,同一个Group一般来说发送和消费的消息都是一样的 Offset:在RocketMQ中,所有消息队列都是持久化,长度无限的数据结构,所谓长度无限是指队列中的每个存储单元都是定长,访问其中的存储单元使用Offset来访问,Offset为Java Long类型,64位,理论上在 100年内不会溢出,所以认为是长度无限。也可以认为Message Queue是一个长度无限的数组,Offset就是下标。
本文使用 文章同步助手 同步
网友评论