///发送WM_COPYDATA消息的数据结构  ///    internal struct COPYDATASTRUCT    {        ///        ///用户自定义数据        ///        internal IntPtr dwData;        ///        ///数据长度        ///        internal int cbData;        ///        ///数据首地址指针        ///        internal IntPtr lpData;    }现在我们来看看具体如何实现:1、 我们首先创建一个类,让它从Form类继承,因为我们需要一个窗体,然后对它的消息进行处理: internal class WinMsg : Form{        private string _messageString;        private List _windowList;        private int _message;        private int _intHandler;        private bool _isConnected;} 2、 然后定义构造函数,在构造函数里注册一个消息通道值,并发出一个广播通知其它在这个通道的窗口。        internal WinMsg(string messageString)        {            _messageString = messageString;            _isConnected = false;            _intHandler = Handle.ToInt32();            _windowList = new List();            _message = Win32.RegisterWindowMessage(_messageString);//注册一个消息通道            int errCode = Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.CONNECTION, _intHandler);//向此通道内所有的窗口广播自己的句柄            if (errCode == 0)            {                throw new Win32Exception(errCode);//发生错误,抛出异常            }            else            {                _isConnected = true;            }        }3、 重写基类的WndProc函数,处理接收到的消息:        protected override void WndProc(ref Message m)        {            if (m.Msg == _message)//接收到广播消息,进行处理            {                int LParam = m.LParam.ToInt32();                int WParam = m.WParam.ToInt32();                if (LParam != 0 && LParam != _intHandler)                {                    if (WParam == Win32.DISCONNECTION)                    {                        _windowList.Remove(m.WParam);//将对方窗口的句柄从列表中删除                    }                    else                    {                        if (WParam==Win32.CONNECTION)                        {                            Win32.PostMessage(m.LParam, _message, Win32.REVERSION, _intHandler);                        }                        _windowList.Add(m.LParam);//将对方窗口的句柄存入列表中                    }                }                return;            }            switch (m.Msg)            {                case Win32.WM_COPYDATA://接收到其它窗口发送过来的数据                    {                        COPYDATASTRUCT data = new COPYDATASTRUCT();                        data = (COPYDATASTRUCT)m.GetLParam(data.GetType());                        byte[] message = new byte[data.cbData];                        Marshal.Copy(data.lpData, message, 0, data.cbData);//从非托管内存中将数据复制到我们的byte数组中。                        Anyzler(m.WParam, message);//在这里处理接收到的数据。                    }                    break;                case Win32.WM_DESTROY:                case Win32.WM_QUERYENDSESSION://窗口被关闭,向其它窗口广播通知从队列中删除自己                    Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.DISCONNECTION, _intHandler);                    base.WndProc(ref m);//调用基类的消息处理函数。                    break;                default:                    base.WndProc(ref m); //调用基类的消息处理函数。                    break;            }        }4、 定义发送消息的函数:        internal void Send(byte[] message)        {            if (_isConnected)            {                int length = message.Length;                IntPtr ptr = Marshal.AllocHGlobal(length);//申请一块非托管内存                Marshal.Copy(message, 0, ptr, length);//将要发送的数据封送到非托管内存                COPYDATASTRUCT data = new COPYDATASTRUCT();                data.dwData = IntPtr.Zero;//这里可以随意定义。                data.cbData = length;//传递要发送的数据的长度                data.lpData = ptr;//传递要发送的数据的地址指针                //向其它所有窗口发送数据,这里不能发广播消息。必须一个一个发送。                foreach (IntPtr window in _windowList)                {                    Win32.SendMessage(window, Win32.WM_COPYDATA, this.Handle, ref data);                }                Marshal.FreeHGlobal(ptr);//释放这块非托管内存,这行一定要写上,不然会内存泄漏。            }        }好了,主要代码就是这些了!-IMDN开发者社群-imdn.cn">     ///发送WM_COPYDATA消息的数据结构  ///    internal struct COPYDATASTRUCT    {        ///        ///用户自定义数据        ///        internal IntPtr dwData;        ///        ///数据长度        ///        internal int cbData;        ///        ///数据首地址指针        ///        internal IntPtr lpData;    }现在我们来看看具体如何实现:1、 我们首先创建一个类,让它从Form类继承,因为我们需要一个窗体,然后对它的消息进行处理: internal class WinMsg : Form{        private string _messageString;        private List _windowList;        private int _message;        private int _intHandler;        private bool _isConnected;} 2、 然后定义构造函数,在构造函数里注册一个消息通道值,并发出一个广播通知其它在这个通道的窗口。        internal WinMsg(string messageString)        {            _messageString = messageString;            _isConnected = false;            _intHandler = Handle.ToInt32();            _windowList = new List();            _message = Win32.RegisterWindowMessage(_messageString);//注册一个消息通道            int errCode = Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.CONNECTION, _intHandler);//向此通道内所有的窗口广播自己的句柄            if (errCode == 0)            {                throw new Win32Exception(errCode);//发生错误,抛出异常            }            else            {                _isConnected = true;            }        }3、 重写基类的WndProc函数,处理接收到的消息:        protected override void WndProc(ref Message m)        {            if (m.Msg == _message)//接收到广播消息,进行处理            {                int LParam = m.LParam.ToInt32();                int WParam = m.WParam.ToInt32();                if (LParam != 0 && LParam != _intHandler)                {                    if (WParam == Win32.DISCONNECTION)                    {                        _windowList.Remove(m.WParam);//将对方窗口的句柄从列表中删除                    }                    else                    {                        if (WParam==Win32.CONNECTION)                        {                            Win32.PostMessage(m.LParam, _message, Win32.REVERSION, _intHandler);                        }                        _windowList.Add(m.LParam);//将对方窗口的句柄存入列表中                    }                }                return;            }            switch (m.Msg)            {                case Win32.WM_COPYDATA://接收到其它窗口发送过来的数据                    {                        COPYDATASTRUCT data = new COPYDATASTRUCT();                        data = (COPYDATASTRUCT)m.GetLParam(data.GetType());                        byte[] message = new byte[data.cbData];                        Marshal.Copy(data.lpData, message, 0, data.cbData);//从非托管内存中将数据复制到我们的byte数组中。                        Anyzler(m.WParam, message);//在这里处理接收到的数据。                    }                    break;                case Win32.WM_DESTROY:                case Win32.WM_QUERYENDSESSION://窗口被关闭,向其它窗口广播通知从队列中删除自己                    Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.DISCONNECTION, _intHandler);                    base.WndProc(ref m);//调用基类的消息处理函数。                    break;                default:                    base.WndProc(ref m); //调用基类的消息处理函数。                    break;            }        }4、 定义发送消息的函数:        internal void Send(byte[] message)        {            if (_isConnected)            {                int length = message.Length;                IntPtr ptr = Marshal.AllocHGlobal(length);//申请一块非托管内存                Marshal.Copy(message, 0, ptr, length);//将要发送的数据封送到非托管内存                COPYDATASTRUCT data = new COPYDATASTRUCT();                data.dwData = IntPtr.Zero;//这里可以随意定义。                data.cbData = length;//传递要发送的数据的长度                data.lpData = ptr;//传递要发送的数据的地址指针                //向其它所有窗口发送数据,这里不能发广播消息。必须一个一个发送。                foreach (IntPtr window in _windowList)                {                    Win32.SendMessage(window, Win32.WM_COPYDATA, this.Handle, ref data);                }                Marshal.FreeHGlobal(ptr);//释放这块非托管内存,这行一定要写上,不然会内存泄漏。            }        }好了,主要代码就是这些了! - IMDN开发者社群-imdn.cn">
登录
首页 » C# » C# 不同进程间通讯实例源码下载(SendMessage方式)

