来源： VS2019无法获取本地变量或参数的值，因为它在此指令指针中不可用，可能是因为它已经被优化掉了。 – Mr、哈哈 – 博客园

在此指令指针中不可用，可能是因为它已经被优化掉了。

来源： 使用宝塔网站加速插件来加速网站速度，优化网站 – 知乎

产品简介

宝塔网站加速 是宝塔面板推出的一款网站加速插件，实测博客类网站加速效果很好。

原理是：在http协议层，对动态页面进行缓存，对需要实时信息及已登录的会话跳出缓存，此技术主要针对匿名访问的用户进行加速响应，以减少应用服务器和数据库的开销。

不同网站类型加速效果

内容型网站: 如wordpress, phpcms, 各类企业站，cms，博客，商城等有最佳加速效果

交互型网站: 如 discuz，HYBBS等效果良好

其它网站: 对纯静态、后台管理系统， 如 各类OA系统，API接口等没有加速的意义

使用教程：

只需简单几步，即可完成加速配置

宝塔控制面板出现切换Nginx版本出现错误，宝塔nginx启动不起来，无法正常启动出现错误提示，服务器上面的网站也打不开。

Nginx配置规则错误:

nginx: [emerg] open() “/www/server/nginx/conf/agent_deny.conf” failed (2: No such file or directory) in /www/server/panel/vhost/nginx/www.cuiruo.com.conf:71

nginx: configuration file /www/server/nginx/conf/nginx.conf test failed

在宝塔控制面板 > 文件 > /www/server/nginx/conf/ 目录下新建文件命名agent_deny.conf就解决了错误问题。

来源： FFmpeg循环推流脚本-荒岛

yum -y install screen

screen -S stream

#!/bin/bash
PATH=/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:/usr/local/sbin:~/bin
export PATH
#=================================================================#
#   System Required: CentOS7 X86_64                               #
#   Description: FFmpeg Stream Media Server                       #
#   Author: LALA                                    #
#   Website: https://www.lala.im                                  #
#=================================================================#

# 颜色选择
red='\033[0;31m'
green='\033[0;32m'
yellow='\033[0;33m'
font="\033[0m"

ffmpeg_install(){
# 安装FFMPEG
read -p "你的机器内是否已经安装过FFmpeg4.x?安装FFmpeg才能正常推流,是否现在安装FFmpeg?(yes/no):" Choose
if [ $Choose = "yes" ];then
	yum -y install wget
	wget --no-check-certificate https://www.johnvansickle.com/ffmpeg/old-releases/ffmpeg-4.0.3-64bit-static.tar.xz
	tar -xJf ffmpeg-4.0.3-64bit-static.tar.xz
	cd ffmpeg-4.0.3-64bit-static
	mv ffmpeg /usr/bin && mv ffprobe /usr/bin && mv qt-faststart /usr/bin && mv ffmpeg-10bit /usr/bin
fi
if [ $Choose = "no" ]
then
    echo -e "${yellow} 你选择不安装FFmpeg,请确定你的机器内已经自行安装过FFmpeg,否则程序无法正常工作! ${font}"
    sleep 2
fi
	}

stream_start(){
# 定义推流地址和推流码
read -p "输入你的推流地址和推流码(rtmp协议):" rtmp

# 判断用户输入的地址是否合法
if [[ $rtmp =~ "rtmp://" ]];then
	echo -e "${green} 推流地址输入正确,程序将进行下一步操作. ${font}"
  	sleep 2
	else  
  	echo -e "${red} 你输入的地址不合法,请重新运行程序并输入! ${font}"
  	exit 1
fi 

# 定义视频存放目录
read -p "输入你的视频存放目录 (格式仅支持mp4,并且要绝对路径,例如/opt/video):" folder

# 判断是否需要添加水印
read -p "是否需要为视频添加水印?水印位置默认在右上方,需要较好CPU支持(yes/no):" watermark
if [ $watermark = "yes" ];then
	read -p "输入你的水印图片存放绝对路径,例如/opt/image/watermark.jpg (格式支持jpg/png/bmp):" image
	echo -e "${yellow} 添加水印完成,程序将开始推流. ${font}"
	# 循环
	while true
	do
		cd $folder
		for video in $(ls *.mp4)
		do
		ffmpeg -re -i "$video" -i "$image" -filter_complex overlay=W-w-5:5 -c:v libx264 -c:a aac -b:a 192k -strict -2 -f flv ${rtmp}
		done
	done
fi
if [ $watermark = "no" ]
then
    echo -e "${yellow} 你选择不添加水印,程序将开始推流. ${font}"
    # 循环
	while true
	do
		cd $folder
		for video in $(ls *.mp4)
		do
		ffmpeg -re -i "$video" -c:v copy -c:a aac -b:a 192k -strict -2 -f flv ${rtmp}
		done
	done
fi
	}

