1. 环境准备
确保你已经安装了 Redis 服务器，并且可以在本地或者远程访问它。如果你还没有安装 Redis，请先安装并启动 Redis 服务。
2. 创建 Spring Boot 项目
使用 Spring Initializr 或者其他 IDE 创建一个新的 Spring Boot 项目，并添加以下依赖：
-
Spring Data Redis -
Spring Web -
Lombok (可选)
在 pom.xml 文件中添加依赖：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
</dependencies>
3. 配置 Redis
在 application.properties 中配置 Redis 连接信息：
spring.redis.host=localhost
spring.redis.port=6379
4. 创建 Redis 消息模型
定义一个简单的 POJO 来表示登录成功消息：
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class LoginSuccessMessage {
private String username;
private long timestamp;
}
5. 配置 RedisTemplate
配置 RedisTemplate 来支持 LoginSuccessMessage 的序列化和反序列化：
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, LoginSuccessMessage> loginSuccessMessageRedisTemplate(RedisConnectionFactory connectionFactory) {
RedisTemplate<String, LoginSuccessMessage> template = new RedisTemplate<>();
template.setConnectionFactory(connectionFactory);
template.setKeySerializer(new StringRedisSerializer());
template.setValueSerializer(new Jackson2JsonRedisSerializer<>(LoginSuccessMessage.class));
return template;
}
}
6. 创建 Redis Publisher
创建一个服务类来负责发布消息到 Redis 通道：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
@Service
public class LoginPublisher {
private final RedisTemplate<String, LoginSuccessMessage> redisTemplate;
@Autowired
public LoginPublisher(RedisTemplate<String, LoginSuccessMessage> redisTemplate) {
this.redisTemplate = redisTemplate;
}
public void publishLoginSuccess(String username) {
LoginSuccessMessage message = new LoginSuccessMessage(username, System.currentTimeMillis());
redisTemplate.convertAndSend("login-success-channel", message);
}
}
7. 创建 Redis Subscriber
创建一个监听器来监听 Redis 通道的消息：
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;
@Component
public class LoginSubscriber implements MessageListener {
@Override
public void onMessage(Message message, byte[] pattern) {
// 消息处理逻辑...
}
@Autowired
private RedisTemplate<String, LoginSuccessMessage> redisTemplate;
}
8. 配置 Redis Channel Listener Container
配置 Redis Channel Listener Container 来监听特定的通道：
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.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
@Configuration
public class RedisSubscriberConfig {
@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter) {
// 容器配置逻辑...
}
// 其他 Bean 配置...
}
9. 使用 Publisher 发布消息
当用户登录成功后，可以调用 LoginPublisher 的 publishLoginSuccess 方法来发布消息：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class LoginController {
@Autowired
private LoginPublisher loginPublisher;
@PostMapping("/login")
public String handleLogin(@RequestBody LoginRequest request) {
// 登录逻辑...
return "Login processed.";
}
}
以上步骤将帮助你构建一个基本的 Spring Boot 应用程序，该应用程序可以使用 Redis 的发布/订阅功能来通知登录成功的事件。你可以根据实际需求扩展和修改这些代码片段。
👇关注我，下期了解👇 SpringBoot自动配置 
回复 222，获取Java面试题合集 关于我 一枚爱折腾的Java程序猿，专注Spring干货。把路上的问题记录下来，帮助那些和我一样的人。 好奇心强，喜欢并深入研究古天文。 崇尚 个人系统创建，做一些时间越长越有价值的事情。思考 把时间留下来 又 每刻都是新的。
本文由 mdnice 多平台发布
