//Author:dalerkd
//地址:http://blog.csdn.net/dalerkd
//Team:15pb
//创建多子个线程实例
#include <stdio.h>
#include <process.h>
#include <windows.h>
//油聊0.1
//目标电脑名字
wchar_t wcCPName[20]=L"";
//存放目标电脑名字拼接结果
wchar_t wcCPNameEnd[40]=L"\\\\";

//发送消息的子线程函数
unsigned int __stdcall ThreadSend(PVOID pM)
{
    char tc[40]="";

    while (TRUE)
    {

    printf_s("输入要发送的信息:\r\n");
    fflush(stdin);
    scanf_s("%s",tc,40);

    //1.打开邮槽对象
    HANDLE hFile=CreateFile(
        wcCPNameEnd,//邮槽名称
        GENERIC_WRITE,                  //读写属性
        FILE_SHARE_READ,                //共享属性
        NULL,                           //安全属性
        OPEN_EXISTING,                  //打开方式
        FILE_ATTRIBUTE_NORMAL,          //标志位
        NULL                            //文件模块(默认留空)
        );
    //2.向mailslot写入
    DWORD dwWritten;
    LPSTR lpMessage =tc;/*"UDP风暴来袭>>>>>>>>>>>"*/
    DWORD dwMegLen = strlen(lpMessage)+sizeof(CHAR);
    WriteFile(hFile,lpMessage,dwMegLen,&dwWritten,NULL);
    //3.结束

    CloseHandle(hFile);

    }   
    return 0;
}


//接收消息的子线程函数
unsigned int __stdcall ThreadReceive(PVOID pM)
{
    BOOL bIsTrue = true;
    BYTE lpBuffer[0x60]={0};



    //1.创建邮槽对象
    HANDLE hSlot = CreateMailslot(L"\\\\.\\mailslot\\KITTY",0,MAILSLOT_WAIT_FOREVER,(LPSECURITY_ATTRIBUTES)NULL);
    //2.循环读取邮槽信息
    while (bIsTrue)
    {
        //2.1获取邮槽消息数量
        DWORD dwMsgCount = 0,dwMsgSize=0;
        GetMailslotInfo(hSlot,(LPDWORD)NULL,&dwMsgSize,&dwMsgCount,(LPDWORD)NULL);
        if (dwMsgSize==MAILSLOT_NO_MESSAGE)
        {
            Sleep(2000);
            continue;
        }
        //2.2循环获取全部消息
        while (dwMsgCount)
        {
            DWORD dwRet;
            ZeroMemory(lpBuffer,dwMsgSize);
            if (!ReadFile(hSlot,lpBuffer,dwMsgSize,&dwRet,NULL))
            {
                printf("ReadFile执行失败，错误码:%d",GetLastError());
                return 0;
            }
            //显示信息
            printf("邮槽内容:%s\n",lpBuffer);
            //计算机剩余消息数
            GetMailslotInfo(hSlot,(LPDWORD)NULL,&dwMsgSize,&dwMsgCount,nullptr);
        }
    }


    return 0;
}

//主函数，所谓主函数其实就是主线程执行的函数。
int main()
{

    wprintf_s(L"输入对方机器名称全称");

    //为了拼接成"\\\\机器名全称\\mailslot\\KITTY"的形式.用于后面的通讯
    wscanf_s(L"%s",wcCPName,20);
    wcscat_s(wcCPNameEnd,20,wcCPName);
    wcscat_s(wcCPNameEnd,40,L"\\mailslot\\KITTY");



    const int THREAD_NUM = 2;
    HANDLE handle[THREAD_NUM];

    handle[0]       =   (HANDLE)_beginthreadex(NULL, 0, ThreadSend, NULL, 0, NULL);
    handle[1]       =   (HANDLE)_beginthreadex(NULL, 0, ThreadReceive, NULL, 0, NULL);

    WaitForMultipleObjects(THREAD_NUM,handle, TRUE, INFINITE);
    return 0;
}

[培训]内核驱动高级班，冲击BAT一流互联网大厂工作，每周日13:00-18:00直播授课