# 停止推流
stream_stop(){
	screen -S stream -X quit
	killall ffmpeg
	}

# 开始菜单设置
echo -e "${yellow} CentOS7 X86_64 FFmpeg无人值守循环推流 For LALA.IM ${font}"
echo -e "${red} 请确定此脚本目前是在screen窗口内运行的! ${font}"
echo -e "${green} 1.安装FFmpeg (机器要安装FFmpeg才能正常推流) ${font}"
echo -e "${green} 2.开始无人值守循环推流 ${font}"
echo -e "${green} 3.停止推流 ${font}"
start_menu(){
    read -p "请输入数字(1-3),选择你要进行的操作:" num
    case "$num" in
        1)
        ffmpeg_install
        ;;
        2)
        stream_start
        ;;
        3)
        stream_stop
        ;;
        *)
        echo -e "${red} 请输入正确的数字 (1-3) ${font}"
        ;;
    esac
	}

# 运行开始菜单
start_menu

来源： C#单元测试，带你快速入门 – 农码一生 – 博客园

C#单元测试，带你快速入门

public class Arithmetic
{
    public int Add(int nb1, int nb2)
    {
        return nb1 + nb2;
    }
}

public class Arithmetic_Tests
{
    [Fact]//需要在测试方法加上特性Fact
    public void Add_Ok()
    {
        Arithmetic arithmetic = new Arithmetic();
        var sum = arithmetic.Add(1, 2);
        
        Assert.True(sum == 3);//断言验证
    }
}

[Theory]
[InlineData(2, 3, 5)]
[InlineData(2, 4, 6)]
[InlineData(2, 1, 3)] //对应测试方法的形参
public void Add_Ok_Two(int nb1, int nb2, int result)
{
    Arithmetic arithmetic = new Arithmetic();
    var sum = arithmetic.Add(nb1, nb2);
    Assert.True(sum == result);
}

[Theory]
[InlineData(2, 3, 0)]
[InlineData(2, 4, 0)]
[InlineData(2, 1, 0)] 
public void Add_No(int nb1, int nb2, int result)
{
    Arithmetic arithmetic = new Arithmetic();
    var sum = arithmetic.Add(nb1, nb2);
    Assert.False(sum == result);
}

public int Divide(int nb1, int nb2)
{
    if (nb2==0)
    {
        throw new Exception("除数不能为零");
    }
    return nb1 / nb2;
}

[Fact]      
public void Divide_Err()
{
    Arithmetic arithmetic = new Arithmetic(); 
    Assert.Throws<Exception>(() => { arithmetic.Divide(4, 0); });//断言 验证异常
}

public class StudentRepositories
{
    //...
    public void Add(Student model)
    {
        db.Set<Student>().Add(model);
        db.SaveChanges();
    }
}

[Fact]
public void Add_Ok()
{
    StudentRepositories r = new StudentRepositories();
    Student student = new Student()
    {
        Id = 1,
        Name = "张三"
    };
    r.Add(student);

    var model = r.Students.Where(t => t.Name == "张三").FirstOrDefault();
    Assert.True(model != null);           
}

//注意：测试类要继承IDisposable接口
public void Dispose()
{
 StudentRepositories r = new StudentRepositories();
 var models = r.Students.ToList();
 foreach (var item in models)
 {
     r.Delete(item.Id);
 }
}

 public interface IStudentRepositories
 {
     void Add(Student model);
 }
 public class StudentRepositories: IStudentRepositories
 {
    //省略。。。 （还是原来的实现）
 }   

public class StudentService
{
    IStudentRepositories studentRepositories;
    public StudentService(IStudentRepositories studentRepositories)
    {
        this.studentRepositories = studentRepositories;
    }
    public bool Create(Student student)
    {
        studentRepositories.Add(student);

        return true;
    }
}

[Fact]
public void Create_Ok()
{
    IStudentRepositories studentRepositories = new StubStudentRepositories();
    StudentService service = new StudentService(studentRepositories);
    var isCreateOk = service.Create(null);
    Assert.True(isCreateOk);
}

