Redis：发布（pub）与订阅（sub）实战

news2025/1/10 23:32:27

前言

Redis发布订阅（Pub/Sub）是Redis提供的一种消息传递机制，它使用“发布者-订阅者”（publisher-subscriber）模式来处理消息传递。在这种模式下，发布者将消息发布到一组订阅者中，而无需关心谁是订阅者，也不需要知道订阅者是否收到了消息。
在这里插入图片描述

发布者和订阅者模式允许多个客户端之间建立一个复杂的通信拓扑。在这种模式下，发布者可以发布消息到一个特定的主题，订阅者可以订阅一个或多个主题，并在发布者发布消息时收到消息。由于发布者和订阅者不必直接连接，因此发布者和订阅者可以完全独立地运行，只要它们都连接到Redis实例即可。

Redis发布订阅支持多种消息类型，包括文本、字节数组和数字等。 Redis还支持订阅者识别特定消息，通过模式匹配功能，可以基于主题模式或模式来检索消息。Redis还提供了许多API来帮助您实现发布/订阅模式，因此您可以使用Redis的发布/订阅功能来构建分布式应用程序。

Redis Pub/Sub(发布/订阅) 命令

Redis发布/订阅（Pub/Sub）分为两种

  • 第一种基于频道(Channel)的发布/订阅。
  • 第二种基于模式(pattern)的发布/订阅。

确实，Redis提供了一系列的Pub/Sub命令来支持基于频道和基于模式的发布/订阅模式。以下是一些常用的Pub/Sub命令：

基于频道的发布/订阅

发布消息到指定频道

PUBLISH channel message

例如：

PUBLISH my-channel "Hello, Redis!"

这将向名为my-channel的频道发布消息"Hello, Redis!"。

订阅一个或多个频道

SUBSCRIBE channel channel ...

例如：

SUBSCRIBE my-channel your-channel

这将订阅my-channel和your-channel两个频道。

取消订阅一个或多个频道

UNSUBSCRIBE [channel channel ...]

例如：

UNSUBSCRIBE my-channel your-channel

这将取消订阅my-channel和your-channel两个频道。

基于模式的发布/订阅

订阅一个或多个匹配模式

PSUBSCRIBE pattern pattern ...

例如：

PSUBSCRIBE news-*

这将订阅所有以news-开头的频道。

取消订阅一个或多个匹配模式

PUNSUBSCRIBE [pattern pattern ...]

例如：

PUNSUBSCRIBE news-*

这将取消订阅所有以news-开头的频道。

注意：Pub/Sub命令可以在客户端和服务器之间进行通信，用于实现消息的发布和订阅。这些命令是异步执行的，发送命令后，订阅者将在接收到消息时收到通知。 Pub/Sub是一个强大的工具，用于实现实时消息传递和事件通知。

实战示例

基于MessageListener实现

创建消息接收者

创建一个接收消息的Bean。

package com.example.demo.redis;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;

/**
 * 实现MessageListener的监听类
 */
@Slf4j
@Component
public class RedisMessageSubscriber implements MessageListener {

    @Autowired
    private MessageProcessor messageProcessor;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String channel = new String(message.getChannel());
        String body = new String(message.getBody());
        log.info("@@ 当前执行的方法：onMessage");
        // 处理消息
        messageProcessor.processMessage(channel, body);
    }

}

创建消息处理器

创建一个处理接收到的消息的Bean。

package com.example.demo.redis;
import org.springframework.stereotype.Service;

@Service
public class MessageProcessor {

    public void processMessage(String channel, String message) {
        System.out.println("Received message: " + message + " from channel: " + channel);
        // 在这里进行具体的消息处理逻辑
    }
}

创建消息发送者

创建一个发送消息的Bean。

Redis有两种发布/订阅模式：

  • 基于频道(Channel)的发布/订阅
  • 基于模式(pattern)的发布/订阅
package com.example.demo.redis;// RedisMessagePublisher.java

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

@Component
public class RedisMessagePublisher {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    public void publishMessage(String channel, String message) {
    
        // 基于模式(pattern)的发布/订阅
        // redisTemplate.convertAndSend("your-pattern-channel-1", "Hello, Redis!");
        
