以下是在 WPF 下使用 FreeRedis 操作 Redis Stream 实现简单消息队列的步骤：
一、安装 FreeRedis
在你的 WPF 项目中通过 NuGet 包管理器安装FreeRedis库。
二、引入命名空间
在需要使用 Redis Stream 的代码文件中添加以下命名空间：
using FreeRedis;
三、创建 Redis 客户端连接
string redisConnectionString = "your_redis_connection_string"; var redisClient = new RedisClient(redisConnectionString);
请将your_redis_connection_string替换为你的实际 Redis 连接字符串。
四、发送消息到队列
string streamName = "myStream"; var message = new { data = "This is a test message" }; redisClient.XAdd(streamName, "*", message);
这里创建了一个名为myStream的流，并将一个包含测试消息的对象添加到流中。
五、从队列中接收消息
var messages = redisClient.XRead<string, dynamic>(streamName, new[] { "> " }, 1); if (messages!= null && messages.Count > 0) { foreach (var streamMessages in messages) { foreach (var item in streamMessages.List) { Console.WriteLine($"Received message: {item.Value.data}"); // 确认消息已处理 redisClient.XAck(streamName, "consumerGroup", item.Id); } } }
这段代码从流中读取消息，并在处理后确认消息已被处理。你可以根据实际情况修改消费者组名称。
六、关闭连接
在应用程序结束时，记得关闭 Redis 连接：
redisClient.Dispose();
通过以上步骤，你可以在 WPF 应用程序中使用 FreeRedis 操作 Redis Stream 实现简单的消息队列。请注意，在实际应用中，你可能需要处理更多的错误情况和并发访问等问题。