public class StubStudentRepositories : IStudentRepositories
{
    public void Add(Student model)
    {
    }
}

[Fact]
public void Create_Mock_Ok()
{
    var studentRepositories = new Mock<IStudentRepositories>();
    var notiy = new Mock<Notiy>();
    StudentService service = new StudentService(studentRepositories.Object);
    var isCreateOk = service.Create(null);
    Assert.True(isCreateOk);
}

public class Notiy
{
    public bool Info(string messg)
    {
        //发送消息、邮件发送、短信发送。。。
        //.........
        if (string.IsNullOrWhiteSpace(messg))
        {
            return false;
        }
        return true;
    }
}

public class Notiy_Tests
{
    [Fact]
    public void Info_Ok()
    {
        Notiy notiy = new Notiy();
        var isNotiyOk = notiy.Info("消息发送成功");
        Assert.True(isNotiyOk);
    }
}

public bool Create(Student student)
{
    studentRepositories.Add(student);

    var isNotiyOk = notiy.Info("" + student.Name);//消息通知

    //其他一些逻辑
    return isNotiyOk;
}

[Fact]
public void Create_Mock_Notiy_Ok()
{
    var studentRepositories = new Mock<IStudentRepositories>();
    var notiy = new Mock<Notiy>();
    StudentService service = new StudentService(studentRepositories.Object, notiy.Object);
    var isCreateOk = service.Create(new Student());
    Assert.True(isCreateOk);
}

public virtual bool Info(string messg)
{
    //发送消息、邮件发送、短信发送。。。
    //.........
    if (string.IsNullOrWhiteSpace(messg))
    {
        return false;
    }
    return true;
}

[Fact]
public void Create_Mock_Notiy_Ok()
{
    var studentRepositories = new Mock<IStudentRepositories>();
    var notiy = new Mock<Notiy>();
    notiy.Setup(f => f.Info(It.IsAny<string>())).Returns(true);//【1】
    StudentService service = new StudentService(studentRepositories.Object, notiy.Object);
    var isCreateOk = service.CreateAndNotiy(new Student());
    Assert.True(isCreateOk);
}

notiy.Setup(f => f.Info("")).Returns(false);
notiy.Setup(f => f.Info("消息通知")).Returns(true);

private bool XXXInit()
{
    return true;
}

[Fact]
public void XXXInit_Ok()
{
    var studentRepositories = new StudentService();
    var obj = new Microsoft.VisualStudio.TestTools.UnitTesting.PrivateObject(studentRepositories);
    Assert.True((bool)obj.Invoke("XXXInit"));
}

来源： 推荐一款 在线+离线数据 同步框架 Dotmim.Sync – 张善友 – 博客园

 LODOP打印提示“有窗口已经打开”，无法继续打印

首先点击“设置”，看下当前选择的共享打印机是否正确可用，选正确可用的打印机，否则会提示窗口已打开后，不显示窗口，并且半天后才弹出预览窗口

1、把电脑浏览器左下角或者右下角隐藏的预览窗口关了

来源： Debug模式下，无法获取本地变量或参数的值，因为它在此指令指针中不可用，可能是因为它已经被优化掉了_IT流渊的博客-CSDN博客

Debug模式下，调试中，无法查看变量值；
提示：无法获取本地变量或参数的值，因为它在此指令指针中不可用，可能是因为它已经被优化掉了

解决方法：
在项目属性的生成选项卡里-“优化代码”，不用打勾！

来源： 程序员开发正遭 AI 「革命」_CSDN资讯的博客-CSDN博客

【CSDN 编者按】AI，一个可以让人充满无限想象力的技术。近年来，随着 GPT-3、BERT 等大语言模型的崛起，以及昨日最新 Stable Diffusion 2.0 开源文本图像模型的发布，也让很多「所想即所得」的应用场景逐渐成为现实。反观其背后，技术人在推动 AI 落地的过程中，包括自身的开发习惯、方式等也正被 AI 重置。

作者 | 卞安 责编 | 屠敏

出品 | CSDN（ID：CSDNnews）

AI 作画，作为一个局部领域的产品方向，在基于机器学习算法基础上，为世界打开了一扇大门，随着 AI 作画类软件的大放异彩，基于 AI 进行内容生产话题也越来越受到关注。

作为一名程序员，我们又应该怎么来看待 AI 的这些成果对于开发方式的影响，在此，笔者有幸受邀为各位小伙伴分享一下个人的看法。