        // 基于频道(Channel)的发布/订阅
        redisTemplate.convertAndSend(channel, message);
        
    }
}

使用消息发送者发送消息

在需要发送消息的地方注入RedisMessagePublisher并使用它来发送消息。

package com.example.demo.redis;// MessageController.java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/api/message")
public class MessageController {

    @Autowired
    private RedisMessagePublisher messagePublisher;

    @GetMapping("/send")
    public String sendMessage(@RequestParam(value = "channel") String channel , @RequestParam(value = "messgage") String messgage) {
        messagePublisher.publishMessage("your-channel", "Hello, Redis!");
        messagePublisher.publishMessage(channel, messgage);
        return "Message sent successfully!";
    }
}

相关原理说明

  • 发布/订阅模型： Redis提供了一种发布/订阅（Pub/Sub）模型，其中消息发送者（发布者）将消息发送到一个或多个通道，而消息接收者（订阅者）则监听一个或多个通道以接收消息。
  • 消息监听器： RedisMessageSubscriber 实现了 MessageListener 接口，它监听指定通道上的消息。在这里，我们将接收到的消息传递给 MessageProcessor 进行处理。
  • 消息处理器： MessageProcessor 是一个简单的服务，用于处理接收到的消息。在实际应用中，你可以在这里添加业务逻辑来处理消息。
  • 消息发布者： RedisMessagePublisher 用于发布消息到指定的通道。在 sendMessage 方法中，我们使用 convertAndSend 方法将消息发送到名为 “your-channel” 的通道。
  • 消息发送端点： MessageController 是一个简单的REST控制器，用于触发消息发送。在这里，我们通过调用 messagePublisher.publishMessage 来发送消息。

总体来说，这个实现充分利用了Redis的发布/订阅功能，通过将消息发送者、消息接收者和消息处理器分离，使系统更加模块化和灵活。

RedisConfig配置

package com.example.demo.redis;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;

@Slf4j
@Configuration
public class RedisConfig {

    /**
     * 配置订阅
     * 基于MessageListenerAdapter和RedisMessageListenerContainer
     * @param redisMessageSubscriber
     * @return
     */
    @Bean
    public MessageListenerAdapter messageListenerAdapter(RedisMessageSubscriber redisMessageSubscriber) {
        return new MessageListenerAdapter(redisMessageSubscriber, "handleMessage");
    }

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(
            RedisConnectionFactory connectionFactory,
            MessageListenerAdapter messageListenerAdapter
    ) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        // 添加消息监听器和监听的频道
        // 基于频道的发布/订阅：
        container.addMessageListener(messageListenerAdapter, new ChannelTopic("your-channel"));

        // 基于模式的发布/订阅：
        container.addMessageListener(messageListenerAdapter, new PatternTopic("your-pattern-*"));
        return container;
    }

    /**
     * 基于MessageListener的配置
     * 直接使用RedisMessageSubscriber
     * @param connectionFactory
     * @param redisMessageSubscriber
     * @return
     */
    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(
            RedisConnectionFactory connectionFactory,  RedisMessageSubscriber redisMessageSubscriber) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);

        // 在这里设置你的动态频道名称，可以从配置文件或其他地方获取
        String dynamicChannel = "your-channel";

        // 基于频道的发布/订阅：
        ChannelTopic channelTopic = new ChannelTopic(dynamicChannel);

        // 基于模式的发布/订阅：
        // container.addMessageListener(redisMessageSubscriber, new PatternTopic("your-pattern-*"));

        // 添加消息监听器和监听的动态频道
        container.addMessageListener(redisMessageSubscriber, channelTopic);

        return container;
    }


