「邮槽」单向进程间通信——Console程序设计

2024-05-01 03:18

本文主要是介绍「邮槽」单向进程间通信——Console程序设计,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

命名规则

 

            // ./Mailslot/name                      标定同一台机器上的一个本地邮槽
            //servername/Mailslot/name     标定名为servername的一个远程邮槽服务器
            // domainname/Mailslot/name   标定在指定的domain(域)内,使用特定name(名字)的所有邮槽
            //*/Mailslot/name                      标定系统主域内,标定特定name(名字)的所有邮槽

 

            除了Mailslot 为指定名称外,其他字串均可自由设定

 

创建邮槽服务器端:"邮槽服务器端只能进行读"

 

#include <stdio.h>

#include <tchar.h>

#include <Windows.h>

 

 

int _tmain(int argc, _TCHAR* argv[])

{

    HANDLE Mailslot;

    char   buffer[256];

    DWORD  NumberOfBytesRead;

 

 

    // 创建邮槽,获得邮槽句柄

    // MAILSLOT_WAIT_FOREVER 参数指明数据读取时间为永久

    if ((Mailslot = CreateMailslot(TEXT(".//Mailslot//Myslot"), 0,

        MAILSLOT_WAIT_FOREVER, NULL)) == INVALID_HANDLE_VALUE)

    {

        printf("邮槽服务器创建失败,错误代码: %d/n", GetLastError());

        return -1;

    }

 

    // 读取邮槽中的数据

    // MAILSLOT_WAIT_FOREVER 参数将导致ReadFile函数持续保有控制权,直至读到数据

    while(ReadFile(Mailslot, buffer, 256, &NumberOfBytesRead,

        NULL) != 0)

    {

        buffer[NumberOfBytesRead] = 0; //设置字符串尾

        printf("%s/n", buffer);

    }

    return 0;

}

 

 

创建邮槽客户端 :"邮槽客户端只能进行写"

 

#include <stdio.h>

#include <tchar.h>

#include <Windows.h>

 

 

int _tmain(int argc, _TCHAR* argv[])

{

    HANDLE Mailslot;

    DWORD  BytesWritten; 

 

 

    // 打开一个邮槽,获得邮槽句柄

    // .//Mailslot//Myslot 指明了邮槽位于同一台计算机

    // GENERIC_WRITE 以写模式打开

    // FILE_SHARE_READ 读共享是必须的,因为服务端需要进行读操作

    // 参数四用于指定安全特性,对于邮槽是无意义的,所以设为NULL

    //  OPEN_EXISTING 标志指明该邮槽必须已经存在。若一台机器既是客户机又是服务器,这一设置便显得尤其重要

        //如果服务器没有创建邮槽,对CreateFile的调用便会失败.但如果服务器为远程,该参数就无意义.

    // FILE_ATTRIBUTE_NORMAL 指明属性为默认

    // 最后一个参数为NULL,指定该邮槽不复制扩展属性

    if ((Mailslot = CreateFile(TEXT(".//Mailslot//Myslot"), GENERIC_WRITE,

        FILE_SHARE_READ, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL,

        NULL)) == INVALID_HANDLE_VALUE)

    {

        printf("邮槽打开失败,错误代码: %d/n", GetLastError());

        return -1;

    }

 

    // 向邮槽服务器发送数据

    if (WriteFile(Mailslot, "This is a test", 14, &BytesWritten,

        NULL) == 0)

    {

        printf("消息发送失败,错误代码: %d/n", GetLastError());

        return -1;

    }

 

    printf("Wrote %d bytes/n", BytesWritten);

 

    CloseHandle(Mailslot); // 关闭之前打开的邮槽句柄

    return 0;

}

 

其他邮槽API

 

      GetMailslotInfo 和 SetMailslotInfo 可以在邮槽服务器端调用。

 

      BOOL GetMailslotInfo (
           HANDLE     hMailslot,                  //以创建的邮槽句柄
           LPDWORD lpMaxMessageSize,   //设置可将多大的一条消息写入邮槽(以字节为单位)
           LPDWORD lpNextSize,                //以字节为单位,指出下一条消息的长度
           LPDWORD lpMessageCount,      //指定一个缓冲区,用于接收等候读入的消息的总量
           LPDWORD lpReadTimeout          //一个缓冲区,以毫秒为单位,返回当前设置的一次读操作最多等候时间
       );

 

      如果当前没有消息,lpNextSize 参数的值为常量 MAILSLOT_NO_MESSAGE

 

     BOOL SetMailslotInfo (

          HANDLE     hMailslot,                  //以创建的邮槽句柄

          DWORD     lReadTimeout            //设置一次读操作最多等候时间,以毫秒为单位

                                                           //若将其设为0,在不存在消息的前提下,读操作便会立即返回;

                                                           //若设为MAILSLOT_WAIT_FOREVER,读操作便会永远等待下去

     );