在美国科罗拉多州艺术博览会上基于 Midjourney 获奖的 AI 画作《太空歌剧院》

AI 将改写程序员的开发方式

AI 的底层算法一般是基于神经网络进行建模，通过在神经元上的数学算法不断的训练数据调整建模，使误差向最小靠近的过程。这是一种非常酷的思维方式，它使得计算机可以通过算法寻找到数据变化的趋势。在此基础上发展起来的生成对抗网络，使得计算机学习和模仿数字化内容变的更加可信，这些数字化内容不但包括文本（新闻和小说生成）、图像（AI绘图与视频），3D 模型（AI 生成游戏场景），也包括编程代码和文档。

虽然我们目前还没有能够走到直接通过 AI 来生成完整的项目的地步，但在 AI 大发展的背景下，如何高效、快速、更好的达到编程目标，正在成为解决问题中一个重要的考虑因素。

我们可以对比 AI 的工作原理，反思编程工作中的痛点，预测一些潜在的可能性，也许未来这些可能性会极大的推动我们的编程和工作方式。

从工作形态的进化趋势上来看，预期会分为三个阶段：

第一阶段：编码工作的辅助智能化
这一阶段的主要体现是：通过搜集、归类、梳理编程开发项目中大量的可复用部分（如算法、功能函数或模块）形成数据集，通过对输入意向和数据集进行训练和学习的方式，形成优良的辅助功能，提升程序员的开发效率。

在具体实践上，一些企业已经推出了相关工具类产品：

GitHub Copilot : 通过语音输入指令让 IDE 自动提示并生成代码。

Copilot 是 GitHub 今年早些时候推出的人工智能编程辅助工具，2022 年 6 月 22 日已正式上线（https://github.com/features/copilot），定价每月 10 美元（约 66.9 元人民币）或每年 100 美元（约 669 元人民币），对学生用户和流行开源项目的维护者免费提供。

经过数十亿行代码的训练，它可以将自然语言提示转化为数十种语言的编码建议，支持 Python、JavaScript、TypeScript、Java、Ruby 和 Go 等编程语言。根据今年 GitHub Universe 开发者大会报告给出的数据，Copilot 已经通过基于 AI 的编码建议，帮助全球开发者的工作效率提高了 55%。

2. GodeGeeX：通过输入文字描述让 IDE 自动提示并生成代码。

与此相近的一款国产工具叫做 GodeGeeX（https://models.aminer.cn/codegeex/），来自清华大学知识工程实验证（KEG），CodeGeeX 是一款具有 130 亿参数的多语言代码生成模型，采用华为 MindSpore 框架实现，在鹏城实验室“鹏城云脑II”中的 192 个节点（共 1536 个国产昇腾 910 AI 处理器）上训练而成。

截至 2022 年 6 月 22 日，CodeGeeX 历时两个月在 20 多种编程语言的代码语料库（>8500 亿 Token）上预训练得到。它可以跟据你的描述，或者上下文自动生成一段代码，和以往的代码补全功能是完成不同的。目前支持 Python、C++、Java、JavaScript、Go 五种主流编程语言，而且在准确度上表现较好。

除此之外，还有 Kite、Codota、DeepCode 等一些基于机器学习的 AI 代码生成工具，本质上都是通过大量的代码训练，来智能预测出需要生成的代码，加快编程的效率。

总体来说，这一阶段的产品推动者不需要面向业务，只需要考虑面向程序员，可以达到辅助程序员提升业务开发速度的目标，也可以较好的通过工具化产品形成规范，解决企业的代码风格化统一问题。未来可能会广泛的成为程序员工作中的标配，程序员将不会再花大量的精力在高复用度的具体代码函数设计，而更多的把精力放在业务模块的设计实现。

第二阶段：业务模块的智能生成
这一阶段的主要体现是：通过搜集、归类、梳理相关领域业务开发项目中大量的通用业务（如游戏研发中的登录模块、热更新模块、聊天模块、战斗模块等业务逻辑）形成数据集，通过对业务设计意向和数据集进行训练和学习的方式，自动的进行业务模块前后端框架生成，优化工作流程，提升业务模块的产品设计迭代和研发速度。

我们可以通过一个实例工具软件来理解这个过程，Adobe 推出过的网页三剑客之一的 Dreamweave，其中提供了大量的模块生成功能，比如通过设定数据集和表单的控件对应关系，就可以生成前后端的代码，实际提供一个可以运行的业务模块。

