java开源项目jeecg结构与代码全解析( 三 ) _jeecg

// 添加自己的过滤器并且取名为jwt
Map<string, filter=""> filterMap = new HashMap<string, filter="">(1);
//如果cloudServer为空则说明是单体需要加载跨域配置【微服务跨域切换】
Object cloudServer = env.getProperty(CommonConstant.CLOUD_SERVER_KEY);
//前文定义的过滤器
filterMap.put("jwt", new JwtFilter(cloudServer==null));
shiroFilterFactoryBean.setFilters(filterMap);
//
ex.printStackTrace();
}
}
}
}
public interface MqListener<t> {
default void handler(T map, Channel channel) {
}
}
</t></string,></string,></string,></string,>
2.RabbitMqClient
主要在队列初始化时实现队列的初始化，而是否初始化根据使用时的@RabbitListener、@RabbitComponent判断。
public interface MqListener<t> {
default void handler(T map, Channel channel) {
}
}
@Bean
public void initQueue() {
//获取带RabbitComponent注解的类
Map<string, object=""> beansWithRqbbitComponentMap = this.applicationContext.getBeansWithAnnotation(RabbitComponent.class);
Class clazz = null;
//循环map
for (Map.Entry<string, object=""> entry : beansWithRqbbitComponentMap.entrySet()) {
log.info("初始化队列............");
//获取到实例对象的class信息
clazz = entry.getValue().getClass();
Method[] methods = clazz.getMethods();
//判断是否有RabbitListener注解
RabbitListener rabbitListener = clazz.getAnnotation(RabbitListener.class);
//类上有注解就创建队列
if (ObjectUtil.isNotEmpty(rabbitListener)) {
createQueue(rabbitListener);
}
//方法上有注解就创建队列
for (Method method : methods) {
RabbitListener methodRabbitListener = method.getAnnotation(RabbitListener.class);
if (ObjectUtil.isNotEmpty(methodRabbitListener)) {
createQueue(methodRabbitListener);
}
}
}
}
private void createQueue(RabbitListener rabbitListener) {
String[] queues = rabbitListener.queues();
//创建交换机
DirectExchange directExchange = createExchange(DelayExchangeBuilder.DELAY_EXCHANGE);
rabbitAdmin.declareExchange(directExchange);
//创建队列
if (ObjectUtil.isNotEmpty(queues)) {
for (String queueName : queues) {
Properties result = rabbitAdmin.getQueueProperties(queueName);
if (ObjectUtil.isEmpty(result)) {
Queue queue = new Queue(queueName);
addQueue(queue);
Binding binding = BindingBuilder.bind(queue).to(directExchange).with(queueName);
rabbitAdmin.declareBinding(binding);
log.info("创建队列:" + queueName);
}else{
log.info("已有队列:" + queueName);
}
}
}
}
</string,></string,></t>
3.RabbitMqConfig
为消息队列的常用配置方式。这里不多描述。
4.event
这个包主要是为使用mq发送消息使用，多类别的消息会实现JeecgBusEventHandler类，而baseApplicationEvent通过消息类型传入的不同的参数选择合适的业务类发送消息。
5.DelayExchangeBuilder
为延时队列的交换机声明与绑定。
2.jeecg-boot-starter-lock
1.如何使用分布式锁
使用时有两种方式，一种是使用注解方式，一种是使用redisson提供的API 。

@Scheduled(cron = "0/5 * * * * ?")
@JLock(lockKey = CloudConstant.REDISSON_DEMO_LOCK_KEY1)
public void execute() throws InterruptedException {
log.info("执行execute任务开始，休眠三秒");
Thread.sleep(3000);
System.out.println("=======================业务逻辑1=============================");
Map map = new baseMap();
map.put("orderId", "BJ0001");
rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map);
//延迟10秒发送
map.put("orderId", "NJ0002");
rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map, 10000);
log.info("execute任务结束，休眠三秒");
}
public DemoLockTest() {
}
//@Scheduled(cron = "0/5 * * * * ?")
public void execute2() throws InterruptedException {
if (redissonLock.tryLock(CloudConstant.REDISSON_DEMO_LOCK_KEY2, -1, 6000)) {
log.info("执行任务execute2开始，休眠十秒");
Thread.sleep(10000);
System.out.println("=======================业务逻辑2=============================");
log.info("定时execute2结束，休眠十秒");

java开源项目jeecg结构与代码全解析( 三 )

推荐阅读

对于六安瓜片，中国工程院院士有话说

樱桃奶球|盘点五部鬼片可以当作搞笑片看的电影

春季谨防感冒发生糖尿病患者巧用“香菜”可治病

怪咖搞笑|幽默笑话：几天前因工作失误被老板训了半小时

怎样把皮肤变细腻白嫩

国家经济|印度前国安顾问：中国远未被孤立

基金|建发股份：拟出资3037.5万元认购安科基金

挖贝网|营业成本同比减少，华电国际2020年上半年净利23.86亿增长43.49%

封面新闻|30秒｜韩星金贤重抢救昏迷者，事后回应“只是做了该做的事”

酷玩四方|我的世界：最安全的火柴盒在高处？4个极具创意的MC建筑灵感

借款连累朋友，很难过

浙报融媒体|8个镇迎来发展契机，“萧山南花园”即将被串联

乐而雅零触感卫生巾安全吗

居民|儿童青少年超重肥胖问题凸显

c罗|第79分钟，球王C罗射丢第10脚攻门，亲手送别大奖，留下无奈苦笑

「中国特色社会主义」北京市发布全国文化中心建设未来15年规划

法律博士试点!对美国法学博士的了解

怎样才能快速祛斑美白？快速美白祛斑

安徽未来将有大发展的城市，不是芜湖和马鞍山，是你家乡吗

音乐响起|一开就是大半年，沾土就活，新手也能养的好！，聪明人都养3种花