这篇关于「邮槽」单向进程间通信——Console程序设计的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/950601

相关文章

C#如何优雅地取消进程的执行之Cancellation详解

《C#如何优雅地取消进程的执行之Cancellation详解》本文介绍了.NET框架中的取消协作模型,包括CancellationToken的使用、取消请求的发送和接收、以及如何处理取消事件... 目录概述与取消线程相关的类型代码举例操作取消vs对象取消监听并响应取消请求轮询监听通过回调注册进行监听使用Wa

[Linux]:进程(下)

✨✨ 欢迎大家来到贝蒂大讲堂✨✨ 🎈🎈养成好习惯,先赞后看哦~🎈🎈 所属专栏:Linux学习 贝蒂的主页:Betty’s blog 1. 进程终止 1.1 进程退出的场景 进程退出只有以下三种情况: 代码运行完毕,结果正确。代码运行完毕,结果不正确。代码异常终止(进程崩溃)。 1.2 进程退出码 在编程中,我们通常认为main函数是代码的入口,但实际上它只是用户级

java 进程 返回值

实现 Callable 接口 与 Runnable 相比,Callable 可以有返回值,返回值通过 FutureTask 进行封装。 public class MyCallable implements Callable<Integer> {public Integer call() {return 123;}} public static void main(String[] args

C#关闭指定时间段的Excel进程的方法

private DateTime beforeTime;            //Excel启动之前时间          private DateTime afterTime;               //Excel启动之后时间          //举例          beforeTime = DateTime.Now;          Excel.Applicat

linux中使用rust语言在不同进程之间通信

第一种:使用mmap映射相同文件 fn main() {let pid = std::process::id();println!(

java线程深度解析(二)——线程互斥技术与线程间通信

http://blog.csdn.net/daybreak1209/article/details/51307679      在java多线程——线程同步问题中,对于多线程下程序启动时出现的线程安全问题的背景和初步解决方案已经有了详细的介绍。本文将再度深入解析对线程代码块和方法的同步控制和多线程间通信的实例。 一、再现多线程下安全问题 先看开启两条线程,分别按序打印字符串的

C语言程序设计(数据类型、运算符与表达式)

一、C的数据类型 C语言提供的数据类型: 二、常量和变量 2.1常量和符号常量 在程序运行过程中,其值不能被改变的量称为常量。 常量区分为不同的类型: 程序中用#define(预处理器指令)命令行定义变量将代表常量,用一个标识符代表一个常量,称为符合常量。 2.2变量 变量代表内存中具有特定属性的一个存储单元,用来存放数据,在程序运行期间,这些值是可以 改变的。 变

C语言程序设计(选择结构程序设计)

一、关系运算符和关系表达式 1.1关系运算符及其优先次序 ①<(小于) ②<=(小于或等于) ③>(大于) ④>=(大于或等于 ) ⑤==(等于) ⑥!=(不等于) 说明: 前4个优先级相同,后2个优先级相同,关系运算符的优先级低于算术运算符,关系运算符的优先级高于赋值运算符 1.2关系表达式 用关系运算符将两个表达式(可以是算术表达式或关系表达式,逻辑表达式,赋值表达式,字符

Golang进程权限调度包runtime

关于 runtime 包几个方法: Gosched:让当前线程让出 cpu 以让其它线程运行,它不会挂起当前线程,因此当前线程未来会继续执行GOMAXPROCS:设置最大的可同时使用的 CPU 核数Goexit:退出当前 goroutine(但是defer语句会照常执行)NumGoroutine:返回正在执行和排队的任务总数GOOS:目标操作系统NumCPU:返回当前系统的 CPU 核数量 p

如何保证android程序进程不到万不得已的情况下,不会被结束

最近,做一个调用系统自带相机的那么一个功能,遇到的坑,在此记录一下。 设备:红米note4 问题起因 因为自定义的相机,很难满足客户的所有需要,比如:自拍杆的支持,优化方面等等。这些方面自定义的相机都不比系统自带的好,因为有些系统都是商家定制的,难免会出现一个奇葩的问题。比如:你在这款手机上运行,无任何问题,然而你换一款手机后,问题就出现了。 比如:小米的红米系列,你启用系统自带拍照功能后