当然，这是由没有结合人工智能辅助的情况，如果基于新的智能化生成，那我们在开发时，智能化生成模块会自动跟据上下文来提示是否需要生成相应的业务前后端模块，我们只需要再跟据生成的模块进行微调或扩展即可达到我们的要求。

下图是笔者使用 DreamWeaver 来生成一个简单的登录模块，只需要设定一下数据表字段，即可生成表单，完成登录判断和跳转功能。

又或者在游戏开发领域。作者曾在企业负责技术中台设计时，推动过面向各游戏项目组通用业务模块的抽象与开发，比如热更新、原生接口调用，甚至包括游戏战斗机制等大量的通用业务，对于每一个项目几乎都是需要的，只是因为技术栈或者界面的不同而需要重复的开发，这些工作往往耗时耗力。

站在一个更高的维度，这些业务完全可以基于机器学习训练结合需求变化被快速地进行调整而满足各个项目的使用。所以，基于企业的技术中台，把这些通用业务的统一框架和智能化定制与人工智能结合，基于主流开发软件、引擎工具或平台工具推出可实际操作的软件或插件。从而形成更好的开发工作流是非常有意义的。

这个阶段目前是各领域企业争相降本增效的方向之一，程序员的工作正在进一步从通用业务开发中解放，而把更多的把精力放在具体产品的需求上。

第三阶段：产品原型的智能生成
这一阶段主要体现是：通过对产品研发工作流中可智能化生成的部分进行整合和优化，达到能够根据用户需求自动的生成具备完整功能逻辑和效果表现的产品项目原型的目标，帮助产品经理快速看到期望的结果。

这里以几个案例加以说明：

一、市场上大量自助建网站，电商小程序类的平台。

这些平台直接面向用户方，提供给用户可以自助订制化的业务模块并生成最终产品的服务。如腾讯云的自助式建站：

这些平台虽然具备直接生成最终产品的能力，但其底层逻辑主要是基于一定数量的前后端模板和风格模板进行组合，通过固化的需求条目选项得到产品各模板模块的组合结果，产品的领域有限、形态有限、规模有限，目前大部分不具备通过对用户需求分析和产品形态数据集进行机器学习来生成目标产品的能力。

在数字人研发企业里，目前已经在通过对人脸照片，动作视频采用人物脸部识别，动作识别技术来建立模型数据集，通过机器学习对三维模型重建和自动动作绑定，快速化生产高精度数字人，这种方式与以往通过美术建模，手动绑定骨骼及人物动作的工作流有较大差别，它可以大大的加快数字人的生成效率、规模和精度。

在 GTC 大会上，黄仁勋宣布推出一个全方位的虚拟化身平台 —— Omniverse Avatar（来源：https://developer.nvidia.com/nvidia-omniverse-platform/ace）

二、在一些游戏方向，如剧情文字类游戏（AVG）领域，开发者也在通过剧本生成，二次元立绘生成类软件，通过脚本进行完整的游戏产品生产尝试，可以将原本需要几个月才能完成的剧情文字游戏，在短短几个小时内生成出来。

当然，这些方面的业务相对简单，但随着人工智能的发展，相信不久的未来，一个软件产品设计师可以通过提供一些简单的需求描述得到一个完整可运行的产品DEMO。它所要做的，是通过不断的修改需求描述来不断提交，得到期望的产品原型。

总结

最后，我想说的是，内容生成的算法目前在一些方面有了较大突破，但在软件开发领域，特别是开发者工具领域，我们也需要相关企业和创业者不断的结合这些突破，落地到具体的工具软件产品中来提升开发者的工作流程和体验，推出更好的产品形态，谁能够在未来提供更好的智能化内容生成体验，也就会在未来更受欢迎。

作者介绍：卞安，游戏引擎技术专家，CSDN 博客专家，独立软件创业者。从事游戏研发行业近二十年，孜孜不倦地学习和思考引擎研发技术和工具链设计，曾任端游企业引擎技术总监，Cocos 游戏引擎产品总监。目前在学习游戏引擎与 AI 的结合，致力于开发基于 Python 语言的全栈式开发工具软件产品《PyMe》。

————————————————
版权声明：本文为CSDN博主「CSDN资讯」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/csdnnews/article/details/128125034

来源： redis之mq实现发布订阅模式 – 云天 – 博客园