C# 不同进程间通讯实例源码下载(SendMessage方式)

于 2013-09-14 发布
0 76
下载积分: 1 下载次数: 0

代码说明:

在.NET中基于Windows消息的IPC实现 一、什么是IPC IPC(Inter process Communication)就是“进程间通讯”。我们都知道,在windows系统中,各个应用程序(进程)之间常常需要交换、传递数据,这就要解决进程间的数据通信问题。在最初的16位Windows3.x系统中,所有Windows应用程序共享单一地址,任何进程都能够对这一共享地址空间的数据进行读写操作。 随着Windwos98、Windows NT、Windows2000等32位的操作系统的出现,每个进程都有自己的地址空间,一个Windows进程不能存取另一个进程的私有数据,也就是说,虽然两个进程可以用具有相同值的指针寻址,但所读写的只是它们各自的数据,这样就减少了进程之间的相互干扰。 二、如何实现IPC 那么在windows当前系统下,如何实现进程通讯呢?其实有很多方法,如: 1、    剪贴板Clipboard 2、    DDE(动态数据交换) 3、    内存映像 4、    消息管道 5、    邮件槽 6、    Socket 7、    RPC 8、    串行/并行通信(Serial/Parallel Communication) 9、    COM/DCOM 10、Windows消息 三、基于Windows消息的IPC 现在让我们进入今天我们要讲的主题:“基于Windows消息的IPC实现”。 在这里,我假定大家对Windows消息机制都有很好的理解,所以我就不在这上面费太多的墨水了。我们直接看看Windows消息是怎么样实现进程间通讯的。我们首先看看Windows的消息常数: WM_COPYDATA=0x004A//  当一个应用程序传递数据给另一个应用程序时发送此消息。 这就是我们要的。下面我们来看看如何利用它来实现IPC。 让我们先看看几个API函数,没有它们,我们没有办法将数据发送出去。 1、 PostMessage  函数功能:该函数将一个消息放入(寄送)到与指定窗口创建的线程相联系消息队列里,不等待线程处理消息就返回。消息队列里的消息通过调用GetMessage和PeekMessage取得。 函数原型:B00L PostMessage(HWND hWnd,UINT Msg,WPARAM wParam,LPARAM lParam); 参数 hWnd:其窗口程序接收消息的窗口的句柄。可取有特定含义的两个值: HWND.BROADCAST:消息被寄送到系统的所有顶层窗口,包括无效或不可见的非自身拥有的窗口、被覆盖的窗口和弹出式窗口。消息不被寄送到子窗口。 NULL:此函数的操作和调用参数dwThread设置为当前线程的标识符PostThreadMessage函数一样。 Msg:指定被寄送的消息。 wParam:指定附加的消息特定的信息。 IParam:指定附加的消息特定的信息。 返回值:如果函数调用成功,返回非零值:如果函数调用失败,返回值是零。若想获得更多的错误信息,请调用GetLastError函数。 2、 SendMessage  函数功能:该函数将指定的消息发送到一个或多个窗口。此函数为指定的窗口调用窗口程序,直到窗口程序处理完消息再返回。而函数PostMessage不同,将一个消息寄送到一个线程的消息队列后立即返回。 函数原型:LRESULT SendMessage(HWND hWnd,UINT Msg,WPARAM wParam,LPARAM IParam); 参数: hWnd:其窗口程序将接收消息的窗口的句柄。如果此参数为HWND_BROADCAST,则消息将被发送到系统中所有顶层窗口,包括无效或不可见的非自身拥有的窗口、被覆盖的窗口和弹出式窗口,但消息不被发送到子窗口。 Msg:指定被发送的消息。 wParam:指定附加的消息指定信息。 IParam:指定附加的消息指定信息。 返回值:返回值指定消息处理的结果,依赖于所发送的消息。 3、 RegisterWindowMessage 函数功能:RegisterWindowMessage函数定义一个新的窗口消息,该消息保证在整个系统范围内是唯一的。调用SendMessage或PostMessage函数时可以使用该函数返回的消息值。 函数原型:UINT RegisterWindowMessage(lpsz) 参数: lpsz指向一个以NULL结束的字符串,该字符串指定待登记的消息。 返回值:若成功地登记了消息,返回值是一个消息标识符。该标识符值的范围在0XC000到0XFFFF之间,否则,返回值为0。 我们现在在C#中声明这些API函数:         [DllImport("user32")]        internal static extern int RegisterWindowMessage(string lpString);        [DllImport("user32")]        internal static extern int PostMessage(IntPtr hWnd, int Msg, int wParam, int lParam);        [DllImport("user32")]        internal static extern int PostMessage(IntPtr hwnd, int wMsg, IntPtr wParam, IntPtr lParam);        [DllImport("user32")]        internal static extern int SendMessage(IntPtr hWnd, int Msg, IntPtr wParam, ref COPYDATASTRUCT lParam); 然后定义一些我们需要的常数:                 internal const int WM_COPYDATA = 0x004A; //当一个应用程序传递数据给另一个应用程序时发送此消息        internal const int WM_DESTROY = 0x0002; //窗体被销毁        internal const int WM_CREATE = 0x0001; //应用程序创建一个窗口        internal const int WM_QUERYENDSESSION = 0x0011; //当用户选择结束对话框或程序自己调用ExitWindows函数        internal static readonly IntPtr HWND_BROADCAST = new IntPtr(0xFFFF); 我们还需要一个传送数据的结构:     ///    ///发送WM_COPYDATA消息的数据结构  ///    internal struct COPYDATASTRUCT    {        ///        ///用户自定义数据        ///        internal IntPtr dwData;        ///        ///数据长度        ///        internal int cbData;        ///        ///数据首地址指针        ///        internal IntPtr lpData;    } 现在我们来看看具体如何实现: 1、 我们首先创建一个类,让它从Form类继承,因为我们需要一个窗体,然后对它的消息进行处理:   internal class WinMsg : Form{        private string _messageString;        private List _windowList;        private int _message;        private int _intHandler;        private bool _isConnected;}   2、 然后定义构造函数,在构造函数里注册一个消息通道值,并发出一个广播通知其它在这个通道的窗口。         internal WinMsg(string messageString)        {            _messageString = messageString;            _isConnected = false;            _intHandler = Handle.ToInt32();            _windowList = new List();            _message = Win32.RegisterWindowMessage(_messageString);//注册一个消息通道            int errCode = Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.CONNECTION, _intHandler);//向此通道内所有的窗口广播自己的句柄            if (errCode == 0)            {                throw new Win32Exception(errCode);//发生错误,抛出异常            }            else            {                _isConnected = true;            }        } 3、 重写基类的WndProc函数,处理接收到的消息:         protected override void WndProc(ref Message m)        {            if (m.Msg == _message)//接收到广播消息,进行处理            {                int LParam = m.LParam.ToInt32();                int WParam = m.WParam.ToInt32();                if (LParam != 0 && LParam != _intHandler)                {                    if (WParam == Win32.DISCONNECTION)                    {                        _windowList.Remove(m.WParam);//将对方窗口的句柄从列表中删除                    }                    else                    {                        if (WParam==Win32.CONNECTION)                        {                            Win32.PostMessage(m.LParam, _message, Win32.REVERSION, _intHandler);                        }                        _windowList.Add(m.LParam);//将对方窗口的句柄存入列表中                    }                }                return;            }            switch (m.Msg)            {                case Win32.WM_COPYDATA://接收到其它窗口发送过来的数据                    {                        COPYDATASTRUCT data = new COPYDATASTRUCT();                        data = (COPYDATASTRUCT)m.GetLParam(data.GetType());                        byte[] message = new byte[data.cbData];                        Marshal.Copy(data.lpData, message, 0, data.cbData);//从非托管内存中将数据复制到我们的byte数组中。                        Anyzler(m.WParam, message);//在这里处理接收到的数据。                    }                    break;                case Win32.WM_DESTROY:                case Win32.WM_QUERYENDSESSION://窗口被关闭,向其它窗口广播通知从队列中删除自己                    Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.DISCONNECTION, _intHandler);                    base.WndProc(ref m);//调用基类的消息处理函数。                    break;                default:                    base.WndProc(ref m); //调用基类的消息处理函数。                    break;            }        }4、 定义发送消息的函数:         internal void Send(byte[] message)        {            if (_isConnected)            {                int length = message.Length;                IntPtr ptr = Marshal.AllocHGlobal(length);//申请一块非托管内存                Marshal.Copy(message, 0, ptr, length);//将要发送的数据封送到非托管内存                COPYDATASTRUCT data = new COPYDATASTRUCT();                data.dwData = IntPtr.Zero;//这里可以随意定义。                data.cbData = length;//传递要发送的数据的长度                data.lpData = ptr;//传递要发送的数据的地址指针                //向其它所有窗口发送数据,这里不能发广播消息。必须一个一个发送。                foreach (IntPtr window in _windowList)                {                    Win32.SendMessage(window, Win32.WM_COPYDATA, this.Handle, ref data);                }                Marshal.FreeHGlobal(ptr);//释放这块非托管内存,这行一定要写上,不然会内存泄漏。            }        }好了,主要代码就是这些了!

