Socketサーバクラス [詳解]

#include <TnbSocket.h>

CSocketServer の継承関係図

公開メンバ関数
void	Close (void)
	[実行] サーバをクローズ [詳解]

	CSocketServer (void)
	コンストラクタ [詳解]

void	DisableReportViewer (void)
	[設定] レポートビュワー停止. [詳解]

void	Disconnect (SOCKET so)
	[実行] 指定ソケットの切断 [詳解]

void	Disconnect (void)
	[実行] 全ソケットの切断. [詳解]

INT_PTR	GetConnectedSockets (CSocketVector *P=NULL) const
	[取得] 接続ソケット一覧と数を取得 [詳解]

int	GetIdleInterval (void) const
	[取得] アイドルイベント間隔取得 [詳解]

virtual DWORD	GetInterfaceId (void) const
	[取得] インターフェースID取得 [詳解]

bool	GetPeerName (CSocketAddress &_address, SOCKET so)
	[取得] 指定ソケットの接続情報取得 [詳解]

virtual DWORD	GetReportID (void) const
	[取得] コミュニケーションID. [詳解]

virtual CStr	GetReportName (void) const
	[取得] コミュニケーション名. [詳解]

virtual bool	IsAlive (void) const
	[確認] Aliveチェック. [詳解]

bool	IsConnect (SOCKET so) const
	[確認] 指定ソケットの接続確認 [詳解]

virtual bool	IsConnect (void) const
	[確認] 接続チェック [詳解]

virtual bool	Lock (DWORD dwTime=INFINITE) const
	[排他] ロック [詳解]

bool	Open (const CSocketAddress &address)
	[実行] オープン. [詳解]

virtual void	Purge (void)
	[設定] パージ. [詳解]

CThreadStatus &	ReferThreadStatus (void)
	[参照] 受信スレッド状態参照. [詳解]

virtual bool	Send (size_t dataSize, LPCVOID lpcvData)
	[実行] 全部に送信. [詳解]

bool	Send (SOCKET so, size_t dataSize, LPCVOID lpcvData)
	[実行] データ送信 [詳解]

void	SetConnectMax (size_t max)
	[設定] 接続可能数. [詳解]

void	SetDelayMode (bool boIsDelay)
	[設定] 送信遅延モード設定 [詳解]

virtual void	SetIdleEventMode (int iInterval=0)
	[設定] アイドルイベント設定 [詳解]

virtual void	SetListener (IReport::IListener *piCommListener=NULL)
	[登録] 共通 Listner 登録. [詳解]

void	SetParameter (const CSocketAddress &address)
	[設定] サーバ設定 [詳解]

virtual void	SetSocketListener (IListener *piSocketListener)
	[設定] リスナー登録 [詳解]

virtual bool	Start (void)
	[実行] 開始. [詳解]

virtual void	Stop (void)
	[実行] サーバをクローズ [詳解]

virtual void	Unlock (void) const
	[排他] アンロック [詳解]

bool	WaitConnect (DWORD dwTime) const
	[確認] 接続待ち [詳解]

virtual	~CSocketServer (void)
	デストラクタ [詳解]

静的公開メンバ関数
static CDwordVector	GetMyAddress (void)
	[取得] 自ＩＰアドレス取得. [詳解]

static void	StartUp (void)
	[設定] SOCKET初期化. [詳解]

限定公開メンバ関数
bool	m_OnEvent (const CReportEvent &ev)
	[内部] コールバック通知実行 [詳解]

void	m_OnSend (size_t sizeData, LPCVOID lpcvData)
	[内部] 送信情報通知 [詳解]

void	ToViewer (LPCTSTR lpszText)
	[出力] 文字列出力. [詳解]

void	ToViewer (size_t sizeData, LPCVOID lpcvData)
	[出力] ダンプ出力. [詳解]

詳解

Socketサーバクラス

サーバ用にソケットを用意します。

受信は CAbstractSocket::IListener のサブクラスを登録し行います。
( IReport::IListener でも受信は出来ますが基本機能しかありません)