• 示例代码-github

概述

Redis不仅可作为缓存服务器，还可用作消息队列，本示例演示如何使用redis实现发布/订阅消息队列。

• 在Redis中，发布者没有将消息发送给特定订阅者的程序。相反，发布的消息被描述为通道，而不知道(如果有的话)可能有哪些订阅者。
• 订阅者表示对一个或多个主题感兴趣，只接收感兴趣的消息，而不知道(如果有的话)发布者是什么。
• 发布者和订阅者的这种解耦可以实现更大的可伸缩性和更动态的网络拓扑。

代码实现

redis实现mq的存储方式很多，可以使用list,zset及stream，这些数据的存储结构决定了怎么消费问题（消息是一次使用、允许多次使用、允许多端消息等），比如使用list，我们可以使用leftPush插入消息，使用rightPop消费消息，实现一条消息一次消息，可以参考与以示例代码：

    @Test
    public void testMq() {
        for (int i = 0; i < 10; i++) {
            redisTemplate.opsForList().leftPush("task-queue", "data" + i);
            log.info("插入了一个新的任务==>{}", "data" + i);
        }
        String taskId = redisTemplate.opsForList().rightPop("task-queue").toString();
        log.info("处理成功，清除任务==>{}", taskId);
    }

1.配置代码RedisConfig.java

package demo.data.mqRedis.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
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.core.StringRedisTemplate;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

    @Autowired
    private RedisTemplate redisTemplate;

    /**
     * redisTemplate 序列化使用的jdkSerializeable, 存储二进制字节码, 所以自定义序列化类,方便调试redis
     *
     * @param redisConnectionFactory
     * @return
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {

        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();

        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值
        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());

        //使用StringRedisSerializer来序列化和反序列化redis的ke
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());

        //开启事务
        redisTemplate.setEnableTransactionSupport(true);

        redisTemplate.setConnectionFactory(redisConnectionFactory);

        return redisTemplate;
    }

    @Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter(new RedisMessageSubscriber());
    }

    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                            MessageListenerAdapter listenerAdapter) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(listenerAdapter, topic());

        return container;
    }

    @Bean
    MessagePublisher redisPublisher() {
        return new RedisMessagePublisher(redisTemplate, topic());
    }

    @Bean
    ChannelTopic topic() {
        return new ChannelTopic("messageQueue");
    }
}

2.定义消息发布接口MessagePublisher.java

package demo.data.mqRedis.config;

public interface MessagePublisher {
    void publish(String message);
}

3.发布方实现RedisMessagePublisher.java

package demo.data.mqRedis.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.ChannelTopic;

/**
 * 消息发布方
 */
public class RedisMessagePublisher implements MessagePublisher {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @Autowired
    private ChannelTopic topic;

    public RedisMessagePublisher(
            RedisTemplate<String, Object> redisTemplate, ChannelTopic topic) {
        this.redisTemplate = redisTemplate;
        this.topic = topic;
    }

    public void publish(String message) {
        redisTemplate.convertAndSend(topic.getTopic(), message);
    }
}

4.消息接收方RedisMessageSubscriber.java

package demo.data.mqRedis.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;

/**
 * 消息订阅方
 */
@Service
@Slf4j
public class RedisMessageSubscriber implements MessageListener {

    public static List<String> messageList = new ArrayList<>();

    public void onMessage(Message message, byte[] pattern) {
        messageList.add(message.toString());
        log.info("订阅方接收到了消息==>{}", message.toString());
    }
}

5.最后贴上application.yml配置

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password:

查看运行结果

1.编写测试用例试发布消息TestRedisMQ.java

package demo.data.mqRedis;

import demo.data.mqRedis.config.RedisMessagePublisher;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.UUID;

@RunWith(SpringRunner.class)
@SpringBootTest
@Slf4j
public class TestRedisMQ {

    @Autowired
    RedisMessagePublisher redisMessagePublisher;

    @Test
    public void testMq() {
        String message = "Message " + UUID.randomUUID();
        redisMessagePublisher.publish(message);
    }
}

2.运行结果

2019-09-05 15:51:33.931  INFO 10772 --- [    container-2] d.d.m.config.RedisMessageSubscriber      : 订阅方接收到了消息==>"Message c95959bf-6c30-4801-bc80-0e1e3c9f81bc"

订阅方成功接收到消息了

资料

• 示例代码-github
• redis实现mq的方案以及stream的应用
• 发布-订阅模式