//    /**
//     * 多频道示例
//     * @param connectionFactory
//     * @param redisMessageSubscriber
//     * @return
//     */
//    @Bean
//    public RedisMessageListenerContainer redisMessageListenerContainerMoreTopic(
//            RedisConnectionFactory connectionFactory,
//            RedisMessageSubscriber redisMessageSubscriber
//    ) {
//        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
//        container.setConnectionFactory(connectionFactory);
//
//        // 在这里设置你的动态频道名称列表，可以从配置文件或其他地方获取
//        List<String> dynamicChannels = Arrays.asList("channel1", "channel2", "channel3");
//
//        // 创建包含所有频道的ChannelTopic列表
//        List<ChannelTopic> channelTopics = createChannelTopics(dynamicChannels);
//
//        // 添加消息监听器和监听的多个频道
//        for (ChannelTopic channelTopic : channelTopics) {
//            container.addMessageListener(redisMessageSubscriber, channelTopic);
//        }
//
//        return container;
//    }
//
//    private List<ChannelTopic> createChannelTopics(List<String> channelNames) {
//        // 使用动态频道名称创建ChannelTopic列表
//        List<ChannelTopic> channelTopics = new ArrayList<>();
//        for (String channelName : channelNames) {
//            channelTopics.add(new ChannelTopic(channelName));
//        }
//        return channelTopics;
//    }
}

这段代码是用于配置并创建 RedisMessageListenerContainer 的方法。RedisMessageListenerContainer 是 Spring Data Redis 提供的一个用于监听 Redis 消息的容器。以下是对代码的详细解释：

方法签名

  • RedisConnectionFactory connectionFactory：这是用于创建 Redis 连接的工厂。
  • RedisMessageSubscriber redisMessageSubscriber：这是一个 Redis 消息订阅者，用于处理接收到的消息。

创建 RedisMessageListenerContainer 实例

RedisMessageListenerContainer container = new RedisMessageListenerContainer(); 
container.setConnectionFactory(connectionFactory);
  • 创建一个新的 RedisMessageListenerContainer 实例。
  • 将 connectionFactory 设置为容器的连接工厂，用于创建连接到 Redis 的连接。

设置动态频道名称

String dynamicChannel = "your-channel";
  • 定义一个动态频道名称，可以从配置文件或其他地方获取。

创建 ChannelTopic 对象

ChannelTopic channelTopic = new ChannelTopic(dynamicChannel);
  • 创建一个 ChannelTopic 对象，表示基于频道的发布/订阅，其中 dynamicChannel 是频道名称。

添加消息监听器和频道

container.addMessageListener(redisMessageSubscriber, channelTopic);
  • 将 redisMessageSubscriber 添加为消息监听器，用于处理接收到的消息。
  • 指定要监听的频道，这里使用了基于频道的发布/订阅模式。

返回 RedisMessageListenerContainer 实例

return container;
  • 返回配置好的 RedisMessageListenerContainer 实例。

通过以上步骤，这段代码的目的是创建一个配置好的 RedisMessageListenerContainer，该容器已设置好连接工厂、消息监听器以及要监听的动态频道。当 Redis 中的指定频道发布消息时，redisMessageSubscriber 的 onMessage 方法将被调用来处理消息。这是一种基于频道的发布/订阅模式，允许应用程序实时地接收并处理消息。

自定义监听的回调函数

创建消息接收者

不需要实现MessageListener接口

package com.example.demo.redis;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 自定义的监听类
 */
@Slf4j
@Component
public class RedisMessageCustomSubscriber {

    @Autowired
    private MessageProcessor messageProcessor;

    /**
     * 自定义的回调函数
     * @param message
     * @param channel
     */
    public void handleMessage(String message, String channel) {
        log.info("@@ 当前执行的方法：handleMessage");
        messageProcessor.processMessage(channel, message);
    }
}

RedisConfig配置

package com.example.demo.redis;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;

@Slf4j
@Configuration
public class RedisConfig {

    /**
     * 配置订阅
     * 基于MessageListenerAdapter和RedisMessageListenerContainer
     * @param redisMessageSubscriber
     * @return
     */
    @Bean
    public MessageListenerAdapter messageListenerAdapter(RedisMessageSubscriber redisMessageSubscriber) {
        return new MessageListenerAdapter(redisMessageSubscriber, "handleMessage");
    }

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(
            RedisConnectionFactory connectionFactory,
            MessageListenerAdapter messageListenerAdapter
    ) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        // 添加消息监听器和监听的频道
        // 基于频道的发布/订阅：
        container.addMessageListener(messageListenerAdapter, new ChannelTopic("your-channel"));

