mfc_NetWork_2 - 8BitsCoding/RobotMentor GitHub Wiki

이전 CSocket의 문제점을 해결해보자.

문제는 클라이언트를 2개 이상 사용하면 서버가 죽게된다.

MyUser를 여러개 관래해야한다. -> List 자료구조사용

// MyServer
pirvate:
    //CPtrList;
    CObList m_user_list;
    // 두 가지 List 자료구조가 있고
    // CPtrList - CObject를 상속하지 않는 경우 사용
    // CObList - CObject를 상속하는 경우 사용

// OnAccept
MyUser * p_user = new MyUser;
m_user_list.AddTail(p_user);

Accept(*p_user);

// ...

소멸자에서 메모리 반환

// MyServer::~MyServer
MyUSer *p;
POSITON pos = m_user_list.GetHeadPosition();
while(pos != NULL) {
    p = (MyUser *)m_user_list.GetNext(pos);
    delete p;
}

// MyUser.h
private:
    CObList* mp_user_list;
public:
    MyUser(CObList * ap_user_list);

// MyUser.cpp
MyUser(CObList * ap_user_list)
{
    mp_user_list = ap_user_list;
}

// MyUser::OnClose

ShutDown(2);
Close();

MyUser *p = NULL;
POSITION pos = mp_user_list->GetHeadPosition(), check_pos;
while(pos != NULL) {
    check_pos = pos;
    p = (MyUser*)mp_user_list->GetNext(pos);
    if(p == this) {
        mp_user_list->RemoveAt(check_pos);
        break;
    }
}

if (p != NULL) delete p;

---

Server에서 Client가 보낸 메시지를 ListBox에 추가하도록 기능을 추가하자

// Dlg.h
void AddEventString(const wchar_t * ap_string)
{
    int index = m_evnet_list.InsertString(-1, ap_string);
    m_event_list.SetCurSel(index);
}

private:
    CListBox m_evnet_list;

// MyUser::OnReceive
int value;
Receive(&value, sizeof(int));

CString str;
str.Format(L"%d", value);

((Dlg*)AfxGetMainWnd())->AddEventString(str);

value = 1;
Send(&value, sizeof(int));

// ...

---

문자열을 송/수신하게 해보자.

// ClientDlg 송신 버튼
CString str;
GetDlgItemText(IDC_VALUE_EDIT, str);
unsigned int data_size = (str.GetLength()+1) * 2;
char * p_send_data = new char[sizeof(unsigned int) + data_size];
*(unsigned int*)p_send_data = data_size;
memcpy(p_send_data + sizeof(unsigned int), str.GetBuffer(), data_size);

m_client.Send(p_send_data, sizeof(unsigned int) + data_size);

delete[] p_send_data;

// Server
// MyUser.h
private:
    CObList * mp_user_list;
    char m_is_header = 1;
    unsigned int m_data_size;

// Server
// MyUser::OnReceive

DWORD temp_size;
if(IOCtl(FIONREAD, &temp_size)) {
    // 수신 버퍼에 데이터가 얼마나 들어와있는지 확인
    if(m_is_header) {
        if(temp_size >= sizeof(unsigned_int)) {
            Receive(&m_data_size, sizeof(unsigend int));
            m_is_header != m_is_header;
        }
    }
    else {
        if(temp_size >= m_data_size) {
            char * p_string = new char[m_data_size];
            Receive(p_string, m_data_size);

            ((Dlg*)AfxGetMainWnd())->AddEventString((wchar_t*)p_string);

            delete[] p_string;
            m_is_header != m_is_header;
        }
    }
} else {
    ((Dlg*)AfxGetMainWnd())->AddEventString(L"수신에 문제가 있습니다.!!");
}

// ...

---