ネットワークゲームへのアプローチ　２　　ソケット（サーバ）

　#include "stdafx.h"
　
　#include <windows.h>
　#include <winsock.h>
　#include <process.h>
　#include <iostream.h>
　#include <stdio.h>
　
　void SockTread(void *sock);
　
　int main()
　{
　
　//----- サーバのコード
　WSADATA Data;
　int result = WSAStartup (MAKEWORD(1,1), &Data);
　// m_List1.AddString(" int result = WSAStartup (MAKEWORD(1,1), &Data);");
　cout << "WSAStartup (MAKEWORD(1,1), &Data);" << endl;
　
　if (WSAStartup(MAKEWORD(1,1), &Data)!=0)
　{
　// m_List1.AddString("Server : Winsock DLL ロードに失敗しました");
　　cout << "Server : Winsock DLL load error" << endl;
　　return 0;
　}
　//----- ＷｉｎｓｏｃｋＤＬＬの初期化に成功した -----------------------
　// m_List1.AddString("Server : Winsock DLL ロードしました");
　cout << "Server : Winsock DLL load success" << endl;
　
　//☆☆☆☆☆☆☆☆☆☆☆☆
　
　//-----ＷｉｎｓｏｃｋＤＬＬの後処理-----------------------------------
　result = WSACleanup();
　
　if (result == 0)
　// m_List1.AddString("WSAStartup clennup 良好に終了しました");
　　cout << "WSAStartup clennup test end" << endl;
　else
　// m_List1.AddString("WSAStartup cleanup error");
　　cout << "WSAStartup cleanup 失敗しました" << endl;
　
　　return 0;
　}
 

　//----- ソケットを作る
　SOCKADDR_IN svAddress, clAddress;// アドレスとポートを指定するためのデータ構造
　SOCKET svSocket, clSocket;

　memset(&svAddress, // svAddress を初期化する
　0 , // 設定する文字
　sizeof(SOCKADDR_IN)); // 文字数

　svAddress.sin_family = AF_INET; // 定型いつも同じ
　svAddress.sin_port = htons(1225);// ポートを指定する
　svAddress.sin_addr.s_addr=htonl(INADDR_ANY); // ここにアドレスがくるはずだが・・・・・
　// svAddress.sin_addr=htonl("128.0.0.1");//INADDR_ANY); // ここにアドレスがくるはずだが・・・・・

　svSocket = socket(AF_INET, // 定型いつも同じ
　SOCK_STREAM, // tcp/ipの場合はこれ
　0); // 最後は０にする
　
　if (svSocket == INVALID_SOCKET)
　{
　　// m_List1.AddString("Server Socket make error");
　　cout << "Server Socket make error" << endl;
　　return 0;
　}
　//----- ソケットを作ことができた
　// m_List1.AddString("Server ソケットを作りました");
　cout << "Server ソケットを作りました" << endl;
　
　//----- ソケットのアドレスを指定する
　result = bind( svSocket,
　(const struct sockaddr *) &svAddress,
　sizeof(svAddress));
　if (result == SOCKET_ERROR)
　{
　// m_List1.AddString("Server Socket アドレス指定が失敗しました");
　　cout << "Server Socket アドレス指定が失敗しました" << endl;
　　return 0;
　}
　//----- ソケットのアドレスを指定することができた
　// m_List1.AddString("Server Socket アドレス指定が成功しました");
　cout << "Server Socket アドレス指定が成功しました" << endl;
　//☆☆☆☆☆☆☆☆☆☆☆☆
　
　//----- ソケットをクロースする
　closesocket(svSocket);
　// m_List1.AddString("Server ソケットをクローズしました");
　cout << "Server ソケットをクローズしました" << endl;
 

　//----- ソケットを接続待ちにする
　result = listen(svSocket, 1);
　if (result == SOCKET_ERROR)
　{
　　// m_List1.AddString("listenが失敗しました");
　　cout << "listenが失敗しました" << endl;
　　closesocket(svSocket);
　　result = WSACleanup();
　　return 0;
　}
　//----- ソケットのアドレスを指定することができた
　// m_List1.AddString("listenが成功しました");
　cout << "listenが成功しました" << endl;

　
　//----- 接続待ちか？
　int limit = 0;
　
　while(1)
　{
　int adlen = sizeof(clAddress);
　
　clSocket=accept // 待機状態にする
　(svSocket,
　(struct sockaddr *) &clAddress,
　&adlen);
　
　if (result == INVALID_SOCKET)
　{
　// m_List1.AddString("待機状態になれませんでした");
　　cout << "待機状態になれませんでした" << endl;

　　break;
　}
　//----- ソケットのアドレスを指定することができた　
　// m_List1.AddString("待機状態になりした");
　cout << "待機状態になりした";
　

　//----- 接続用のスレッドを作成する
　DWORD thread;
　HANDLE threadHandle =
　CreateThread(0,0,
　(LPTHREAD_START_ROUTINE) SockTread,
　(void*)clSocket, 0, &thread);
　
　if (threadHandle == NULL)
　{
　　cout << "Server : thread creation error" << endl;
　　closesocket(clSocket);
　}
　limit ++;
　if( limit > 2 )break;
　}
　
これもおきて破りの無限ループになっています。実際に動かすと、Ａｃｃｅｐｔ部分でハング状態になります。始めこれの原因がわからなかったのですが、データを受信するまで帰ってきません。これはちょっと悩みましたね。
　
でもこれは仕様なので、これでシステムに悪影響があるわけではないので慌てる必要はありません。
　
ともあれ、データが来たらスレッドを起動してまた待機に入ります。そのままだと永遠に終わらないので２回で終わるようにしてあります。
　
次がサーバがデータを待ち構えるために動かすスレッドです。
　
　#define SD_BOTH 0x02
　
　//----- サーバ用スレッド
　void SockTread(void *sock)
　{
　double x;
　
　char *y = "これを送ります1234567890";
　
　int result;
　
　cout << "スレッドを開始します" << endl;
　// ソケットを渡される
　SOCKET clSock=(SOCKET)sock;
　while(1)
　{
　　//----- 受信する
　　result = recv(
　　clSock,
　　(char*)&x,
　　sizeof(double),
　　0);
　//----- ０を受信したらスレッドを終了する
　if(result==0)
　{
　　// m_List1.AddString("Server : clSock : closed;");
　　cout << "Server : clSock : closed;" << endl;
　　break;
　}
　//----- 受信エラーならスレッドを終了する
　else if(result == SOCKET_ERROR)
　{
　　// m_List1.AddString("Server : clSock : recv error");
　　cout << "Server : clSock : recv error" << endl;
　　break;
　}
　else
　//----- うまく受信できた場合は
　{
　　//y = x*x; //----- 受信した数を倍にして
　　//----- 送り返す
　　result = send(
　　clSock,
　　(char*)&y,
　　sizeof(y),
　　0);
　//----- 送信に失敗したらスレッドを終了
　if (result==sizeof(double))
　{
　// m_List1.AddString("Server : clSock : send error");
　　cout << "Server : clSock : send error" << endl;
　　break;
　}
　　// m_List1.AddString("Server : recv : ");
　　//----- 送った値を表示する
　　cout << "Server : recv : " << x << y << endl;
　}
　}
　　//----- データ転送を禁止する
　　cout << "データ転送を中止しました";
　　result = shutdown(clSock, SD_BOTH);
　//----- データ転送を禁止できたら
　if (result == 0)
　　//----- ソケットをクローズして終わり
　　result = closesocket(clSock);
　　cout << "スレッドを終了しました" << endl;
　}