        // 基于模式的发布/订阅：
        container.addMessageListener(messageListenerAdapter, new PatternTopic("your-pattern-*"));
        return container;
    }

//    /**
//     * 基于MessageListener的配置
//     * 直接使用RedisMessageSubscriber
//     * @param connectionFactory
//     * @param redisMessageSubscriber
//     * @return
//     */
//    @Bean
//    public RedisMessageListenerContainer redisMessageListenerContainer(
//            RedisConnectionFactory connectionFactory,  RedisMessageSubscriber redisMessageSubscriber) {
//
//        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
//        container.setConnectionFactory(connectionFactory);
//
//        // 在这里设置你的动态频道名称，可以从配置文件或其他地方获取
//        String dynamicChannel = "your-channel";
//
//        // 基于频道的发布/订阅：
//        ChannelTopic channelTopic = new ChannelTopic(dynamicChannel);
//
//        // 基于模式的发布/订阅：
//        // container.addMessageListener(redisMessageSubscriber, new PatternTopic("your-pattern-*"));
//
//        // 添加消息监听器和监听的动态频道
//        container.addMessageListener(redisMessageSubscriber, channelTopic);
//
//        return container;
//    }

//    /**
//     * 多频道示例
//     * @param connectionFactory
//     * @param redisMessageSubscriber
//     * @return
//     */
//    @Bean
//    public RedisMessageListenerContainer redisMessageListenerContainerMoreTopic(
//            RedisConnectionFactory connectionFactory,
//            RedisMessageSubscriber redisMessageSubscriber
//    ) {
//        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
//        container.setConnectionFactory(connectionFactory);
//
//        // 在这里设置你的动态频道名称列表，可以从配置文件或其他地方获取
//        List<String> dynamicChannels = Arrays.asList("channel1", "channel2", "channel3");
//
//        // 创建包含所有频道的ChannelTopic列表
//        List<ChannelTopic> channelTopics = createChannelTopics(dynamicChannels);
//
//        // 添加消息监听器和监听的多个频道
//        for (ChannelTopic channelTopic : channelTopics) {
//            container.addMessageListener(redisMessageSubscriber, channelTopic);
//        }
//
//        return container;
//    }
//
//    private List<ChannelTopic> createChannelTopics(List<String> channelNames) {
//        // 使用动态频道名称创建ChannelTopic列表
//        List<ChannelTopic> channelTopics = new ArrayList<>();
//        for (String channelName : channelNames) {
//            channelTopics.add(new ChannelTopic(channelName));
//        }
//        return channelTopics;
//    }
}

这段代码配置了两个 @Bean 方法，一个用于创建 MessageListenerAdapter 实例，另一个用于创建 RedisMessageListenerContainer 实例。以下是详细解释：

创建 MessageListenerAdapter 实例

@Bean
public MessageListenerAdapter messageListenerAdapter(RedisMessageSubscriber redisMessageSubscriber) {
    return new MessageListenerAdapter(redisMessageSubscriber, "handleMessage");
}
  • 通过 @Bean 注解创建一个 MessageListenerAdapter 实例。
  • 将 RedisMessageSubscriber 对象传递给构造函数，表示这个适配器将调用 RedisMessageSubscriber 的方法来处理消息。
  • 第二个参数 "handleMessage" 表示要调用的消息处理方法的名称。

创建 RedisMessageListenerContainer 实例