下载说明:请别用迅雷下载,失败请重下,重下不扣分!

发表评论

0 个回复

  • radmin21
    说明:  务器端基于select I/O模型。为防止程序界面阻塞,有一个子线程用于不断接收socket并select其中的处理。客户端只有一个线程函数,不过其利用率很高,可用于远程目录交换,请求文件大小,创建若干线程来下载文件。文件传输有上传和下载,还有对等传输,这个项目中,传输文件具体指下载。(Client server based on select I/O model. Programming interfaces in order to prevent obstruction, there is a sub-thread for receiving socket and select which treatment. There is only one client thread function, but its utilization very high, can be used for remote directory exchange, request the file size, create a number of threads to download the file. File transfer are uploading and downloading, as well as peer-to-peer transmission, this project, the specific means to transfer files to download.)
    2008-10-20 11:08:26下载
    积分:1
  • ask_answer
    该程序模拟知乎,作为网上问答系统,用户能注册,登录,提问,回答,点赞,关注,取关,查找问题,等一系列操作,一个服务器端可以同时连接多个客户端,能够同步各个客户端操作结果。程序分为客户端和服务器端,用户gui采用mfc编写,通信方式为socket方式,开发环境为win7 vs2015,编译器v140.(The program simulates know almost as online quiz system, users can register, login, questions, answers, thumbs up, focus on, take off, find the problem, and a series of operations, a server can be connected to multiple clients simultaneously, it is possible to synchronize each client operating results. Program is divided into client and server side, the user using mfc gui written communication for the socket, the development environment for win7 vs2015, compiler v140.)
    2016-05-17 11:56:13下载
    积分:1
  • TCPNet
    一个采用TCP协议的网络测试工具。采用VC6.0开发环境,具有客户端和服务器端,加入进来的客户端可以互相发送接受数据,对学习socket编程是不错的借鉴。(using a TCP network testing tools. VC6.0 use development environment with the client and server side, joined the client can accept each other this data, to learn socket programming is a good reference.)
    2020-11-14 16:19:43下载
    积分:1
  • 1
    说明:  WinSock网络编程实用宝典。适合初学者以及深入理解网络编程的朋友。(WinSock network programming practical Collection. Suitable for beginners as well as in-depth understanding of network programming friends.)
    2011-07-04 17:38:27下载
    积分:1
  • kdcxcs2
    快递发送单查询通信, 利用了socket(Courier to send single query communication using a socket)
    2013-01-04 19:39:10下载
    积分:1
  • ipmsg
    IPmsg的源代码,用于研究其中所用到的协议和算法(IPmsg source file)
    2012-04-08 14:55:39下载
    积分:1
  • EasyChat
    说明:  socket通讯 (发消息聊天) 实例源码 (亲测)(Socket communication (message chat) instance source code (pro test))
    2021-02-15 10:58:29下载
    积分:1
  • cPP-Guinness-classic-code
    c++经典代码大全,适合初学者下载参考使用。(c++ Guinness classic code, suitable for beginners reference.)
    2014-01-13 11:17:12下载
    积分:1
  • wireless
    用于无线网络编程的学习,很实用,作为初学者的入门教材还是很有用的。(Wireless network programming for learning)
    2013-12-02 17:25:50下载
    积分:1
  • gofk
    c语言编的词法分析器,可以学习的源码,不错(C language of lexical analyzer, you can learn the source code, good)
    2018-12-25 21:44:27下载
    积分:1
  • 696524资源总数
  • 103971会员总数
  • 70今日下载