京东价格监控软件开发技术探讨十五：通过酷Q和ZeroMQ实现推送变价变库消息到QQ群-程序员宅基地

技术标签：爬虫实战：电商采数令酷Q NetMQ

在对该需求展开进行说明前，我们需要先了解几个基本名词。

1、酷Q是什么？

简单来说，酷Q是一个QQ机器人软件，能在QQ群里回答、发布信息。相关的机器人软件比较多，如QQLight、

2、ZeroMQ是什么？

简单来说，ZeroMQ是一个网络层的数据通信组件，支持TCP或UDP发送数据。具体到C#，有一个NetMQ的组件，简单好用。

酷Q的使用就不多说了，可以加入酷Q官网或者相关技术群进行学习。

NetMQ的使用非常简单，我们需要创建一个服务端和一个客户端。服务端接收数据，客户端发送数据。

第一步：引用两个类库，AsyncIO和NetMQ，可直接在NuGet下载。

第二步：创建服务端，通过While（true）保持监听

using (NetMQSocket serverSocket = new ResponseSocket())
{
    serverSocket.Bind("tcp://127.0.0.1:5555");
    while (true)
    {
        string message1 = serverSocket.ReceiveFrameString();
        Console.WriteLine("Receive message :\r\n{0}\r\n", message1);
        string[] msg = message1.Split(':');
        string message = msg[1];

        serverSocket.SendFrame(message);
        if (message == "exit")
        {
            break;
        }
    }
}

第三步：创建客户端

 using (NetMQSocket clientSocket = new RequestSocket())
 {
    clientSocket.Connect("tcp://127.0.0.1:5555");
    string message = "Hello";
    clientSocket.SendFrame(num + ":" + message);

    string answer = clientSocket.ReceiveFrameString();
    Console.WriteLine("Answer from server:{0}", answer);
 }

需要特别注意的是，客户端必须接收服务端的回馈信息，否则会报异常。

上面三步就已经搭建起了基本的NetMQ通信框架。现在我们将这段代码移植到酷Q插件中去。

在插件加载的事件中，将酷QAPI的对象存储下来，然后创建一个NetMQHelper类，在该类的Push（方法名称随意）事件中，编写如下代码。

Task.Factory.StartNew(() =>
                {
                    using (this.Socket = new ResponseSocket($"@tcp://{Common.NetMQSrv}:{Common.ZeroMqPort}"))
                    {
                        BEnable = true;
                        while (BEnable)
                        {
                            //log.Info("ZeroMQ", "Execing");
                            string msg = this.Socket.ReceiveFrameString();
                            if (!string.IsNullOrEmpty(msg))
                            {
                                //log.Info("ZeroMQ", msg);
                                File.AppendAllText($@"{Common.RunDirectory}/Logs/NetMQ.log", $"{DateTime.Now} 收到 {msg}\r\n");
                                if (OnMessage != null)
                                {
                                    OnMessage(msg);
                                }

                            }
                            Socket.SendFrame(msg);
                            //Console.WriteLine("进行 线程" + Thread.CurrentThread.ManagedThreadId);
                        }
                    }
                }, TaskCreationOptions.LongRunning);

其中的OnMessage是一个代理事件，当通过NetMQ接收到数据后，可通过OnMessage和其它业务关联起来进行业务处理，比如调用酷Q的群消息推送。

操作原理就是这样了，赶紧去试试，不明白的可以加群一起讨论。在此说明下，插件的开发是使用的Native.SDK开发框架，在网上搜搜，此处就略过不表。

杀京东做最走心的电商舆情监控平台免费开源的价格监控软件欢迎加入QQ群415014949一起讨论

本文链接：https://blog.csdn.net/36/article/details/105427448

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

mysql sql语句引号_sql语句中单引号,双引号的处理方法-程序员宅基地

文章浏览阅读1.5k次。关于Insert字符串很多同学都在(单引号,双引号)这个方面发生了问题，其实主要是因为数据类型和变量在作怪。下面我们就分别讲述，虽然说的是Insert语句，但是Select、Update、Delete语句都是一样的。假如有下述表格：mytabe字段1 username 字符串型(姓名)字段2 age 数字型(年龄)字段3 birthday ..._sql单引号里的双引号取值

pandas 难以置信的多重索引2——获取多重索引的值（史上最全）_pandas多重索引取值-程序员宅基地

文章浏览阅读2.4w次，点赞14次，收藏45次。我们平时使用到的多重索引，但是网上很少有人介绍如果获取多重索引本身的值，这部分的内容比上一节更加实用获取多重索引的标签值get_level_values()方法将返回一个特定级别上每个位置的标签向量:iterables = [['bar', 'baz', 'foo', 'qux'], ['one', 'two']]arrays = pd.MultiIndex.from_product(iterables, names=['first', 'second'])arrays'''MultiInde_pandas多重索引取值

AllWinnerTech A10添加驱动ko模块方法_allwinner tech a10-程序员宅基地

文章浏览阅读3.8k次。【1】添加Linux触摸屏驱动：添加驱动代码文件：lichee\linux-2.6.36\drivers\input\touchscreen\mg-i2c-ts.clichee\linux-2.6.36\drivers\input\touchscreen\mg-i2c-ts.hkconfig文件lichee\linux-2.6.36\drivers\input\touchscree_allwinner tech a10

python入门教程完整版(懂中文就能学会)-Python入门教程完整版（懂中文就能学会）...-程序员宅基地

文章浏览阅读48次。不过小编的内心是强大的，网友虐我千百遍，我待网友如初恋，因为今天又给大家带来了干货，Python入门教程完整版，完整版啊！完整版！言归正传，小编该给大家介绍一下这套教程了，希望每个小伙伴都沉迷学习，无法自拔第一阶段：该阶段首先通过介绍不同领域的三种操作系统，操作系统的发展简史以及Linux系统的文件目录结构让大家对Linux系统有一个简单的认识，同时知道为什么要学习Linux命令。然后我们会正式学..._懂中文就能学会python

JAVA基础面试题-程序员宅基地

文章浏览阅读778次，点赞17次，收藏23次。（2）当我们试图把某个类的对象当成 HashMap的 key，或试图将这个类的对象放入 HashSet 中保存时，重写该类的equals(Object obj)方法和 hashCode() 方法很重要，而且这两个方法的返回值必须保持一致：当该类的两个的 hashCode() 返回值相同时，它们通过 equals() 方法比较也应该返回 true。简单来说，用户进程在发起一个IO操作以后，必须等待IO操作的完成，只有当真正完成了IO操作以后，用户进程才能运行，BIO方式适用于连接数目比较小且固定的架构。

RunTimeError:element 0 of tensors does not require grad and does not have a grad_fn_runtimeerror: element 0 of tensors does not requir-程序员宅基地

文章浏览阅读2.3k次。这个错误源于Pytorch对Tensor进行 backward() 自动求导时，该Tensor的requires_grad为False，requires_grad参数指定是否记录对Tensor的操作以便计算梯度。在创建Tensor时该参数默认为False，需要手动设置如下。也可以通过loss.requires_grad_(True)设置。_runtimeerror: element 0 of tensors does not require grad and does not have a