C++写的一个聊天室代码,用于XEIM开源即时通讯软件上的
// C++写的一个聊天室代码,用于XEIM开源即时通讯软件上的,欢迎大家一起交流。
// XEIM_ChatroomDlg.cpp : implementation file
// [即时通讯软件],[XEIM],[飞鸽传书]
#include "stdafx.h"
#include "xeim.h"
#include "xeimDlg.h"
#include "XEIM_ChatroomDlg.h"
#include "XEIM_Text.h"
#include "XEIM_Message.h"
#include "XEIM_ChatDlg.h"
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
/
// CXEIM_ChatroomDlg dialog
CXEIM_ChatroomDlg::CXEIM_ChatroomDlg(CWnd* pParent /*=NULL*/)
: CDialog(CXEIM_ChatroomDlg::IDD, pParent)
{
//{{AFX_DATA_INIT(CXEIM_ChatroomDlg)
// NOTE: the ClassWizard will add member initialization here
m_bServerRunning = FALSE;
m_hServer = INVALID_HANDLE_VALUE;
//}}AFX_DATA_INIT
m_hIcon = AfxGetApp()->LoadIcon(IDI_ICONCHAT);
}
CXEIM_ChatroomDlg::CXEIM_ChatroomDlg(LPCTSTR lpszUID, CWnd* pParent/* = NULL*/)
{
m_hIcon = AfxGetApp()->LoadIcon(IDI_ICONCHAT);
m_bServerRunning = FALSE;
m_hServer = INVALID_HANDLE_VALUE;
CString strUID = lpszUID;
if (! strUID.IsEmpty())
{
m_bServerRunning = TRUE;
if (! m_client.xConnect(M()->T.GetContactIP(lpszUID), 9989))
{
MessageBox(m_client.m_strLastError);
return;
}
else
{
DWORD dwTID;
m_client.SetWnd(this);
HANDLE hThread = CreateThread(NULL, 0, SockRecvProc, (LPVOID)&m_client, 0, & dwTID);
if (NULL == hThread)
{
MessageBox("CreateThread(NULL, 0, CreateHTML_Proc, (LPVOID)m_client, 0, & dwTID) failed.");
return;
}
m_mapClient.insert(pair<HANDLE, CXEIMSocket*>(hThread, &m_client));
}
}
}
void CXEIM_ChatroomDlg::AddRecvText(LPCTSTR lpszUser, LPCTSTR lpszData)
{
CTime m_StartTime1 = CTime::GetCurrentTime();
CString csStartTime;
// 信息 发送者 和 发送时间
csStartTime.Format(_T("%s - %s/r/n"), M()->T.GetContactDisplayName(lpszUser),
m_StartTime1.Format(_T("%H:%M:%S")));
//
int iTotalTextLength = m_richMsg.GetWindowTextLength();
m_richMsg.SetSel(iTotalTextLength, iTotalTextLength);
m_richMsg.ReplaceSel(csStartTime);
int iStartPos = iTotalTextLength;
CHARFORMAT cf;
cf.cbSize = sizeof(CHARFORMAT);
cf.dwMask = CFM_COLOR | CFM_UNDERLINE | CFM_BOLD;
cf.dwEffects = (unsigned long)~(CFE_AUTOCOLOR | CFE_UNDERLINE | CFE_BOLD);
cf.crTextColor = RGB(0, 128, 0);
int iEndPos = m_richMsg.GetWindowTextLength();
m_richMsg.SetSel(iStartPos, iEndPos);
m_richMsg.SetSelectionCharFormat(cf);
m_richMsg.SetSel(iEndPos, iEndPos);
CString str = lpszData;
int nIdx = 0;
while (nIdx != -1)
{
nIdx = str.Find('/n', nIdx+1);
str.Insert(nIdx+1, " ");
}
str += "/r/n";
m_richMsg.ReplaceSel(str);
m_richMsg.SetSel(iEndPos, m_richMsg.GetWindowTextLength());
cf.crTextColor = RGB(0, 0, 0);
m_richMsg.SetSelectionCharFormat(cf);
m_richMsg.PostMessage(WM_VSCROLL, SB_BOTTOM,0);
/* m_editAllMessage += lpszUser;
m_editAllMessage += "/r/n";
m_editAllMessage += lpszData;
UpdateData(FALSE);
AfxMessageBox(lpszData);*/
}
void CXEIM_ChatroomDlg::OnAcceptClose()
{
// AfxMessageBox("asdf");
}
void CXEIM_ChatroomDlg::OnRecvData(WPARAM wParam, LPARAM lParam)
{
CXEIMSocket *pclient = (CXEIMSocket*)lParam;
CXEIMData *pData = (CXEIMData*)wParam;
// AfxMessageBox(pData->GetData());
if (pData->GetMessage() == 2)
{
CString strData = pData->GetData();
UINT nLeft = strData.Find("|");
CString strUID = strData.Left(nLeft);
CString strText = strData.Right(strData.GetLength()-nLeft-1);
AddRecvText(strUID, strText);
if (m_bServerRunning) {
map<HANDLE, CXEIMSocket*>::iterator _beg=m_mapClient.begin(),
_end=m_mapClient.end();
for (; _beg != _end; _beg++)
{
_beg->second->xSend(pData->GetData(), pData->GetDataLength());
}
}
}
else if (pData->GetMessage() == 1)
{
CString strData = pData->GetData();
CString strRight = strData;
UINT nIdx = strData.Find("|");
while (-1 != nIdx)
{
CString strUser = strRight.Left(nIdx);
m_listboxUser.AddString(strUser);
CString strk;
strk.Format("%s - %d,%d",strData, nIdx, strData.GetLength());
strRight = strRight.Right(strRight.GetLength()-nIdx-1);
nIdx = strRight.Find("|");
}
}
delete pData;
}
void CXEIM_ChatroomDlg::OnNewClient(WPARAM wParam, LPARAM lParam)
{
CXEIMSocket *pClient = new CXEIMSocket((SOCKET)wParam, (CWnd*)lParam);
DWORD dwTID;
HANDLE hThread = CreateThread(NULL, 0, SockRecvProc, (LPVOID)pClient, 0, & dwTID);
if (NULL == hThread)
{
MessageBox("CreateThread(NULL, 0, CreateHTML_Proc, (LPVOID)this, 0, & dwTID) failed.");
return;
}
m_mapClient.insert(pair<HANDLE, CXEIMSocket*>(hThread, pClient));
CString strUsers;
int nCount = m_listboxUser.GetCount(); // 得到项目总数
for(int i=0; i<nCount; ++ i)
{
CString strText;
m_listboxUser.GetText(i, strText);
strUsers += strText;
strUsers += "|";
}
pClient->xSend1(strUsers, strUsers.GetLength()+1);
// MessageBox(pClient->GetHostAddress());
}
void CXEIM_ChatroomDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CXEIM_ChatroomDlg)
DDX_Control(pDX, IDC_RICHEDIT1, m_richMsg);
DDX_Control(pDX, IDC_LIST1, m_listboxUser);
//}}AFX_DATA_MAP
}
BEGIN_MESSAGE_MAP(CXEIM_ChatroomDlg, CDialog)
//{{AFX_MSG_MAP(CXEIM_ChatroomDlg)
ON_MESSAGE(WM_SERVER_CREATED, OnServerCreated)
ON_MESSAGE(WM_ACCEPT_CLOSE, OnAcceptClose)
ON_MESSAGE(WM_NEW_CLIENT, OnNewClient)
ON_MESSAGE(WM_RECV_DATA, OnRecvData)
ON_BN_CLICKED(IDC_SEND, OnSend)
ON_MESSAGE(XM_EMDBLCLICKTREE, XDoubleClickUserList)
//}}AFX_MSG_MAP
END_MESSAGE_MAP()
/
// CXEIM_ChatroomDlg message handlers
void CXEIM_ChatroomDlg::OnOK()
{
// TODO: Add extra validation here
CDialog::OnOK();
}
void CXEIM_ChatroomDlg::OnCancel()
{
// TODO: Add extra cleanup here
CDialog::OnCancel();
}
void CXEIM_ChatroomDlg::OnSend()
{
// TODO: Add your control notification handler code here
/* UpdateData();
if (m_editSend.IsEmpty())
{
AfxMessageBox("请输入要发送的消息");
return;
}
if (! m_bServerRunning) { // 客户端
m_client.xSend(m_editSend, m_editSend.GetLength()+1);
}
else // 服务端
{
map<HANDLE, CXEIMSocket*>::iterator _beg=m_mapClient.begin(),
_end=m_mapClient.end();
for (; _beg != _end; _beg++)
{
_beg->second->xSend(m_editSend, m_editSend.GetLength()+1);
}
AddRecvText("Server", m_editSend);
}
m_editSend = "";
UpdateData(FALSE);*/
CString str;
GetDlgItemText(IDC_RICHEDIT2, str);
if(str.IsEmpty())
{
MessageBox("请输入消息内容!");
return;
}
if (str.GetLength() > 1024 - 100)
{
CString str2;
str2.Format(_T("你所发的信息太长,请分几次发送,最大 1024 个字符。"), str.GetLength());
MessageBox(str2, _T("警告"), MB_ICONINFORMATION);
return;
}
CString strSend;
strSend.Format(_T("%s|%s"), M()->T.GetLocalUID(), str);
if (! m_bServerRunning)
{
m_client.xSend(strSend, strSend.GetLength()+1);
}
else
{
map<HANDLE, CXEIMSocket*>::iterator
_beg=m_mapClient.begin(),
_end=m_mapClient.end();
for (; _beg != _end; _beg++)
{
_beg->second->xSend(strSend, strSend.GetLength()+1);
}
AddRecvText(M()->T.GetLocalUID(), str);
}
SetDlgItemText(IDC_RICHEDIT2, "");
// m_client.xSend("33",3);
}
void CXEIM_ChatroomDlg::OnServerCreated(WPARAM wParam, LPARAM lParam)
{
XEIM _p = M();
CString strFileString;
strFileString.Format(_T("%s|%s"), XEIM_CHATROOM, m_strChatroomName);
/* map<HTREEITEM, XEIM_User*>::iterator imap
= _p->m_chatroomUsers.begin(),
_end = _p->m_chatroomUsers.end();
// 读取聊天室成员
for (; imap!=_end; ++imap) {
CXEIM_Text xText(imap->second->GetUID(), strFileString);
// 获取用户联系人
XEIM_Message toSend("forward",xText.GetBuffer());
// AfxMessageBox(toSend.GetData());
if(! _p->m_iocp.BuildPackageAndSend(_p->m_serverSocket,Job_UserData,toSend.GetBuffer()))
{
AfxMessageBox("Send not successfull.!");
}
// int nIndex = m_listboxUser.AddString(imap->second->GetDisplayName());
// m_listboxUser.SetItemData(nIndex, imap->first);
}*/
}
BOOL CXEIM_ChatroomDlg::OnInitDialog()
{
CDialog::OnInitDialog();
// Set the icon for this dialog. The framework does this automatically
// when the application's main window is not a dialog
SetIcon(m_hIcon, TRUE); // Set big icon
SetIcon(m_hIcon, FALSE); // Set small icon
// TODO: Add extra initialization here
// 设置聊天室名称
CString strRoomname;
strRoomname.Format(_T("%s - 聊天室"), m_strChatroomName);
SetWindowText(strRoomname);
// 创建 聊天室服务器 线程
/* if (! m_bServerRunning)
{
// 聊天是首先要有自己
CString strSelfName = M()->GetLocalDisplayName();
strSelfName += _T("(主机)");
int nIndex = m_listboxUser.AddString(strSelfName);
m_listboxUser.SetItemData(nIndex, 0);
m_bServerRunning = TRUE;
DWORD dwTID;
m_hServer = CreateThread(NULL, 0, ServerThreadProc, (LPVOID)this, 0, & dwTID);
if (NULL == m_hServer)
{
AfxMessageBox("CreateThread(NULL, 0, CreateHTML_Proc, (LPVOID)this, 0, & dwTID) failed.");
return TRUE;
}
map<SOCKET, XEIM_User*>::iterator imap
= M()->m_chatroomUsers.begin(),
_end = M()->m_chatroomUsers.end();
// 读取聊天室成员
for (; imap!=_end; ++imap) {
int nIndex = m_listboxUser.AddString(imap->second->GetDisplayName());
m_listboxUser.SetItemData(nIndex, imap->first);
}
}
else
{
m_bServerRunning = ! m_bServerRunning;
}
*/
return TRUE; // return TRUE unless you set the focus to a control
// EXCEPTION: OCX Property Pages should return FALSE
}
DWORD CALLBACK CXEIM_ChatroomDlg::SockRecvProc(LPVOID lParam)
{
CXEIMSocket *pclient = (CXEIMSocket*)lParam;
CXEIM_ChatroomDlg *pDlg = (CXEIM_ChatroomDlg*)pclient->GetWnd();
// ::MessageBox(NULL,"","",MB_OK);
while(1)
{
UINT nLen = 0;
char * buf = pclient->xRecv(nLen);
if (nLen > 0)
{
CXEIMData *pData = new CXEIMData(buf, nLen);
if (pDlg)
pDlg->PostMessage(WM_RECV_DATA, (WPARAM)pData, (LPARAM)pclient);
}
delete buf;
}
pclient->xShutdown(SD_BOTH);
pclient->xCloseSocket();
return -1;
}
DWORD CALLBACK CXEIM_ChatroomDlg::ServerThreadProc(LPVOID lParam)
{
CXEIM_ChatroomDlg *pDlg = (CXEIM_ChatroomDlg*)lParam;
//最好不要使用aSocket.Create创建,因为容易会出现10048错误
pDlg->m_svrSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (INVALID_SOCKET == pDlg->m_svrSocket)
{
char szError[256] = {0};
sprintf(szError, "Create Faild: %d", WSAGetLastError());
AfxMessageBox(szError);
return -1;
}
BOOL bOptVal = TRUE;
int bOptLen = sizeof(BOOL);
//设置Socket的选项, 解决10048错误必须的步骤
setsockopt(pDlg->m_svrSocket, SOL_SOCKET, SO_REUSEADDR, (LPSTR)&bOptVal, bOptLen);
// pDlg->m_svrSocket.SetSockOpt(SO_REUSEADDR, (void *)&bOptVal, bOptLen, SOL_SOCKET);
SOCKADDR_IN local;
memset(&local, 0, sizeof(SOCKADDR_IN));
local.sin_addr.s_addr = htonl(INADDR_ANY);
local.sin_family = AF_INET;
local.sin_port = htons(9989);
int ret = bind(pDlg->m_svrSocket, (PSOCKADDR)&local, sizeof(SOCKADDR_IN));
//绑定端口
if (SOCKET_ERROR == ret)
{
char szError[256] = {0};
sprintf(szError, "Bind Faild: %d", WSAGetLastError());
AfxMessageBox(szError);
return -1;
}
//监听
ret = listen(pDlg->m_svrSocket, 10);
if(SOCKET_ERROR == ret)
{
char szError[256] = {0};
sprintf(szError, "Listen Faild: %d", WSAGetLastError());
AfxMessageBox(szError);
return -1;
}
// 通知上级线程 线程服务可以开始了
pDlg->PostMessage(WM_SERVER_CREATED);
while (pDlg->m_bServerRunning)
{
// 接收外部连接
int iAddress = sizeof(SOCKADDR_IN);
SOCKET sClient;
SOCKADDR_IN addrClient;
memset(&addrClient, 0, sizeof(SOCKADDR_IN));
sClient = accept(pDlg->m_svrSocket, (PSOCKADDR)&addrClient, &iAddress);
if (INVALID_SOCKET == sClient)
{
// AfxMessageBox("delete pClient");
pDlg->PostMessage(WM_ACCEPT_CLOSE, 0, 0);
break;
}
else
{
pDlg->PostMessage(WM_NEW_CLIENT, (WPARAM)sClient, (LPARAM)lParam);
// char szRecvMsg[256] = {0};
// char szOutMsg[256] = {0};
//接收客户端内容:阻塞
// sClient.Receive(szRecvMsg, 256);
// sprintf(szOutMsg, "Receive Msg: %s ", szRecvMsg);
// AfxMessageBox("");
// pDlg->GetDlgItemText(IDC_EDIT_LOG, strText);
// strText += szOutMsg;
//aDlg->SetDlgItemText(IDC_EDIT_LOG, strText);
//发送内容给客户端
// serverSocket.Send("Have Receive The Msg", 50);
//关闭
// sClient.Close();
// serverSocket.Close();
}
}
return -1;
}
void CXEIM_ChatroomDlg::ShowAndUpdate()
{
PostMessage(XM_EMDBLCLICKTREE);
}
void CXEIM_ChatroomDlg::XDoubleClickUserList(WPARAM wParam, LPARAM lParam)
{
ShowWindow(SW_SHOW);
GetDlgItem(IDC_RICHEDIT2)->SetFocus();
}
C++写的一个聊天室代码,用于XEIM开源即时通讯软件上的相关推荐
- php 利用redis写一个聊天室,使用Redis完成聊天室功能
Redis提供了Pub/Sub(发布/订阅)模式的消息机制.发布者向指定频道发布消息,订阅了该频道的订阅者就可以获取消息.通过该机制,我们可以完成聊天室.公告牌等功能. 首先,来介绍下关于pub/su ...
- 撸一个聊天室(vue+koa2+websokect+mongodb)
撸一个聊天室(vue+koa2+websokect+mongodb) 本篇博客主要介绍聊天室项目,作者学习vue和node时间较短,若有什么错误或建议,欢迎指出,谢谢~ 贴上源码链接 -> 源码 ...
- C++网络:IO复用epoll服务器-附带网络聊天室代码实例
//! //! C++网络:IO复用epoll服务器-附带网络聊天室代码实例 //! //! ===== IO复用简介 ===== //! 众所周知,在LINUX中有一切皆文件的说法,将文件视为一种I ...
- emqttd java 即时通讯_使用Emqttd搭建一个聊天室
前言 由于项目需要,目前需要使用Emqttd搭建一个聊天室,自己写了个demo,特记录下来 代码 使用IDEA搭建一个Spring Boot工程 pom.xml文件,此处我只列出dependencie ...
- java netty聊天室_netty实现消息中心(二)基于netty搭建一个聊天室
前言 上篇博文(netty实现消息中心(一)思路整理 )大概说了下netty websocket消息中心的设计思路,这篇文章主要说说简化版的netty聊天室代码实现,支持群聊和点对点聊天. 此demo ...
- node+socket.io 实现一个聊天室
我们只做简单的实现,不接入数据库,nodejs也不使用express和koa等框架 因此依赖只有两个: 1.socket.io 2.mime(用于获取静态资源时获取文件的mime类型) 安装命令: n ...
- python聊天室设计_如何使用 Python 开发一个聊天室?
接下来我们就使用 Python 来操作 socket ,实现一个聊天室的一些主要功能.首先我们来回想下,一般的聊天室都是怎样的,有多个用户可以同时在线,他们可以实时获取到消息,实时发送消息. 服务端 ...
- 2021-06-14 Socketio学习使用搭建一个聊天室
Socketio搭建一个聊天室 前言 本次实验所用编程语言为HTML以及javascript和JQurey语言和Socketio框架,所用编辑文本工具为VS code. 注意事项 (1)前端编程注意H ...
- GTK+实现linux聊天室代码详解-clientr端
查看原代码请点击此超链接 注意!!此聊天室对红帽无兼容.需在其他linux系统上运行,如"深度". 加油学习! GTK+实现linux聊天室代码详解-server端:GTK+实现l ...
最新文章
- 用python绘制柱状图标题-如何用Python绘制3D柱形图
- 合并两个有序的单链表
- 自编码器及相关变种算法简介
- Android调用系统软件打开文件(包括apk文件)
- 机器学习笔记1(K-近邻算法)
- 写题过程中碰见的小问题
- 非顺序控制结构的c语言语法是怎样的,流程控制语句:顺序结构和选择结构
- Python shutil文件操作、文件夹操作
- 元宵节,程序员用 Python 送你一盏 3D 花灯
- 二级缓存:EHCache的使用
- 在mysql中怎么存储表情符号,如何在MySQL数据库中存储表情符号字符
- zepto,kissy前端框架实现跨域
- stm32实验报告心得体会_STM32单片机红外遥控MP3实验报告
- html+css仿写小米商城
- 新塘单片机烧写器_新唐MCU常用的工具软件
- errorC1083 无法打开源文件 c1xx
- 利用Python删除Android项目中未使用的图片
- 将一个自然数拆分为N个自然数
- sugarnms如何快速实现网管软件定制开发?
- bash:bison未找到命令
热门文章
- Netty从零开始(一)
- 互联网晚报 | 1月25日 星期二 | 知乎首次举办上星晚会;微信视频号上线首个付费直播间;淘宝天猫“春节不打烊”活动正式上线...
- B端产品经理,应从哪些方面理解业务?
- 所有的面试问题都可以归结为这三类(附回答套路)
- python字典与顺序有关吗_python – 为什么在字典和集合中的顺序是任意的?
- 证券期货行业监管大数据治理方案研究
- 【计算机网络】信息与信号
- 【数据结构与算法】二维Kd树的Java实现
- 基础系列(1)-- html
- Linux基本管理七大流程