首页 > 其他分享 >分布式事物传递 NetMQ测试

分布式事物传递 NetMQ测试

时间:2024-11-08 11:08:07浏览次数:3  
标签:string NetMQ System subscriber 测试 using message 分布式


using NetMQ;
using NetMQ.Sockets;
using System;
using System.Threading;
namespace 消息传递库_NetMQ服务端
{
    internal class Program
    {
        public static void Main()
        {
            using (var publisher = new PublisherSocket())
            {
                // 绑定到一个端口,等待订阅者连接
                publisher.Bind("tcp://*:5555");

                int messageCount = 0;

                while (true)
                {
                    string message = $"Message {messageCount}";
                    Console.WriteLine($"Publishing: {message}");
                    publisher.SendFrame(message);

                    Thread.Sleep(1000); // 每秒发送一次
                    messageCount++;
                }
            }
        }
    }
}




using NetMQ;
using NetMQ.Sockets;
using System;

namespace 消息传递库_NetMQ客户端
{
    internal class Program
    {
        static void Main(string[] args)
        {
            using (var subscriber = new SubscriberSocket())
            {
                // 连接到发布者的地址
                subscriber.Connect("tcp://localhost:5555");

                // 订阅所有消息
                subscriber.Subscribe(string.Empty);

                while (true)
                {
                    string message = subscriber.ReceiveFrameString();
                    Console.WriteLine($"Received: {message}");
                }
            }
        }
    }
}




image

标签:string,NetMQ,System,subscriber,测试,using,message,分布式
From: https://www.cnblogs.com/hlm750908/p/18534731

相关文章

  • 符合ISO26262的零部件级的软件测试解决方案:目前功能安全零部件测试的困难|软件单元、
    引言在功能安全的开发、测试过程中概念阶段的活动一般都是由主机厂负责,而从系统开发到单元实现则是由供应商负责,对于供应商所做的一系列测试通常称为零部件级测试。根据ISO26262功能安全标准的划分,功能安全在零部件阶段的测试包括:软件单元测试、软件集成测试、硬件集成测......
  • 福禄克DTX,DSX系列内置标准以及生成的测试报告如何解读?
    今日,接到一些朋友的询问?虽然使用了很长一段时间的FLUKEDSX-5000或者DSX-8000,但是对于测试标准和测试生成的报告一知半解,借此咱们一块屡屡清楚。1,经常有的朋友拿到设备后,第一时间就问,咱们福禄克内置的标准的多少?我线的参数(被测的铜缆)达到多少db,才能算过了测试?这些通过一个表......
  • Linux命令行压力测试工具:基准测试与性能优化
    文章目录Linux命令行压力测试工具:基准测试与性能优化Linux安装模拟CPU压力基本用法:高负载模拟:常见选项解析:模拟CPU满负荷模拟I/O瓶颈随机读测试:顺序写测试:初始化与清理操作:模拟大流量网络压力客户端测试命令:服务端命令:模拟端口禁用与防火墙配置查看当前规则:禁用出口端......
  • 基于Zynq FPGA对雷龙SD NAND的测试
    一、SDNAND特征1.1SD卡简介雷龙的SDNAND有很多型号,在测试中使用的是CSNP4GCR01-AMW与CSNP32GCR01-AOW。芯片是基于NANDFLASH和SD控制器实现的SD卡。具有强大的坏块管理和纠错功能,并且在意外掉电的情况下同样能保证数据的安全。其特点如下:接口支持SD2......
  • 【Simulink仿真】新能源电动汽车VCU,BMS hil硬件在环仿真测试电动汽车模型
    摘要本文基于Simulink平台构建了新能源电动汽车控制器硬件在环(Hardware-in-the-Loop,HIL)仿真测试系统。该系统包含整车控制器(VehicleControlUnit,VCU)与电池管理系统(BatteryManagementSystem,BMS)的仿真模型。通过搭建仿真环境,对VCU和BMS进行实时交互测试,验证控制策略......
  • 基于Java+SpringBoot心理测评心理测试系统功能实现五
    一、前言介绍:1.1项目摘要心理测评和心理测试系统在当代社会中扮演着越来越重要的角色。随着心理健康问题日益受到重视,心理测评和心理测试系统作为评估个体心理状态、诊断心理问题、制定心理治疗方案的工具,其需求和应用范围不断扩大。首先,现代社会节奏快速,竞争激烈,人们面临着来......
  • 基于Java+SpringBoot心理测评心理测试系统功能实现六
    一、前言介绍:1.1项目摘要心理测评和心理测试系统在当代社会中扮演着越来越重要的角色。随着心理健康问题日益受到重视,心理测评和心理测试系统作为评估个体心理状态、诊断心理问题、制定心理治疗方案的工具,其需求和应用范围不断扩大。首先,现代社会节奏快速,竞争激烈,人们面临着来......
  • 聊聊接口测试用例设计规范
    1、通过性验证:先按照接口文档传入所有必填字段并且字段值在正确范围内,预期返回正确结果2、参数验证(正向/逆向):必填参数:针对每个必填参数,都设计一条参数为空的测试用例,接口错误信息返回正确非必填参数:设计一条用例所有非必填的参数都传入值,非必填参数(类型,范围)不正确,是否给出合......
  • HCL AppScan Standard 10.7.0 (Windows) - Web 应用程序安全测试
    HCLAppScanStandard10.7.0(Windows)-Web应用程序安全测试HCLAppScanStandardv10forWindowsMultilingual请访问原文链接:https://sysin.org/blog/appscan-10/查看最新版。原创作品,转载请保留出处。作者主页:sysin.org市场领先的应用程序安全解决方案(SAST、D......
  • etcd分布式键值存储系统
    etcdetcd是一个分布式键值存储系统,它在分布式系统领域具有重要地位,以下是关于它的详细介绍:一、基本概述etcd是用Go语言开发的,具有高可用性、强一致性、分布式等特点,主要用于存储和管理关键数据,并在分布式系统中起到协调和同步的作用。二、核心特性1.高可用性etcd......