Programer

Node.js + Google Protocol Buffer + Express + MySQL (Server 구성)

Unity3D Coroutine + WWW (Client 구성)

0.1초 마다 WebServer에 요청 시도 하는 Client 20개로 TEST 진행

컴퓨터 사항 : I-5 2500K 3.30GHz + RAM 8GB + SSD 구성

// 웹서버
var Express = require('express');
var app = Express();

//protobuf
var fs = require('fs');
var Schema = require('protobuf').Schema;

// protobuf file 읽어 오기
var schema = new Schema(fs.readFileSync('GameMessagePacket.desc'));

app.get('/GameServer/:id', function (request1, response)
{
    var Msg = schema['Message.Login'];

    var Test = Msg.serialize({id : 'hoobboong', password : 'qwer1234'});
    console.log('proto.length:', Test.length);
    response.send(Test);
});
app.listen(3000);

using UnityEngine;
using System.Collections;
using System.IO;

public class NodeJSConnector : MonoBehaviour 
{

	// Use this for initialization
	void Start () 
    {
        download();
	}
	
	// Update is called once per frame
	void Update () 
    {
	
	}

    private void download()
    {
        StartCoroutine(work());
    }

    private IEnumerator work()
    {
        WWW www = new WWW("http://127.0.0.1:3000/GameServer/hoobboong");

        yield return www;

        using (MemoryStream MemStream = new MemoryStream(www.bytes))
        {
            Message.Login LoginMsg = ProtoBuf.Serializer.Deserialize(MemStream);
            Debug.Log(LoginMsg.id);
            Debug.Log(LoginMsg.password);
        }
    }
}

#include "fstream"

std::ofstream		fOutDataFile;	// 파일 생성 및 입력
std::ifstream		fInDataFile;	// 파일 읽어 오기

// 파일 생성
{
	// 바이너리 값을 입력 할 수 있도록 생성
	fOutDataFile.open( "DataFile.dat", std::ios_base::binary );

	if ( fOutDataFile.fail() )
	{
		return;
	}
}

// INT형 쓰기
{
	int		nValue;

	fOutDataFile.write( (const char*)nValue, sizeof(nValue) );
}

// String형 쓰기
{
	std::string strValue = "MonsterName";
	int			nSize	 = strValue.size();

	fOutDataFile.write( (const char*)nSize, sizeof(nSize) );
	fOutDataFile.write( strValue.c_str(), nSize );
}

// 파일 읽기
{
	int nOpenMode = std::ios_base::in || std::ios_base::binary;

	fInDataFile.open( "DataFile.dat", nOpenMode );

	if ( fInDataFile.fail() )
	{
		return;
	}
}

// INT형 읽기
{
	int		Value = 0;

	fInDataFile.read( (char*)&Value, sizeof(Value) );
}

// String형 읽기
{
	int			nSize		= 0;	
	char		Buf[512]	= "";
	std::string	strValue	= "";

	fInDataFile.read( (char*)&nSize, sizeof(nSize) );
	fInDataFile.read( Buf, nSize);

	strValue = Buf;
}

#include "sstream"

{
	std::string			strString;
	std::ostringstream	ost;
	int					nNumber = 100;

	ost.str("");
	ost << nNumber;

	strString += ost.str();
}

CWinThread*		WinThread = NULL;

// 쓰레드로 처리할 루프
UINT __cdecl ThreadLoop(LPVOID pParam)
{
	BOOL *pbContinue = (BOOL *)pParam;

	while(*pbContinue)
	{
		Sleep(1);
	}

	return 0;
}

// 쓰레드 시작
WinThread = AfxBeginThread(ThreadLoop, this);

// 쓰레드 종료
DWORD nExitCode = NULL ;

GetExitCodeThread( WinThread->m_hThread, &nExitCode ) ;
TerminateThread( WinThread->m_hThread, nExitCode ) ;

#include "boost shared_ptr.hpp"

class CEntity
{
private:
	int	m_nEntityType;

public:
	void SetEntiyType(int a_nEntityType)	{ m_nEntityType = a_nEntityType; }
	int  GetEntiyType(void)					{ return m_nEntityType; }

public:
	CEntity(void) {}
	~CEntity(void) {}
};

{
	// 선언 및 동적 할당
	// 스마트 포인터의 경우 선언과 동시에 동적할당을 해 주어야 한다.
	boost::shared_ptr		spEntity(new CEntity);

	// 포인터 처럼 사용 하면 된다.
	spEntity->SetEntiyType( TY_MONSTER );
	int nEntityType		= spEntity->GetEntiyType();

	 // 포인터 얻어 오기
	CEntity* pentity	= spEntity.get();
}

#include