src/sample/XXX.Plugin.ZeroMQ/Controller/ZeroMQController.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using NetMQ;
using NetMQ.Sockets;
using System.Net.Http.Json;
using System.NetPro;
using System.Text;

namespace XXX.Plugin.Tdengine
{
    /// <summary>
    /// zeromq Demo
    /// 81：发布订阅；82：推拉
    /// </summary>
    [ApiController]
    [Route("[controller]")]
    public class ZeroMQController : ControllerBase
    {
        private readonly ILogger<ZeroMQController> _logger;
        private readonly PublisherSocket _publisherSocket;
        private readonly PushSocket _pushSocket;
        private readonly static object _lock = new();//zeromq socket is thread-unsafe

        /// <summary>
        /// 
        /// </summary>
        /// <param name="logger"></param>
        /// <param name="publisherSocket"></param>
        /// <param name="pushSocket"></param>
        public ZeroMQController(
            ILogger<ZeroMQController> logger,
            PublisherSocket publisherSocket,
            PushSocket pushSocket
            )
        {
            _logger = logger;
            _publisherSocket = publisherSocket;
            _pushSocket = pushSocket;
        }

        /// <summary>
        /// 发布zeromq
        /// </summary>
        /// <returns></returns>
        [HttpGet("PublisherSocket")]
        [ProducesResponseType(200, Type = typeof(ResponseResult))]
        public IActionResult PublisherSocket()
        {
            lock (_lock)
            {
                _publisherSocket.SendMoreFrame("A:b") // Topic支持特殊符号，topic命名最佳实践：模块名/功能命/功能层级
                    .SendFrame(DateTimeOffset.Now.ToString());
            }


            return Ok();
        }

        /// <summary>