本文目录
- 如果Netty做服务器端, iOS做游戏客户端, 请问通信问题如何解决
- 求教netty集群方案
- 基于netty4实现进程间通信，使用什么encode，decode机制效率高
- netty 实现的服务器 怎么和c++客户端进行通讯
- netty是如何实现即时通讯的
如果Netty做服务器端, iOS做游戏客户端, 请问通信问题如何解决
通信信息在网络上都是以byte传输的。只要客户端的消息格式符合netty的规则就可以通信。跟客户端用不用netty没有关系
求教netty集群方案
比较简单的方法是利用zookeeper来实现服务发现。netty服务端启动时注册到zk，服务关闭的时候主动注销。客户端通过进程名到zk拉去可用的netty服务，并订阅zk的服务端的事件，在客户端处理分布式逻辑。
基于netty4实现进程间通信，使用什么encode，decode机制效率高
进程间通信机制 1 文件映射 文件映射(Memory-Mapped Files)能使进程文件内容作进程址区间块内存待进程必使用文件I/O操作需简单指针操作读取修改文件内容 Win32 API允许进程访问同文件映射象各进程自址空间接收内存指针通使用些指针同进程读或修改文件内容实现文件数据共享 应用程序三种使进程共享文件映射象 (1)继承：第进程建立文件映射象进程继承该象句柄 (2)命名文件映射：第进程建立文件映射象给该象指定名字(与文件名同)第二进程通名字打文件映射象另外第进程通些其IPC机制(名管道、邮件槽等)名字传给第二进程 (3)句柄复制：第进程建立文件映射象通其IPC机制(名管道、邮件槽等)象句柄传递给第二进程第二进程复制该句柄取该文件映射象访问权限 文件映射进程间共享数据非效较安全性文件映射能用于本机器进程间能用于网络发者必须控制进程间同步 2 共享内存 Win32 API共享内存(Shared Memory)实际文件映射种特殊情况进程创建文件映射象用0xFFFFFFFF代替文件句柄(HANDLE)表示应文件映射象操作系统页面文件访问内存其进程打该文件映射象访问该内存块由于共享内存用文件映射实现所较安全性能运行于同计算机进程间 注意点： 要控制同步且CString、list、arry、map等collect class都能安全使用于共享内存 要拥虚函数C++类放共享内存 要CObject派类MFC象放共享内存 要使用"point within the shared memory"指针 要使用"point outside of the shared memory"指针 使用"based"指针安全要使用 3 匿名管道 管道(Pipe)种具两端点通信通道：端句柄进程另端句柄进程通信管道单向－端读另端点写；双向管道两端点既读写 匿名管道(Anonymous Pipe) 父进程进程间或同父进程两进程间传输数据名字单向管道通由父进程创建管道由要通信进程继承通道读端点句柄或写 端点句柄实现通信父进程建立两或更继承匿名管道读写句柄进程些进程使用管道直接通信需要通父进程 匿名管道单机实现进程标准I/O重定向效能网使用能用于两相关进程间 4 命名管道 命名管道(Named Pipe)服务器进程或客户进程间通信单向或双向管道同于匿名管道命名管道相关进程间同计算机间使用服务器建立命名管道给指定名字任何进程都通该名字打管道另端根据给定权限服务器进程通信 命名管道提供相简单编程接口使通网络传输数据并比同计算机两进程间通信更困难要同进程通信力 5 邮件槽 邮件槽(Mailslots)提 供进程间单向通信能力任何进程都能建立邮件槽邮件槽服务器其进程称邮件槽客户通邮件槽名字给邮件槽服务器进程发送消息进消 息直放邮件槽直服务器进程读取止进程既邮件槽服务器邮件槽客户建立邮件槽实现进程间双向通信 通邮件槽给本计算机邮件槽、其计算机邮件槽或指定网络区域所计算机同名字邮件槽发送消息广播通信消息度能超400字节非广播消息度则受邮件槽服务器指定消息度限制 邮件槽与命名管道相似传输数据通靠数据报(TCP/IP协议UDP包)完旦网络发错误则保证消息确接收命名管道传输数据则建立靠连接基础邮件槽简化编程接口给指定网络区域内所计算机广播消息能力所邮件槽失应用程序发送接收消息另种选择 6 剪贴板 剪贴板(Clipped Board)实质Win32 API组用传输数据函数消息Windows应用程序间进行数据共享提供介Windows已建立剪切(复制)－粘贴机制同应用程序间共享同格式数据提供条捷径用户应用程序执行剪切或复制操作应用程序选取数据用种或种格式放剪贴板任何其应用程序都剪贴板拾取数据给定格式选择适合自格式 剪贴板非松散交换媒介支持任何数据格式每格式由符号整数标识标准(预定义)剪贴板格式该值Win32 API定义量；非标准格式使用Register Clipboard Format函数注册新剪贴板格式利用剪贴板进行交换数据需数据格式致或都转化某种格式行剪贴板能基于Windows程序使用能网络使用 7 态数据交换 态数据交换(DDE)使用共享内存应用程序间进行数据交换种进程间通信形式应用程序使用DDE进行性数据传输现新数据通发送更新值应用程序间态交换数据 DDE剪贴板既支持标准数据格式(文本、位图等)支持自定义数据格式数据传输机制却同明显区别剪贴板操作几乎总用作用户指定操作性应答－菜单选择Paste命令尽管DDE由用户启继续发挥作用般必用户进步干预DDE三种数据交换式： (1) 冷链：数据交换性数据传输与剪贴板相同 (2) 温链：数据交换服务器通知客户客户必须请求新数据 (3) 热链：数据交换服务器自给客户发送数据 DDE交换发单机或网络同计算机应用程序间发者定义定制DDE数据格式进行应用程序间特别目IPC更紧密耦合通信要求数基于Windows应用程序都支持DDE 8 象连接与嵌入 应用程序利用象连接与嵌入(OLE)技术管理复合文档(由种数据格式组文档)OLE提供使某应用程序更容易调用其应用程序进行数据服务例OLE支持字处理器嵌套电表格用户要电表格OLE库自启电表格器用户退电表格器该表格已原始字处理器文档更新电表格器变字处理器扩展使用DDE用户要显式启电表格器 同DDE技术相同数基于Windows应用程序都支持OLE技术 9 态连接库 Win32态连接库(DLL)全局数据调用DLL所进程共享给进程间通信辟条新途径访问要注意同步问题 虽通DLL进行进程间数据共享数据安全角度考虑我并提倡种使用带访问权限控制共享内存更些 10 远程程调用 Win32 API提供远程程调用(RPC)使应用程序使用远程调用函数使网络用RPC进行进程通信像函数调用简单RPC既单机同进程间使用网络使用 由于Win32 API提供RPC服OSF-DCE(Open Software Foundation Distributed Computing Environment)标准所通Win32 API编写RPC应用程序能与其操作系统支持DECRPC应用程序通信使用RPC发者建立高性能、紧密耦合布式应用程序 11 NetBios函数 Win32 API提供NetBios函数用于处理低级网络控制主要IBM NetBios系统编写与Windows接口除非些特殊低级网络功能要求应用程序其应用程序要使用NetBios函数进行进程间通信 12 Sockets Windows Sockets规范U.C.BerkeleyBSD UNIX流行Socket接口范例定义套Windows网络编程接口除Berkeley Socket原库函数外扩展组针Windows函数使程序员充利用Windows消息机制进行编程 现通Sockets实现进程通信网络应用越越主要原Sockets跨平台性要比其IPC机制另外WinSock 2.0仅支持TCP/IP协议且支持其协议(IPX)Sockets唯缺点支持底层通信操作使单机进程间进行简单数据传递太便使用面介绍WM_COPYDATA消息更合适些 13 WM_COPYDATA消息 WM_COPYDATA种非强却鲜知消息应用向另应用传送数据发送需使用调用SendMessage函数参数目窗口句柄、传递数据起始址、WM_COPYDATA消息接收需像处理其消息处理WM_COPY DATA消息收发双实现数据共享 WM_COPYDATA种非简单底层实际通文件映射实现缺点灵性高并且能用于Windows平台单机环境
netty 实现的服务器 怎么和c++客户端进行通讯
C++通过socket编程实现服务端与客户端的通讯，代码如下（个人环境下测试正常，如果遇到运行send发送报错，请检查服务器端口是否被占用，调试的时候请先运行服务端程序在运行客服端，一定要加载库函数ws2_32.lib，发送字符时应该多加一个空字符作为结束字符）：服务器端程序：12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697 // Server.cpp : Defines the entry point for the console application.#include "winsock2.h"#pragma comment(lib, "ws2_32.lib")#include 《iostream》using namespace std;int main(int argc, char* argv){ const int BUF_SIZE = 64; WSADATA wsd; //WSADATA变量 SOCKET sServer; //服务器套接字 SOCKET sClient; //客户端套接字 SOCKADDR_IN addrServ;; //服务器地址 char buf; //接收数据缓冲区 char sendBuf;//返回给客户端得数据 int retVal; //返回值 //初始化套结字动态库 if (WSAStartup(MAKEWORD(2,2), &wsd) != 0) { cout 《《 "WSAStartup failed!" 《《 endl; return 1; } //创建套接字 sServer = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if(INVALID_SOCKET == sServer) { cout 《《 "socket failed!" 《《 endl; WSACleanup();//释放套接字资源; return -1; } //服务器套接字地址 addrServ.sin_family = AF_INET; addrServ.sin_port = htons(4999); addrServ.sin_addr.s_addr = INADDR_ANY; //绑定套接字 retVal = bind(sServer, (LPSOCKADDR)&addrServ, sizeof(SOCKADDR_IN)); if(SOCKET_ERROR == retVal) { cout 《《 "bind failed!" 《《 endl; closesocket(sServer); //关闭套接字 WSACleanup(); //释放套接字资源; return -1; } //开始监听 retVal = listen(sServer, 1); if(SOCKET_ERROR == retVal) { cout 《《 "listen failed!" 《《 endl; closesocket(sServer); //关闭套接字 WSACleanup(); //释放套接字资源; return -1; } //接受客户端请求 sockaddr_in addrClient; int addrClientlen = sizeof(addrClient); sClient = accept(sServer,(sockaddr FAR*)&addrClient, &addrClientlen); if(INVALID_SOCKET == sClient) { cout 《《 "accept failed!" 《《 endl; closesocket(sServer); //关闭套接字 WSACleanup(); //释放套接字资源; return -1; } while(true) { //接收客户端数据 ZeroMemory(buf, BUF_SIZE); retVal = recv(sClient, buf, BUF_SIZE, 0); if (SOCKET_ERROR == retVal) { cout 《《 "recv failed!" 《《 endl; closesocket(sServer); //关闭套接字 closesocket(sClient); //关闭套接字 WSACleanup(); //释放套接字资源; return -1; } if(buf == ’0’) break; cout 《《 "客户端发送的数据: " 《《 buf 《《endl; cout 《《 "向客户端发送数据: " ; cin 》》 sendBuf; send(sClient, sendBuf, strlen(sendBuf), 0); } //退出 closesocket(sServer); //关闭套接字 closesocket(sClient); //关闭套接字 WSACleanup(); //释放套接字资源; return 0;}客户端程序：123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172 #include "winsock2.h"#include 《iostream》#pragma comment(lib, "ws2_32.lib") using namespace std;BOOL RecvLine(SOCKET s, char* buf); //读取一行数据 int main(int argc, char* argv){const int BUF_SIZE = 64; WSADATA wsd; //WSADATA变量SOCKET sHost; //服务器套接字SOCKADDR_IN servAddr; //服务器地址char buf; //接收数据缓冲区char bufRecv;int retVal; //返回值//初始化套结字动态库if (WSAStartup(MAKEWORD(2,2), &wsd) != 0){cout 《《 "WSAStartup failed!" 《《 endl;return -1;}//创建套接字sHost = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);if(INVALID_SOCKET == sHost){cout 《《 "socket failed!" 《《 endl;WSACleanup();//释放套接字资源return -1;} //设置服务器地址和端口servAddr.sin_family =AF_INET;servAddr.sin_addr.s_addr = inet_addr("127.0.0.1");servAddr.sin_port = htons((short)4999);int nServAddlen = sizeof(servAddr); //连接服务器retVal=connect(sHost,(LPSOCKADDR)&servAddr, sizeof(servAddr));if(SOCKET_ERROR == retVal){cout 《《 "connect failed!" 《《 endl;closesocket(sHost); //关闭套接字WSACleanup(); //释放套接字资源return -1;}while(true){//向服务器发送数据ZeroMemory(buf, BUF_SIZE);cout 《《 " 向服务器发送数据: ";cin 》》 buf;retVal = send(sHost, buf, strlen(buf), 0);if (SOCKET_ERROR == retVal){cout 《《 "send failed!" 《《 endl;closesocket(sHost); //关闭套接字WSACleanup(); //释放套接字资源return -1;}//RecvLine(sHost, bufRecv);ZeroMemory(bufRecv, BUF_SIZE);recv(sHost, bufRecv,BUF_SIZE , 0); // 接收服务器端的数据， 只接收5个字符cout 《《 endl 《《"从服务器接收数据："《《 bufRecv;cout《《"\n";}//退出closesocket(sHost); //关闭套接字WSACleanup(); //释放套接字资源return 0;}
netty是如何实现即时通讯的
Netty实现即时通讯其实很简单，你可以直接接入即构科技的im sdk，他们家的im sdk整个接入过程很顺畅，支持单聊、群聊、房间聊天，助力丰富业务场景多样性，为每条消息的安全保驾护航，适配 15000+终端设备及外设兼容 25 种平台及语言，真心推荐。