@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(
        RedisConnectionFactory connectionFactory,
        MessageListenerAdapter messageListenerAdapter
) {
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
  • 通过 @Bean 注解创建一个 RedisMessageListenerContainer 实例。
  • 将 RedisConnectionFactory 传递给构造函数，表示这个容器将使用的连接工厂。

添加消息监听器和频道

// 添加消息监听器和监听的频道
// 基于频道的发布/订阅：
container.addMessageListener(messageListenerAdapter, new ChannelTopic("your-channel"));

// 基于模式的发布/订阅：
container.addMessageListener(messageListenerAdapter, new PatternTopic("your-pattern-*"));
  • 使用 container.addMessageListener 方法添加消息监听器（messageListenerAdapter）。
  • 第一个参数是消息监听器适配器，它会调用 RedisMessageSubscriber 的 handleMessage 方法来处理消息。
  • 第二个参数是 ChannelTopic 对象，表示基于频道的发布/订阅模式，监听指定的频道。
  • 第三个参数是 PatternTopic 对象，表示基于模式的发布/订阅模式，监听指定模式的频道。

返回 RedisMessageListenerContainer 实例

return container;
  • 返回配置好的 RedisMessageListenerContainer 实例。

通过这样的配置，RedisMessageListenerContainer 已经设置好了连接工厂和消息监听器，并分别基于频道和基于模式的发布/订阅模式来监听相应的消息。当 Redis 中的指定频道发布消息时，handleMessage 方法将被调用来处理消息。

区别

MessageListenerAdapter 和 RedisMessageListenerContainer 是 Spring Data Redis 提供的两个重要组件，用于实现 Redis 消息监听的机制。

MessageListenerAdapter

MessageListenerAdapter 是一个适配器，用于将普通的 Java 对象（POJO）转换为 Redis 消息监听器。它通过反射调用目标对象的方法来处理接收到的消息。在你的 POJO 类中，你可以定义一个或多个方法来处理不同类型的消息。

主要特点和用法：

  • 将普通的 Java 对象转换为 Redis 的消息监听器。
  • 可以指定调用目标对象的特定方法来处理消息。
  • 通过设置消息转换器，可以支持多种消息格式，如 JSON、XML 等。
  • 提供了一种简化消息处理逻辑的方式，避免了直接实现 MessageListener 接口的繁琐性。

RedisMessageListenerContainer

RedisMessageListenerContainer 是 Spring 提供的容器，用于管理 Redis 消息的监听器。它可以注册一个或多个消息监听器，并在接收到消息时调用相应的处理方法。该容器还负责管理连接到 Redis 的连接工厂，以及监听的频道或模式。

主要特点和用法：

  • 管理 Redis 连接工厂，确保连接的创建和关闭。
  • 注册消息监听器，并在接收到消息时调用相应的处理方法。
  • 支持基于频道和基于模式的发布/订阅模式。
  • 提供了灵活的配置选项，如消息转换器、错误处理器等。

总体而言，MessageListenerAdapter 和 RedisMessageListenerContainer 是一对重要的组件，它们使得在 Spring 应用中实现 Redis 消息监听变得更加简单和灵活。

​

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

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

相关文章

C++八股总结（不间断更新）

C++八股总结（不间断更新）

数据类型和大小&#xff08;32位和64位&#xff09; char&#xff1a;1字节 1字节 short&#xff1a;2字节 2字节 int&#xff1a;4字节 4字节 long&#xff1a;4字节 8字节 long long&#xff1a;8字节 8字节 new-delete malloc-free new是C中的关键字。new可以根据动态分配内…
阅读更多...
中等职业学校新媒体一键分发软件实训室解决方案

中等职业学校新媒体一键分发软件实训室解决方案

一、产品介绍 新媒体一键分发软件实训平台是专为中等职业学校设计&#xff0c;以满足新媒体运营、营销等岗位需求的教育解决方案。该平台通过模拟真实的新媒体工作环境&#xff0c;提供账号管理、内容编辑、一键分发等功能&#xff0c;使学生能够在实际操作中掌握新媒体技术的…
阅读更多...
Java 回顾方法的定义

Java 回顾方法的定义

一、方法的定义 1&#xff0e;修饰符&#xff08;public static…&#xff09;详见博客【Java 方法的定义】 2&#xff0e;返回值&#xff08;int, double, char[],…., void&#xff09;详见博客【Java 方法的定义】 3. break&#xff1a;跳出switch 结束循环&#xff0c;详…
阅读更多...
西门子S7协议(PROFINET端口)转罗克韦尔AB的Ethernet/IP网络通讯

西门子S7协议(PROFINET端口)转罗克韦尔AB的Ethernet/IP网络通讯

智能网关IGT-DSER支持多种PLC之间、PLC与智能仪表之间多对多通讯&#xff0c;支持以太网&#xff0c;串口设备混合数据交换&#xff1b;无需PLC内编程开发&#xff0c;只需在智能网关的参数管理软件上配置数据的起始地址和数量即可&#xff0c;支持热插拔&#xff0c;断电断网后…
阅读更多...
gazebo 中车子静态（不设置速度）滑动的问题

gazebo 中车子静态（不设置速度）滑动的问题

目录 写在前面的话&#xff08;重要&#xff01;&#xff01;&#xff01;&#xff09;gazebo中的参数设置设置启动小车的初始姿态 发现车子与地面的接触点有问题&#xff08;关键&#xff01;&#xff01;&#xff01;&#xff09;查看接触点的步骤&#xff1a;原始车轮设置原…
阅读更多...
实现mini-redis字符串操作

实现mini-redis字符串操作

写在文章开头 在之前的系列文章中&#xff0c;我们通过命令行模式完成了mini-redis解析和处理指令的执行基调&#xff0c;这篇文章笔者将对mini-redis中存储字符串的set和get指令的设计和实现进行分析讲解&#xff0c;希望对你了解mini-redis有所帮助。 Hi&#xff0c;我是 sh…
阅读更多...
94 、k8s之rbac

94 、k8s之rbac

一、rbac----安全机制 赋权机制 集群是按照用户名进行登录&#xff0c;按照项目名称进行命名空间的分类。 配电云主站------62天 8个人 高温补贴 一主2从 user pdyzz pdyzz -n pdyzz 资源空间 pod数量 1.1、k8s的安全机制&#xff1a; apiserver------>集群内和外…
阅读更多...
S3C2440开发板点亮LED灯+PWM定时器

S3C2440开发板点亮LED灯+PWM定时器

目录 GPIO引脚和寄存器概述 点亮LED灯步骤 1.配置GPIO 2.点亮LED 设置引脚为输出 控制引脚电平 完整代码 PWM GPIO引脚和寄存器概述 GPIO端口&#xff1a; S3C2440的GPIO引脚可被配置为输入或输出&#xff08;控制LED的引脚通常配置为输出模式&#xff09;。寄存器&#…
阅读更多...
从LoRA到QLoRA：量化技术如何改变预训练模型的微调方式

从LoRA到QLoRA：量化技术如何改变预训练模型的微调方式

在现代人工智能的发展中&#xff0c;预训练语言模型&#xff08;LLM&#xff09;已成为各种自然语言处理任务中的关键技术。这些模型通常具有数十亿甚至数千亿的参数&#xff0c;因此需要巨大的计算和存储资源来进行微调。QLoRA提出了一种新方法&#xff0c;使得在单个48GB的GP…
阅读更多...
“这年头，只依赖上班，是赚不到钱的——揭秘如何利用AI开启赚钱新模式“

“这年头，只依赖上班，是赚不到钱的——揭秘如何利用AI开启赚钱新模式“

苹果&#xff0c;在AI时代终于要有大动作了。 反观国内华为&#xff0c;前段时间刚上线的新款平板MatePad Air也大放异彩&#xff0c;搭载AI助手&#xff0c;创新生产力。 像我这写文案的时常灵感枯竭&#xff0c;打开电脑却迟迟下不了手…而华为小艺帮写功能只需要输入指令就…
阅读更多...
【C\C++】Eigen初体验（VS Code编译）

【C\C++】Eigen初体验（VS Code编译）

Eigen Eigen 是一个高效的 C 库&#xff0c;专注于线性代数运算。PCL 使用 Eigen 来处理矩阵和向量运算&#xff0c;特别是在点云数据的变换、配准和特征计算等方面。Eigen 提供了高效的矩阵运算功能&#xff0c;使得 PCL 在处理大规模点云数据时能够保持高性能。 Eigen 使用…
阅读更多...
如何使用Chainlit让所有网站快速嵌入一个AI聊天助手Copilot

如何使用Chainlit让所有网站快速嵌入一个AI聊天助手Copilot

Copilot 副驾驶 Software Copilot 是嵌入到您的应用/产品中的一种新型助手。它们旨在通过提供情境指导并代表用户采取行动来帮助用户充分利用您的应用。 支持的功能 信息流媒体元素声音的询问用户聊天记录聊天资料反馈✅✅✅✅✅❌✅✅ 嵌入 Copilot 首先&#xff0c;确保您…
阅读更多...
团队协作必备：2025年10大企业知识库管理系统工具推荐

团队协作必备：2025年10大企业知识库管理系统工具推荐

2025年团队协作知识库工具合集TOP 10 在团队协作和知识管理日益重要的今天&#xff0c;选择一款高效、灵活的知识库工具对于提升工作效率至关重要。以下是精心挑选的2025年团队协作知识库工具合集TOP 10&#xff0c;每款工具都具备独特的功能和优势&#xff0c;以满足不同团队…
阅读更多...
基于鸿蒙API10的RTSP播放器(一：基本界面的实现)

基于鸿蒙API10的RTSP播放器(一：基本界面的实现)

ijkplayer简介&#xff1a; ijkplayer 本身是一个开源的 Android 媒体播放库&#xff0c;它主要用于播放视频和音频文件&#xff0c;现在已有前辈将其引入到鸿蒙当中&#xff0c;通过XComponent组件完成适配。向开源致敬&#xff01; 支持格式&#xff1a; 它支持多种格式&…
阅读更多...
wine 麒麟系统运行Windows编译的exe

wine 麒麟系统运行Windows编译的exe

启动终端 首先，我们需要打开终端程序。 在终端中，输入以下命令： sudo apt-get update这个命令通常会要求输入密码，输入你的密码后，就可以继续执行了。 如果你想要切换到 root 用户，可以通过以下方法： su 用户名然后输入 root 用户的密码。 如果你想要重置 root 用户…
阅读更多...
网站如何防范BOT流量？

网站如何防范BOT流量？

随着互联网的快速发展&#xff0c;BOT流量已成为网络安全领域的一大隐患。BOT&#xff0c;即自动化程序&#xff0c;它们在网络中执行各种任务&#xff0c;包括数据抓取、恶意抢购、暴力破解等。这些行为不仅威胁到网站的正常运营&#xff0c;还可能造成数据泄露、经济损失等严…
阅读更多...
day20JS-axios数据通信

day20JS-axios数据通信

1. 什么是axios axios 是一个基于Promise 用于浏览器和 nodejs 的 HTTP 客户端&#xff0c;简单的理解就是ajax的封装&#xff0c;只不过它是Promise的实现版本。 特性&#xff1a; 从浏览器中创建 XMLHttpRequests从 node.js 创建 http 请求支持 Promise API拦截请求和响应转…
阅读更多...
零宽字符应用场景及前端解决方案

零宽字符应用场景及前端解决方案

零宽字符&#xff08;Zero Width Characters&#xff09;是一类在文本中不可见但具有特定功能的特殊字符。称为零宽字符&#xff0c;也叫幽灵字符。它们在显示时不占据任何空间&#xff0c;但在文本处理和显示中发挥着重要作用。这些字符主要包括零宽度空格、零宽度非连接符、零…
阅读更多...
【C++ 高频面试题】STL 你了解多少呢？vector 的底层实现原理

【C++ 高频面试题】STL 你了解多少呢？vector 的底层实现原理

文章目录 1. 常见的 STL 容器2.vector 和 list 的区别3. vector 的底层原理4. push_back() 和 emplace_back() 区别 1. 常见的 STL 容器 &#x1f34e;①序列容器 vector&#xff08;向量&#xff09;&#xff1a;是一个动态数组实现&#xff0c;提供高效的随机访问和在尾部进行…
阅读更多...
基于R语言结构方程模型分析与实践技术应用

基于R语言结构方程模型分析与实践技术应用

结构方程模型&#xff08;Sructural Equation Model&#xff09;是一种建立、估计和检验研究系统中多变量间因果关系的模型方法&#xff0c;它可以替代多元回归、因子分析、协方差分析等方法&#xff0c;利用图形化模型方式清晰展示研究系统中变量间的因果网络关系&#xff0c;…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023