覚え書き: IReport::ITester を登録しても、受信テストは出来ません ( OnCommTestReceive() はコールされません）。; アイドルイベントは、接続されている全クライアントからの受信がなくなって数ms経った時に、全接続に対して、アイドルイベントが通知されます。各接続毎ではないことにご注意ください。; リスナー内で SendMessage を使う場合、 ReferThreadStatus() で関連ウィンドウを指定する必要があります。 CThread::SetOwnerHwnd() を参照してください。

必要ファイル: TnbSocket.h

日付: 06/04/01 新規作成; 06/04/27 接続可能数をつけた。メソッドでの切断でも Disconnectイベントがあがるようにした。; 06/06/22 pingによる切断監視を追加。; 06/08/31 CommViewer に対応。; 06/09/08 Idleイベントサポート。 IsAlive() / IsConnect() 追加。 CanAccess() 廃止。; 07/06/11 親クラスの Start() メソッドに対応。; 09/01/15 一度必ずListenエラーが発生するのを修正。; 09/02/27 リトライ待ち処理を改善。; 09/08/27 SetReceiveThreadPriority() 追加。構成変更。; 09/08/27 アドレス指定に CSocketAddress を使うように変更。; 09/09/10 SetReceiveThreadPriority() 廃止、 GetReceiveThreadStatusGet() 追加。; 10/03/19 ReferThreadStatus() 追加。; 11/06/14 GetReportID() メソッドの戻り値変更。

TnbSocket.h の 1258 行目に定義があります。

構築子と解体子

◆ CSocketServer()

CSocketServer ( void )

コンストラクタ

TnbSocket.h の 1264 行目に定義があります。

◆ ~CSocketServer()

virtual ~CSocketServer ( void )

virtual

デストラクタ

TnbSocket.h の 1270 行目に定義があります。

関数詳解

◆ Close()

void Close ( void )

[実行] サーバをクローズ

TnbSocket.h の 1513 行目に定義があります。

◆ DisableReportViewer()

void DisableReportViewer ( void )

inherited

[設定] レポートビュワー停止.

本メソッドを使用すると、通信ログの出力を行いません。デフォルトは、出力を行います（ただしビルドの設定にもよります）。

TnbAbstractReport.h の 150 行目に定義があります。

◆ Disconnect() [1/2]

void Disconnect ( SOCKET so )

[実行] 指定ソケットの切断

引数

so Sソケット

TnbSocket.h の 1445 行目に定義があります。

◆ Disconnect() [2/2]

void Disconnect ( void )

[実行] 全ソケットの切断.

接続しているすべてを一度切断します。すぐに接続待ちしますので、すぐに接続される可能性も有ります。

TnbSocket.h の 1496 行目に定義があります。

◆ GetConnectedSockets()

INT_PTR GetConnectedSockets ( CSocketVector * P = NULL ) const

[取得] 接続ソケット一覧と数を取得

引数

[out] P ソケット一覧。NULLなら格納しません。

戻り値: 接続ソケット数

TnbSocket.h の 1388 行目に定義があります。

◆ GetIdleInterval()

int GetIdleInterval ( void ) const

inherited

[取得] アイドルイベント間隔取得

戻り値

0	アイドルイベント発生無し
1以上	間隔(ms)

TnbAbstractReport.h の 107 行目に定義があります。

◆ GetInterfaceId()

virtual DWORD GetInterfaceId ( void ) const

virtualinherited

[取得] インターフェースID取得

戻り値: ID

IReportを実装しています。

TnbAbstractReport.h の 78 行目に定義があります。

◆ GetMyAddress()

static CDwordVector GetMyAddress ( void )

staticinherited

[取得] 自ＩＰアドレス取得.

自分のＩＰアドレスを取得します。２つ以上ある場合があります。

戻り値: 自分のＩＰアドレス

TnbSocket.h の 520 行目に定義があります。

◆ GetPeerName()

bool GetPeerName	(	CSocketAddress &	_address,
		SOCKET	so
	)

[取得] 指定ソケットの接続情報取得

引数

[out]	_address	アドレス&ポート
[in]	so	ソケット

戻り値

true	アドレスとポート取得成功。
false	失敗。

TnbSocket.h の 1436 行目に定義があります。

◆ GetReportID()

virtual DWORD GetReportID ( void ) const

virtual

[取得] コミュニケーションID.

TNBVIW_KIND_??? + PORT を返します。

覚え書き: 開発用のメソッドです。

戻り値: ID

IReportを実装しています。

TnbSocket.h の 1302 行目に定義があります。

◆ GetReportName()

virtual CStr GetReportName ( void ) const

virtual

[取得] コミュニケーション名.

覚え書き: 開発用のメソッドです。

戻り値: 名前

IReportを実装しています。

TnbSocket.h の 1291 行目に定義があります。

◆ IsAlive()

virtual bool IsAlive ( void ) const

virtual

[確認] Aliveチェック.

Open() メソッドが実行されている状態か、チェックします。

戻り値

true	開始している。
false	停止している。

IReportを実装しています。

TnbSocket.h の 1456 行目に定義があります。

◆ IsConnect() [1/2]

bool IsConnect ( SOCKET so ) const

[確認] 指定ソケットの接続確認

引数

so ソケット

戻り値

true	接続中
false	切断中

TnbSocket.h の 1404 行目に定義があります。

◆ IsConnect() [2/2]

virtual bool IsConnect ( void ) const

virtual

[確認] 接続チェック

戻り値

true	一つ以上接続中。
false	一つも接続していない。

IReportを実装しています。

TnbSocket.h の 1466 行目に定義があります。

◆ Lock()

virtual bool Lock ( DWORD dwTime = INFINITE ) const

virtualinherited

[排他] ロック

注意: 他のクラスのLock()メソッドとは異なり、dwTimeは無視され、 INFINITEとして動作します。つまりどんな値を入れても、ロック出来るまでリターンされません。

引数

dwTime 値は無視されます。

戻り値: true 固定

ISynchronizedを実装しています。

CSyncSectionExで再実装されています。

TnbSync.h の 148 行目に定義があります。

◆ m_OnEvent()

bool m_OnEvent ( const CReportEvent & ev )

protectedinherited

[内部] コールバック通知実行

引数

ev 通知する内容

戻り値

true	正常
false	切断要求

TnbAbstractReport.h の 178 行目に定義があります。

◆ m_OnSend()

void m_OnSend	(	size_t	sizeData,
		LPCVOID	lpcvData
	)

protectedinherited

[内部] 送信情報通知

覚え書き: 処理は開発用TRACEのみ

引数

sizeData	送信するデータ長。
lpcvData	送信するデータ。

TnbAbstractReport.h の 163 行目に定義があります。

◆ Open()

bool Open ( const CSocketAddress & address )

[実行] オープン.

サーバをオープンし通信を開始します。

引数

address ポートNO＆待ち受けるアドレス。

戻り値

true	成功
false	失敗

TnbSocket.h の 1377 行目に定義があります。

◆ Purge()

virtual void Purge ( void )

virtualinherited

[設定] パージ.

通信のゴミを浄化

覚え書き: 本クラスでは何もしません。

IReportを実装しています。

CBufferingReporter, CCommunicationReporterで再実装されています。

TnbAbstractReport.h の 117 行目に定義があります。

◆ ReferThreadStatus()

CThreadStatus & ReferThreadStatus ( void )

[参照] 受信スレッド状態参照.

戻り値

スレッド状態の参照.

TnbSocket.h の 1525 行目に定義があります。

◆ Send() [1/2]

virtual bool Send	(	size_t	dataSize,
		LPCVOID	lpcvData
	)

virtual

[実行] 全部に送信.

接続しているすべてに送信します。

引数

dataSize	データサイズ
lpcvData	データ

戻り値

true	成功
false	失敗

IReportを実装しています。

TnbSocket.h の 1479 行目に定義があります。

◆ Send() [2/2]

bool Send	(	SOCKET	so,
		size_t	dataSize,
		LPCVOID	lpcvData
	)

[実行] データ送信

引数

so	ソケット
dataSize	データサイズ
lpcvData	データ

戻り値

true	成功
false	失敗

TnbSocket.h の 1422 行目に定義があります。

◆ SetConnectMax()

void SetConnectMax ( size_t max )

[設定] 接続可能数.

一つのサーバに接続できる数を制限します。デフォルトは一つです。

覚え書き: サーバをオープンしてからも数の変更が可能です。ただし、現在の接続数より小さくしたとき、切断はされません。

引数

max 接続可能数

TnbSocket.h の 1315 行目に定義があります。

◆ SetDelayMode()

void SetDelayMode ( bool boIsDelay )

[設定] 送信遅延モード設定

覚え書き: 接続する前に設定する必要があります。; デフォルトでは遅延送信モードです。

引数

boIsDelay trueなら遅延送信。falseなら即送信。

TnbSocket.h の 1281 行目に定義があります。

◆ SetIdleEventMode()

virtual void SetIdleEventMode ( int iInterval = 0 )

virtualinherited

[設定] アイドルイベント設定

覚え書き: 受信がない時、指定の間隔でコールバックを発生させることができます。開始後、あるいは受信処理後、指定ms秒後にコールバックが始まります。 Open中に有無の切り替えは可能です。

引数

iInterval Idleイベントをあげる間隔を指定します。０なら、Idleイベントなし。

IReportを実装しています。

CBufferingReporter, CCommunicationReporterで再実装されています。

TnbAbstractReport.h の 90 行目に定義があります。

◆ SetListener()

virtual void SetListener ( IReport::IListener * piCommListener = NULL )

virtualinherited

[登録] 共通 Listner 登録.

覚え書き: 登録できる IReport::IListener は一つだけです。

引数

piCommListener リスナー。省略すると解除になります。

IReportを実装しています。

CBufferingReporterで再実装されています。

TnbAbstractReport.h の 69 行目に定義があります。

◆ SetParameter()

void SetParameter ( const CSocketAddress & address )

[設定] サーバ設定

引数

address ポートNO＆待ち受けるアドレス。

TnbSocket.h の 1327 行目に定義があります。

◆ SetSocketListener()

virtual void SetSocketListener ( IListener * piSocketListener )

virtualinherited

[設定] リスナー登録

覚え書き: リスナーを登録しないと受信情報が受けられません; 登録できる CAbstractSocket::IListener は一つだけです。

引数

piSocketListener リスナー

TnbSocket.h の 466 行目に定義があります。

◆ Start()

virtual bool Start ( void )

virtual

[実行] 開始.

サーバをオープンし通信を開始します。

覚え書き: SetParameter() で設定後、本メソッドを使用します。

戻り値

true	成功
false	失敗

IReportを実装しています。

TnbSocket.h の 1342 行目に定義があります。

◆ StartUp()

static void StartUp ( void )

staticinherited

[設定] SOCKET初期化.

WSAStartup() コールします。すでにコールしている場合は、何もしません。

覚え書き: 通常、ソケット使用時に自動的に使用されますので、コールする必要は有りません。 TNB Library 以外のソケット関係を先に使用する場合、WSAStartup() の代わりに使用してください。

TnbSocket.h の 478 行目に定義があります。

◆ Stop()

virtual void Stop ( void )

virtual

[実行] サーバをクローズ

IReportを実装しています。

TnbSocket.h の 1505 行目に定義があります。

◆ ToViewer() [1/2]

void ToViewer ( LPCTSTR lpszText )

protectedinherited

[出力] 文字列出力.

引数

lpszText 文字列.

TnbAbstractReport.h の 219 行目に定義があります。

◆ ToViewer() [2/2]

void ToViewer	(	size_t	sizeData,
		LPCVOID	lpcvData
	)

protectedinherited

[出力] ダンプ出力.

引数

sizeData	データサイズ.
lpcvData	データ

TnbAbstractReport.h の 210 行目に定義があります。

◆ Unlock()

virtual void Unlock ( void ) const

virtualinherited

[排他] アンロック

ISynchronizedを実装しています。

TnbSync.h の 155 行目に定義があります。

◆ WaitConnect()

bool WaitConnect ( DWORD dwTime ) const

inherited

[確認] 接続待ち

引数

dwTime 待ち時間(ms)

戻り値

true	接続
false	タイムアウト

TnbAbstractReport.h の 127 行目に定義があります。

公開メンバ関数

静的公開メンバ関数

限定公開メンバ関数

詳解

構築子と解体子

◆ CSocketServer()

◆ ~CSocketServer()

関数詳解

◆ Close()

◆ DisableReportViewer()

◆ Disconnect() [1/2]

◆ Disconnect() [2/2]

◆ GetConnectedSockets()

◆ GetIdleInterval()

◆ GetInterfaceId()

◆ GetMyAddress()

◆ GetPeerName()

◆ GetReportID()

◆ GetReportName()

◆ IsAlive()

◆ IsConnect() [1/2]

◆ IsConnect() [2/2]

◆ Lock()

◆ m_OnEvent()

◆ m_OnSend()

◆ Open()

◆ Purge()

◆ ReferThreadStatus()

◆ Send() [1/2]

◆ Send() [2/2]

◆ SetConnectMax()

◆ SetDelayMode()

◆ SetIdleEventMode()

◆ SetListener()

◆ SetParameter()

◆ SetSocketListener()

◆ Start()

◆ StartUp()

◆ Stop()

◆ ToViewer() [1/2]

◆ ToViewer() [2/2]

◆ Unlock()

◆ WaitConnect()