`

spring boot实战(第十二篇)整合RabbitMQ

spring bootrabbit mq 
阅读更多

前言

本篇主要讲述spring Boot与RabbitMQ的整合，内容非常简单，纯API的调用操作。 操作之间需要加入依赖Jar

 

[html]
  1. <dependency>  
  2. <groupId>org.springframework.boot</groupId>  
  3. <artifactId>spring-boot-starter-amqp</artifactId>  
  4. lt;/dependency>  
			<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-amqp</artifactId>
		</dependency>

 

消息生产者

不论是创建消息消费者或生产者都需要ConnectionFactory
 
 

ConnectionFactory配置

创建AmqpConfig文件AmqpConfig.java(后期的配置都在该文件中)
 
[html]
  1. @Configuration  
  2. public class AmqpConfig {  
  3.   
  4.     public static final String EXCHANGE   = "spring-boot-exchange";  
  5.     public static final String ROUTINGKEY = "spring-boot-routingKey";  
  6.   
  7.     @Bean  
  8.     public ConnectionFactory connectionFactory() {  
  9.         CachingConnectionFactory connectionFactory = new CachingConnectionFactory();  
  10.         connectionFactory.setAddresses("127.0.0.1:5672");  
  11.         connectionFactory.setUsername("guest");  
  12.         connectionFactory.setPassword("guest");  
  13.         connectionFactory.setVirtualHost("/");  
  14.         connectionFactory.setPublisherConfirms(true); //必须要设置  
  15.         return connectionFactory;  
  16.     }  
  17. }  
@Configuration
public class AmqpConfig {

    public static final String EXCHANGE   = "spring-boot-exchange";
    public static final String ROUTINGKEY = "spring-boot-routingKey";

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses("127.0.0.1:5672");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        connectionFactory.setVirtualHost("/");
        connectionFactory.setPublisherConfirms(true); //必须要设置
        return connectionFactory;
    }
}

这里需要显示调用
[html]
  1. connectionFactory.setPublisherConfirms(true);  
 connectionFactory.setPublisherConfirms(true);
才能进行消息的回调。
 
 

RabbitTemplate

通过使用RabbitTemplate来对开发者提供API操作
[html]
  1. @Bean  
  2. @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)  
  3. //必须是prototype类型  
  4. public RabbitTemplate rabbitTemplate() {  
  5.     RabbitTemplate template = new RabbitTemplate(connectionFactory());  
  6.     return template;  
  7. }  
    @Bean
    @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
    //必须是prototype类型
    public RabbitTemplate rabbitTemplate() {
        RabbitTemplate template = new RabbitTemplate(connectionFactory());
        return template;
    }
这里设置为原型，具体的原因在后面会讲到
  在发送消息时通过调用RabbitTemplate中的如下方法
[html]
  1. public void convertAndSend(String exchange, String routingKey, final Object object, CorrelationData correlationData)  
public void convertAndSend(String exchange, String routingKey, final Object object, CorrelationData correlationData)
  • exchange:交换机名称

  • routingKey:路由关键字

  • object:发送的消息内容

  • correlationData:消息ID

 
因此生产者代码详单简洁

Send.java

[html]
  1. @Component  
  2. public class Send  {  
  3.   
  4.     private RabbitTemplate rabbitTemplate;  
  5.   
  6.     /**  
  7.      * 构造方法注入  
  8.      */  
  9.     @Autowired  
  10.     public Send(RabbitTemplate rabbitTemplate) {  
  11.         this.rabbitTemplate = rabbitTemplate;  
  12.     }  
  13.   
  14.     public void sendMsg(String content) {  
  15.         CorrelationData correlationId = new CorrelationData(UUID.randomUUID().toString());  
  16.         rabbitTemplate.convertAndSend(AmqpConfig.EXCHANGE, AmqpConfig.ROUTINGKEY, content, correlationId);  
  17.     }  
  18.   
  19.        
  20. }  
@Component
public class Send  {

    private RabbitTemplate rabbitTemplate;

    /**
     * 构造方法注入
     */
    @Autowired
    public Send(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    public void sendMsg(String content) {
        CorrelationData correlationId = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(AmqpConfig.EXCHANGE, AmqpConfig.ROUTINGKEY, content, correlationId);
    }

     
}

 

如果需要在生产者需要消息发送后的回调，需要对rabbitTemplate设置ConfirmCallback对象，由于不同的生产者需要对应不同的ConfirmCallback，如果rabbitTemplate设置为单例bean，则所有的rabbitTemplate

实际的ConfirmCallback为最后一次申明的ConfirmCallback。

下面给出完整的生产者代码：

 

[html]
  1. package com.u51.lkl.springboot.amqp;  
  2.   
  3. import java.util.UUID;  
  4.   
  5. import org.springframework.amqp.rabbit.core.RabbitTemplate;  
  6. import org.springframework.amqp.rabbit.support.CorrelationData;  
  7. import org.springframework.beans.factory.annotation.Autowired;  
  8. import org.springframework.stereotype.Component;  
  9.   
  10. /**  
  11.  * 消息生产者  
  12.  *   
  13.  * @author liaokailin  
  14.  * @version $Id: Send.java, v 0.1 2015年11月01日 下午4:22:25 liaokailin Exp $  
  15.  */  
  16. @Component  
  17. public class Send implements RabbitTemplate.ConfirmCallback {  
  18.   
  19.     private RabbitTemplate rabbitTemplate;  
  20.   
  21.     /**  
  22.      * 构造方法注入  
  23.      */  
  24.     @Autowired  
  25.     public Send(RabbitTemplate rabbitTemplate) {  
  26.         this.rabbitTemplate = rabbitTemplate;  
  27.         rabbitTemplate.setConfirmCallback(this); //rabbitTemplate如果为单例的话，那回调就是最后设置的内容  
  28.     }  
  29.   
  30.     public void sendMsg(String content) {  
  31.         CorrelationData correlationId = new CorrelationData(UUID.randomUUID().toString());  
  32.         rabbitTemplate.convertAndSend(AmqpConfig.EXCHANGE, AmqpConfig.ROUTINGKEY, content, correlationId);  
  33.     }  
  34.   
  35.     /**  
  36.      * 回调  
  37.      */  
  38.     @Override  
  39.     public void confirm(CorrelationData correlationData, boolean ack, String cause) {  
  40.         System.out.println(" 回调id:" + correlationData);  
  41.         if (ack) {  
  42.             System.out.println("消息成功消费");  
  43.         } else {  
  44.             System.out.println("消息消费失败:" + cause);  
  45.         }  
  46.     }  
  47.   
  48. }  
package com.u51.lkl.springboot.amqp;

import java.util.UUID;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.support.CorrelationData;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 消息生产者
 * 
 * @author liaokailin
 * @version $Id: Send.java, v 0.1 2015年11月01日 下午4:22:25 liaokailin Exp $
 */
@Component
public class Send implements RabbitTemplate.ConfirmCallback {

    private RabbitTemplate rabbitTemplate;

    /**
     * 构造方法注入
     */
    @Autowired
    public Send(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
        rabbitTemplate.setConfirmCallback(this); //rabbitTemplate如果为单例的话，那回调就是最后设置的内容
    }

    public void sendMsg(String content) {
        CorrelationData correlationId = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(AmqpConfig.EXCHANGE, AmqpConfig.ROUTINGKEY, content, correlationId);
    }

    /**
     * 回调
     */
    @Override
    public void confirm(CorrelationData correlationData, boolean ack, String cause) {
        System.out.println(" 回调id:" + correlationData);
        if (ack) {
            System.out.println("消息成功消费");
        } else {
            System.out.println("消息消费失败:" + cause);
        }
    }

}

 

消息消费者

消费者负责申明交换机(生产者也可以申明)、队列、两者的绑定操作。

交换机

[html]
  1. /**  
  2.      * 针对消费者配置  
  3.         FanoutExchange: 将消息分发到所有的绑定队列，无routingkey的概念  
  4.         HeadersExchange ：通过添加属性key-value匹配  
  5.         DirectExchange:按照routingkey分发到指定队列  
  6.         TopicExchange:多关键字匹配  
  7.      */  
  8.     @Bean  
  9.     public DirectExchange defaultExchange() {  
  10.         return new DirectExchange(EXCHANGE);  
  11.     }  
/**
     * 针对消费者配置
        FanoutExchange: 将消息分发到所有的绑定队列，无routingkey的概念
        HeadersExchange ：通过添加属性key-value匹配
        DirectExchange:按照routingkey分发到指定队列
        TopicExchange:多关键字匹配
     */
    @Bean
    public DirectExchange defaultExchange() {
        return new DirectExchange(EXCHANGE);
    }

在Spring Boot中交换机继承AbstractExchange类
 

 

队列

 
[html] view plain copy print?在CODE上查看代码片派生到我的代码片
  1. @Bean  
  2.     public Queue queue() {  
  3.         return new Queue("spring-boot-queue", true); //队列持久  
  4.   
  5.     }  
@Bean
    public Queue queue() {
        return new Queue("spring-boot-queue", true); //队列持久

    }

绑定

[html] view plain copy print?在CODE上查看代码片派生到我的代码片
  1. @Bean  
  2.   public Binding binding() {  
  3.       return BindingBuilder.bind(queue()).to(defaultExchange()).with(AmqpConfig.ROUTINGKEY);  
  4.   }  
  @Bean
    public Binding binding() {
        return BindingBuilder.bind(queue()).to(defaultExchange()).with(AmqpConfig.ROUTINGKEY);
    }
完成以上工作后，在spring boot中通过消息监听容器实现消息的监听，在消息到来时执行回调操作。
 

消息消费

[html]
  1. @Bean  
  2.   public SimpleMessageListenerContainer messageContainer() {  
  3.       SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());  
  4.       container.setQueues(queue());  
  5.       container.setExposeListenerChannel(true);  
  6.       container.setMaxConcurrentConsumers(1);  
  7.       container.setConcurrentConsumers(1);  
  8.       container.setAcknowledgeMode(AcknowledgeMode.MANUAL); //设置确认模式手工确认  
  9.       container.setMessageListener(new ChannelAwareMessageListener() {  
  10.   
  11.           @Override  
  12.           public void onMessage(Message message, Channel channel) throws Exception {  
  13.               byte[] body = message.getBody();  
  14.               System.out.println("receive msg : " + new String(body));  
  15.               channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); //确认消息成功消费  
  16.           }  
  17.       });  
  18.       return container;  
  19.   }  
  @Bean
    public SimpleMessageListenerContainer messageContainer() {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
        container.setQueues(queue());
        container.setExposeListenerChannel(true);
        container.setMaxConcurrentConsumers(1);
        container.setConcurrentConsumers(1);
        container.setAcknowledgeMode(AcknowledgeMode.MANUAL); //设置确认模式手工确认
        container.setMessageListener(new ChannelAwareMessageListener() {

            @Override
            public void onMessage(Message message, Channel channel) throws Exception {
                byte[] body = message.getBody();
                System.out.println("receive msg : " + new String(body));
                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); //确认消息成功消费
            }
        });
        return container;
    }

下面给出完整的配置文件：
 
[html] view plain copy print?在CODE上查看代码片派生到我的代码片
  1. package com.u51.lkl.springboot.amqp;  
  2.   
  3. import org.springframework.amqp.core.AcknowledgeMode;  
  4. import org.springframework.amqp.core.Binding;  
  5. import org.springframework.amqp.core.BindingBuilder;  
  6. import org.springframework.amqp.core.DirectExchange;  
  7. import org.springframework.amqp.core.Message;  
  8. import org.springframework.amqp.core.Queue;  
  9. import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;  
  10. import org.springframework.amqp.rabbit.connection.ConnectionFactory;  
  11. import org.springframework.amqp.rabbit.core.ChannelAwareMessageListener;  
  12. import org.springframework.amqp.rabbit.core.RabbitTemplate;  
  13. import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;  
  14. import org.springframework.beans.factory.config.ConfigurableBeanFactory;  
  15. import org.springframework.context.annotation.Bean;  
  16. import org.springframework.context.annotation.Configuration;  
  17. import org.springframework.context.annotation.Scope;  
  18.   
  19. import com.rabbitmq.client.Channel;  
  20.   
  21. /**  
  22.  * Qmqp Rabbitmq  
  23.  *   
  24.  * http://docs.spring.io/spring-amqp/docs/1.4.5.RELEASE/reference/html/  
  25.  *   
  26.  * @author lkl  
  27.  * @version $Id: AmqpConfig.java, v 0.1 2015年11月01日 下午2:05:37 lkl Exp $  
  28.  */  
  29.   
  30. @Configuration  
  31. public class AmqpConfig {  
  32.   
  33.     public static final String EXCHANGE   = "spring-boot-exchange";  
  34.     public static final String ROUTINGKEY = "spring-boot-routingKey";  
  35.   
  36.     @Bean  
  37.     public ConnectionFactory connectionFactory() {  
  38.         CachingConnectionFactory connectionFactory = new CachingConnectionFactory();  
  39.         connectionFactory.setAddresses("127.0.0.1:5672");  
  40.         connectionFactory.setUsername("guest");  
  41.         connectionFactory.setPassword("guest");  
  42.         connectionFactory.setVirtualHost("/");  
  43.         connectionFactory.setPublisherConfirms(true); //必须要设置  
  44.         return connectionFactory;  
  45.     }  
  46.   
  47.     @Bean  
  48.     @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)  
  49.     //必须是prototype类型  
  50.     public RabbitTemplate rabbitTemplate() {  
  51.         RabbitTemplate template = new RabbitTemplate(connectionFactory());  
  52.         return template;  
  53.     }  
  54.   
  55.     /**  
  56.      * 针对消费者配置  
  57.      * 1. 设置交换机类型  
  58.      * 2. 将队列绑定到交换机  
  59.      *   
  60.      *   
  61.         FanoutExchange: 将消息分发到所有的绑定队列，无routingkey的概念  
  62.         HeadersExchange ：通过添加属性key-value匹配  
  63.         DirectExchange:按照routingkey分发到指定队列  
  64.         TopicExchange:多关键字匹配  
  65.      */  
  66.     @Bean  
  67.     public DirectExchange defaultExchange() {  
  68.         return new DirectExchange(EXCHANGE);  
  69.     }  
  70.   
  71.     @Bean  
  72.     public Queue queue() {  
  73.         return new Queue("spring-boot-queue", true); //队列持久  
  74.   
  75.     }  
  76.   
  77.     @Bean  
  78.     public Binding binding() {  
  79.         return BindingBuilder.bind(queue()).to(defaultExchange()).with(AmqpConfig.ROUTINGKEY);  
  80.     }  
  81.   
  82.     @Bean  
  83.     public SimpleMessageListenerContainer messageContainer() {  
  84.         SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());  
  85.         container.setQueues(queue());  
  86.         container.setExposeListenerChannel(true);  
  87.         container.setMaxConcurrentConsumers(1);  
  88.         container.setConcurrentConsumers(1);  
  89.         container.setAcknowledgeMode(AcknowledgeMode.MANUAL); //设置确认模式手工确认  
  90.         container.setMessageListener(new ChannelAwareMessageListener() {  
  91.   
  92.             @Override  
  93.             public void onMessage(Message message, Channel channel) throws Exception {  
  94.                 byte[] body = message.getBody();  
  95.                 System.out.println("receive msg : " + new String(body));  
  96.                 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); //确认消息成功消费  
  97.             }  
  98.         });  
  99.         return container;  
  100.     }  
  101.   
  102. }  
package com.u51.lkl.springboot.amqp;

import org.springframework.amqp.core.AcknowledgeMode;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.ChannelAwareMessageListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.beans.factory.config.ConfigurableBeanFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Scope;

import com.rabbitmq.client.Channel;

/**
 * Qmqp Rabbitmq
 * 
 * http://docs.spring.io/spring-amqp/docs/1.4.5.RELEASE/reference/html/
 * 
 * @author lkl
 * @version $Id: AmqpConfig.java, v 0.1 2015年11月01日 下午2:05:37 lkl Exp $
 */

@Configuration
public class AmqpConfig {

    public static final String EXCHANGE   = "spring-boot-exchange";
    public static final String ROUTINGKEY = "spring-boot-routingKey";

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses("127.0.0.1:5672");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        connectionFactory.setVirtualHost("/");
        connectionFactory.setPublisherConfirms(true); //必须要设置
        return connectionFactory;
    }

    @Bean
    @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
    //必须是prototype类型
    public RabbitTemplate rabbitTemplate() {
        RabbitTemplate template = new RabbitTemplate(connectionFactory());
        return template;
    }

    /**
     * 针对消费者配置
     * 1. 设置交换机类型
     * 2. 将队列绑定到交换机
     * 
     * 
        FanoutExchange: 将消息分发到所有的绑定队列，无routingkey的概念
        HeadersExchange ：通过添加属性key-value匹配
        DirectExchange:按照routingkey分发到指定队列
        TopicExchange:多关键字匹配
     */
    @Bean
    public DirectExchange defaultExchange() {
        return new DirectExchange(EXCHANGE);
    }

    @Bean
    public Queue queue() {
        return new Queue("spring-boot-queue", true); //队列持久

    }

    @Bean
    public Binding binding() {
        return BindingBuilder.bind(queue()).to(defaultExchange()).with(AmqpConfig.ROUTINGKEY);
    }

    @Bean
    public SimpleMessageListenerContainer messageContainer() {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
        container.setQueues(queue());
        container.setExposeListenerChannel(true);
        container.setMaxConcurrentConsumers(1);
        container.setConcurrentConsumers(1);
        container.setAcknowledgeMode(AcknowledgeMode.MANUAL); //设置确认模式手工确认
        container.setMessageListener(new ChannelAwareMessageListener() {

            @Override
            public void onMessage(Message message, Channel channel) throws Exception {
                byte[] body = message.getBody();
                System.out.println("receive msg : " + new String(body));
                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); //确认消息成功消费
            }
        });
        return container;
    }

}


以上完成 Spring Boot与RabbitMQ的整合 
动配置
在Spring Boot中实现了RabbitMQ的自动配置，在配置文件中添加如下配置信息
[html]
  1. spring.rabbitmq.host=localhost  
  2. spring.rabbitmq.port=5672  
  3. spring.rabbitmq.username=test  
  4. spring.rabbitmq.password=test  
  5. spring.rabbitmq.virtualHost=test  
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=test
spring.rabbitmq.password=test
spring.rabbitmq.virtualHost=test

后会自动创建ConnectionFactory以及RabbitTemplate对应Bean，为什么上面我们还需要手动什么呢?
 
自动创建的ConnectionFactory无法完成事件的回调，即没有设置下面的代码
[html]
  1. connectionFactory.setPublisherConfirms(true);  
connectionFactory.setPublisherConfirms(true);
具体分析见后续文章的源码解读.
转载：http://blog.csdn.net/liaokailin/article/details/49559571
 
分享到：
| 开涛博客分享
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    精通 Spring Boot 42 讲

    15. **Spring Boot实战**：通过案例分析，展示Spring Boot在实际项目中的应用。 以上只是一部分可能的章节内容，实际的"精通 Spring Boot 42 讲"教程可能会更深入地探讨每个主题，并且包含更多实用的示例和实战经验...

    Spring Boot全套教程.txt

    ------------------------课程介绍------------------------ ...14-SringBoot整合Redis、Httpclient、RabbitMQ 15-SpringBoot设置SpringMVC的配置 16-启动测试（解决一些问题） 17-SpringBoot发布到独立的tomcat

    SpringBoot实战（第四版）带目录可以复制粘贴

    11. **Spring Boot与外部服务集成**：如邮件服务、消息队列(RabbitMQ或Kafka)、缓存技术(Guava Cache、Redis)等。 12. **持续集成/持续部署(CI/CD)**：介绍Jenkins、GitLab CI/CD等工具，以及SpringBoot在自动化...

    infor：数字化转型助力制造企业蜕变.pdf

    infor：数字化转型助力制造企业蜕变.pdf

    毕业论文-电视TV_新增蓝光-整站商业源码.zip

    毕业论文-电视TV_新增蓝光-整站商业源码.zip

    InTouch触摸式考勤终端介绍.PDF

    InTouch触摸式考勤终端介绍.PDF

    毕业论文-日主题子主题-整站商业源码.zip

    毕业论文-日主题子主题-整站商业源码.zip

    毕业论文-彩虹目录列表程序v1.3源码-整站商业源码.zip

    毕业论文-彩虹目录列表程序v1.3源码-整站商业源码.zip

    灭火器识别数据集，识别率99.5%，分别率640x640，127张训练图，支持pasical voc xml格式的标注框

    灭火器识别数据集，识别率99.5%，分别率640x640，127张训练图，支持pasical voc xml格式的标注框

    【Java毕业设计】勤无忧考勤工具 - 论文、源码、PPT，打造毕业作品.zip

    此压缩包包含了本毕业设计项目的完整内容，具体包括源代码、毕业论文以及演示PPT模板。 开发语言：Java 框架：SSM（Spring、Spring MVC、MyBatis） JDK版本：JDK 1.8 或以上 开发工具：Eclipse 或 IntelliJ IDEA Maven版本：Maven 3.3 或以上 数据库：MySQL 5.7 或以上 项目配置完成后即可运行，若需添加额外功能，可根据需求自行扩展。 运行条件 确保已安装 JDK 1.8 或更高版本，并正确配置 Java 环境变量。 使用 Eclipse 或 IntelliJ IDEA 打开项目，导入 Maven 依赖，确保依赖包下载完成。 配置数据库环境，确保 MySQL 服务正常运行，并导入项目中提供的数据库脚本。 在 IDE 中启动项目，确认所有服务正常运行。 主要功能简述： 请假审批流程：系统支持请假申请的逐级审批，包括班主任审批和院系领导审批（针对超过三天的请假）。学生可以随时查看请假申请的审批进展情况。 请假记录管理：系统记录学生的所有请假记录，包括请假时间、原因、审批状态及审批意见等，供学生和审批人员查询。 学生在线请假：学生可以通过系统在线填写请假申请，包括请假的起止日期和请假原因，并提交给班主任审批。超过三天的请假需经班主任审批后，再由院系领导审批。 出勤信息记录：任课老师可以在线记录学生的上课出勤情况，包括迟到、早退、旷课和请假等状态。 出勤信息查询：学生、任课老师、班主任、院系领导和学校领导均可根据权限查看不同范围的学生上课出勤信息。学生可以查看自己所有学年的出勤信息，任课老师可以查看所教班级的出勤信息，班主任和院系领导可以查看本班或本院系的出勤信息，学校领导可以查看全校的出勤信息。 出勤统计与分析：系统提供出勤统计功能，可以按班级、学期等条件统计学生的出勤情况，帮助管理人员了解学生的出勤状况。 用户管理：系统管理员负责管理所有用户信息，包括学生、任课老师、班主任、院系领导和学校领导的账号创建、权限分配等。 数据维护：管理员可以动态更新和维护系统所需的数据，如学生信息、课程安排、学年安排等，确保系统的正常运行。 系统配置：管理员可以对系统进行配置，如设置数据库连接参数、调整系统参数等，以满足不同的使用需求。 身份验证：系统采用用户名和密码进行身份验证，确保只有授权用户才能访问系统。不同用户类型（学生、任课老师、班主任、院系领导、学校领导、系统管理员）具有不同的操作权限。 权限控制：系统根据用户类型分配不同的操作权限，确保用户只能访问和操作其权限范围内的功能和数据。 数据安全：系统采取多种措施保障数据安全，如数据库加密、访问控制等，防止数据泄露和非法访问。

    【电子设计竞赛】具有发电功能的储能小车设计与制作：高职高专组比赛任务及要求详解

    内容概要：本文档为2021年全国大学生电子设计竞赛的试题，针对“具有发电功能的储能小车”这一主题进行了详细的任务描述、要求说明及评分标准设定。任务要求设计并制作一款以超级电容为储能元件的手动发电智能小车，通过在特定区域内往复运动完成充电，之后按照规定执行直线行驶或沿圆形轨迹行驶的动作，并具备LED指示、液晶显示行驶距离等功能。基本要求涵盖小车的充电、启动控制、行驶距离等；发挥部分则增加了循迹行驶、硬币探测等挑战性任务。文档还对竞赛规则、测试条件等做了明确说明； 适合人群：参加全国大学生电子设计竞赛的高职高专组学生； 使用场景及目标：①为参赛队伍提供具体的设计与制作指导；②确保各参赛队伍理解竞赛规则、评分标准，以便准备比赛； 阅读建议：仔细研读任务要求和评分细则，确保设计方案符合所有规定，同时关注发挥部分以争取更高分数。

    汽车BCM程序源代码解析：灯光控制、雨刮洗涤、遥控及通讯功能的实现

    内容概要：本文详细介绍了汽车BCM（车身控制模块）程序源代码的关键功能和技术细节。首先探讨了BCM对外部灯光（如前照灯、转向灯、雾灯等）和内部灯光（如顶灯、门灯等）的精确控制机制，确保驾驶员和乘客的安全与舒适。其次，阐述了BCM对前后雨刮和洗涤系统的智能控制，提升车辆在恶劣天气条件下的能见度。接着，讲解了遥控钥匙（RKE）和门锁系统的运作方式，使车主能够远程操控车辆。最后，深入分析了CAN/LIN通讯和ISO15765诊断协议的应用，确保车辆各模块之间的高效协同和故障诊断。文中还展示了部分伪代码示例，帮助读者更好地理解BCM的具体实现。 适用人群：汽车电子工程师、嵌入式软件开发者、汽车爱好者。 使用场景及目标：适用于希望深入了解汽车BCM工作原理的技术人员，旨在掌握BCM在灯光控制、雨刮洗涤、遥控及通讯等方面的具体实现方法，从而应用于实际项目开发或故障排查。 其他说明：本文不仅提供了理论知识，还附有简单代码示例，便于读者理解和实践。

    毕业论文-深蓝AI智能名片小程序1.7.1-整站商业源码.zip

    毕业论文-深蓝AI智能名片小程序1.7.1-整站商业源码.zip

    基于springboot的“考研资讯平台”的设计与实现（源码+数据库+文档+PPT).zip

    # 基于springboot的“考研资讯平台”的设计与实现（源码+数据库+文档+PPT) - 开发语言：Java - 数据库：MySQL - 技术：springboot - 工具：IDEA/Ecilpse、Navicat、Maven

    VMware 17最新安装包

    VMware 17最新安装包

    电动汽车电机控制器：基于英飞凌TC27xC平台的详细设计方案及其实现

    内容概要：本文详细介绍了一种基于英飞凌TC27xC平台的电动汽车电机控制器设计方案。该方案涵盖了原理图、Bom清单、代码及其分析。文中首先概述了方案的整体架构，接着深入解析了原理图中的关键组件，如PWM信号用于控制电机速度和方向，以及ADC用于实时监控电流和电压。随后，提供了详细的Bom清单，列出了所有必要的电子元件。代码部分则分为初始化代码、电机控制代码和代码分析，展示了模块化的编程思路，确保系统的稳定性和易维护性。最后，介绍了该方案在实际电动汽车中的成功应用，强调了其对提升驾驶体验和安全性的贡献。 适合人群：从事电动汽车研发的技术人员、硬件工程师、嵌入式软件开发人员。 使用场景及目标：适用于正在研究或开发电动汽车电机控制系统的人群，旨在帮助他们理解和实现高效的电机控制解决方案。 其他说明：本文不仅提供了理论和技术细节，还分享了实践经验，有助于读者更好地掌握相关技术和应用场景。

    java必读之代码大全笔记

    java必读之代码大全笔记

    20张人脸面部不同区域分割、有标签

    20张人脸面部不同区域分割、有标签

    Java设计成品】学生考勤监控 - 论文、源码、PPT打包.zip

    此压缩包包含了本毕业设计项目的完整内容，具体包括源代码、毕业论文以及演示PPT模板。 开发语言：Java 框架：SSM（Spring、Spring MVC、MyBatis） JDK版本：JDK 1.8 或以上 开发工具：Eclipse 或 IntelliJ IDEA Maven版本：Maven 3.3 或以上 数据库：MySQL 5.7 或以上 项目配置完成后即可运行，若需添加额外功能，可根据需求自行扩展。 运行条件 确保已安装 JDK 1.8 或更高版本，并正确配置 Java 环境变量。 使用 Eclipse 或 IntelliJ IDEA 打开项目，导入 Maven 依赖，确保依赖包下载完成。 配置数据库环境，确保 MySQL 服务正常运行，并导入项目中提供的数据库脚本。 在 IDE 中启动项目，确认所有服务正常运行。 主要功能简述： 请假审批流程：系统支持请假申请的逐级审批，包括班主任审批和院系领导审批（针对超过三天的请假）。学生可以随时查看请假申请的审批进展情况。 请假记录管理：系统记录学生的所有请假记录，包括请假时间、原因、审批状态及审批意见等，供学生和审批人员查询。 学生在线请假：学生可以通过系统在线填写请假申请，包括请假的起止日期和请假原因，并提交给班主任审批。超过三天的请假需经班主任审批后，再由院系领导审批。 出勤信息记录：任课老师可以在线记录学生的上课出勤情况，包括迟到、早退、旷课和请假等状态。 出勤信息查询：学生、任课老师、班主任、院系领导和学校领导均可根据权限查看不同范围的学生上课出勤信息。学生可以查看自己所有学年的出勤信息，任课老师可以查看所教班级的出勤信息，班主任和院系领导可以查看本班或本院系的出勤信息，学校领导可以查看全校的出勤信息。 出勤统计与分析：系统提供出勤统计功能，可以按班级、学期等条件统计学生的出勤情况，帮助管理人员了解学生的出勤状况。 用户管理：系统管理员负责管理所有用户信息，包括学生、任课老师、班主任、院系领导和学校领导的账号创建、权限分配等。 数据维护：管理员可以动态更新和维护系统所需的数据，如学生信息、课程安排、学年安排等，确保系统的正常运行。 系统配置：管理员可以对系统进行配置，如设置数据库连接参数、调整系统参数等，以满足不同的使用需求。 身份验证：系统采用用户名和密码进行身份验证，确保只有授权用户才能访问系统。不同用户类型（学生、任课老师、班主任、院系领导、学校领导、系统管理员）具有不同的操作权限。 权限控制：系统根据用户类型分配不同的操作权限，确保用户只能访问和操作其权限范围内的功能和数据。 数据安全：系统采取多种措施保障数据安全，如数据库加密、访问控制等，防止数据泄露和非法访问。

    commons-csv-1.8.jar中文文档.zip

    # 压缩文件中包含： 中文文档 jar包下载地址 Maven依赖 Gradle依赖 源代码下载地址 # 本文件关键字： jar中文文档.zip,java,jar包,Maven,第三方jar包,组件,开源组件,第三方组件,Gradle,中文API文档,手册,开发手册,使用手册,参考手册 # 使用方法： 解压最外层zip，再解压其中的zip包，双击 【index.html】 文件，即可用浏览器打开、进行查看。 # 特殊说明： ·本文档为人性化翻译，精心制作，请放心使用。 ·只翻译了该翻译的内容，如：注释、说明、描述、用法讲解 等； ·不该翻译的内容保持原样，如：类名、方法名、包名、类型、关键字、代码 等。 # 温馨提示： （1）为了防止解压后路径太长导致浏览器无法打开，推荐在解压时选择“解压到当前文件夹”（放心，自带文件夹，文件不会散落一地）； （2）有时，一套Java组件会有多个jar，所以在下载前，请仔细阅读本篇描述，以确保这就是你需要的文件；

Magicbox
Global site tag (gtag.js) - Google Analytics