// 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开源即时通讯软件上的相关推荐

  1. php 利用redis写一个聊天室,使用Redis完成聊天室功能

    Redis提供了Pub/Sub(发布/订阅)模式的消息机制.发布者向指定频道发布消息,订阅了该频道的订阅者就可以获取消息.通过该机制,我们可以完成聊天室.公告牌等功能. 首先,来介绍下关于pub/su ...

  2. 撸一个聊天室(vue+koa2+websokect+mongodb)

    撸一个聊天室(vue+koa2+websokect+mongodb) 本篇博客主要介绍聊天室项目,作者学习vue和node时间较短,若有什么错误或建议,欢迎指出,谢谢~ 贴上源码链接 -> 源码 ...

  3. C++网络:IO复用epoll服务器-附带网络聊天室代码实例

    //! //! C++网络:IO复用epoll服务器-附带网络聊天室代码实例 //! //! ===== IO复用简介 ===== //! 众所周知,在LINUX中有一切皆文件的说法,将文件视为一种I ...

  4. emqttd java 即时通讯_使用Emqttd搭建一个聊天室

    前言 由于项目需要,目前需要使用Emqttd搭建一个聊天室,自己写了个demo,特记录下来 代码 使用IDEA搭建一个Spring Boot工程 pom.xml文件,此处我只列出dependencie ...

  5. java netty聊天室_netty实现消息中心(二)基于netty搭建一个聊天室

    前言 上篇博文(netty实现消息中心(一)思路整理 )大概说了下netty websocket消息中心的设计思路,这篇文章主要说说简化版的netty聊天室代码实现,支持群聊和点对点聊天. 此demo ...

  6. node+socket.io 实现一个聊天室

    我们只做简单的实现,不接入数据库,nodejs也不使用express和koa等框架 因此依赖只有两个: 1.socket.io 2.mime(用于获取静态资源时获取文件的mime类型) 安装命令: n ...

  7. python聊天室设计_如何使用 Python 开发一个聊天室?

    ​接下来我们就使用 Python 来操作 socket ,实现一个聊天室的一些主要功能.首先我们来回想下,一般的聊天室都是怎样的,有多个用户可以同时在线,他们可以实时获取到消息,实时发送消息. 服务端 ...

  8. 2021-06-14 Socketio学习使用搭建一个聊天室

    Socketio搭建一个聊天室 前言 本次实验所用编程语言为HTML以及javascript和JQurey语言和Socketio框架,所用编辑文本工具为VS code. 注意事项 (1)前端编程注意H ...

  9. GTK+实现linux聊天室代码详解-clientr端

    查看原代码请点击此超链接 注意!!此聊天室对红帽无兼容.需在其他linux系统上运行,如"深度". 加油学习! GTK+实现linux聊天室代码详解-server端:GTK+实现l ...

最新文章

  1. 用python绘制柱状图标题-如何用Python绘制3D柱形图
  2. 合并两个有序的单链表
  3. 自编码器及相关变种算法简介
  4. Android调用系统软件打开文件(包括apk文件)
  5. 机器学习笔记1(K-近邻算法)
  6. 写题过程中碰见的小问题
  7. 非顺序控制结构的c语言语法是怎样的,流程控制语句:顺序结构和选择结构
  8. Python shutil文件操作、文件夹操作
  9. 元宵节,程序员用 Python 送你一盏 3D 花灯
  10. 二级缓存:EHCache的使用
  11. 在mysql中怎么存储表情符号,如何在MySQL数据库中存储表情符号字符
  12. zepto,kissy前端框架实现跨域
  13. stm32实验报告心得体会_STM32单片机红外遥控MP3实验报告
  14. html+css仿写小米商城
  15. 新塘单片机烧写器_新唐MCU常用的工具软件
  16. errorC1083 无法打开源文件 c1xx
  17. 利用Python删除Android项目中未使用的图片
  18. 将一个自然数拆分为N个自然数
  19. sugarnms如何快速实现网管软件定制开发?
  20. bash:bison未找到命令

热门文章

  1. Netty从零开始(一)
  2. 互联网晚报 | 1月25日 星期二 | 知乎首次举办上星晚会;微信视频号上线首个付费直播间;淘宝天猫“春节不打烊”活动正式上线...
  3. B端产品经理,应从哪些方面理解业务?
  4. 所有的面试问题都可以归结为这三类(附回答套路)
  5. python字典与顺序有关吗_python – 为什么在字典和集合中的顺序是任意的?
  6. 证券期货行业监管大数据治理方案研究
  7. 【计算机网络】信息与信号
  8. 【数据结构与算法】二维Kd树的Java实现
  9. 基础系列(1)-- html
  10. Linux基本管理七大流程