com.JRcServer.net.umsg.engine.UdpMessageEngine
|
|||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | ||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | ||||||||
java.lang.Object
public class UdpMessageEngine
UDP-Messageエンジン.
非同期通信を行うエンジン処理をサポートします.
このオブジェクトはUDPプロトコルによる長文送信/受信を可能にした
通信プロトコルです.通常UDPでは、通信到達を保証しませんがこのオブジェクトは
通信到達を保証します.
しかしUDPであることから、到達順位は保証されません.
このオブジェクトの利点として、TCP/IPとは違い相互接続数が多い場合、コストが少なくて済みます.
しかし、相互接続数が少ない場合はTCP/IPを利用した方が、コストが少なく済みます.
利用状況に応じて利用してください.
| コンストラクタの概要 | |
|---|---|
UdpMessageEngine()
コンストラクタ. |
|
| メソッドの概要 | |
|---|---|
void |
close()
クローズ処理. |
int |
getDestroyReceivePacketTime()
受信パケット破棄時間を取得. |
int |
getPacketLength()
送受信パケット長を取得. |
int |
getReceiveCoreThread()
受信コアスレッド数を取得. |
java.net.InetAddress |
getReceiveLocalAddress()
受信ローカルアドレスを取得. |
int |
getReceiveLocalPort()
受信ローカルポートを取得. |
int |
getReceiveThread()
受信スレッド数を取得. |
int |
getSendCoreThread()
送信コアスレッド数を取得. |
java.net.InetAddress |
getSendLocalAddress()
送信ローカルアドレスを取得. |
int |
getSendLocalPort()
送信ローカルポートを取得. |
int |
getSendThread()
送信スレッド数を取得. |
boolean |
isOpen()
オープンチェック. |
void |
open()
オープン処理. |
void |
open(java.net.InetAddress sndAddr,
int sndPort,
int sndCThread,
int sndThread,
int sndBuffer,
java.net.InetAddress rcvAddr,
int rcvPort,
int rcvCThread,
int rcvThread,
int rcvBuffer,
int rcvDestroyTime,
int packetLength,
ResourceType sndResourceType,
ResourceType rcvResourceType)
オープン処理. |
void |
open(int sndPort,
int sndThread,
int rcvPort,
int rcvThread,
int packetLength)
オープン処理. |
void |
open(int sndPort,
int sndThread,
int rcvPort,
int rcvThread,
int packetLength,
ResourceType resourceType)
オープン処理. |
byte[] |
receive(ConnectAddress out)
受信処理. |
byte[] |
receive(ConnectAddress out,
int timeout)
受信処理. |
BinResource |
receiveByBinResource(ConnectAddress out)
受信処理. |
BinResource |
receiveByBinResource(ConnectAddress out,
int timeout)
受信処理. |
void |
send(ConnectAddress conn,
byte[] binary)
送信処理. |
void |
send(java.net.InetAddress addr,
int port,
byte[] binary)
送信処理. |
void |
sendByBinResource(ConnectAddress conn,
BinResource binary)
送信処理. |
void |
sendByBinResource(java.net.InetAddress addr,
int port,
BinResource binary)
送信処理. |
| クラス java.lang.Object から継承されたメソッド |
|---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| コンストラクタの詳細 |
|---|
public UdpMessageEngine()
| メソッドの詳細 |
|---|
public final void open()
public final void open(int sndPort,
int sndThread,
int rcvPort,
int rcvThread,
int packetLength)
throws InputException
sndPort - 送信バインド先ポート番号を設定します.sndThread - 送信スレッドサイズを設定します.rcvPort - 受信バインド先ポート番号を設定します.rcvThread - 受信スレッドサイズを設定します.packetLength - パケットサイズを設定します.InputException - 入力例外.
public final void open(int sndPort,
int sndThread,
int rcvPort,
int rcvThread,
int packetLength,
ResourceType resourceType)
throws InputException
sndPort - 送信バインド先ポート番号を設定します.sndThread - 送信スレッドサイズを設定します.rcvPort - 受信バインド先ポート番号を設定します.rcvThread - 受信スレッドサイズを設定します.packetLength - パケットサイズを設定します.resourceType - リソースタイプを設定します.
InputException - 入力例外.
public final void open(java.net.InetAddress sndAddr,
int sndPort,
int sndCThread,
int sndThread,
int sndBuffer,
java.net.InetAddress rcvAddr,
int rcvPort,
int rcvCThread,
int rcvThread,
int rcvBuffer,
int rcvDestroyTime,
int packetLength,
ResourceType sndResourceType,
ResourceType rcvResourceType)
throws InputException
sndAddr - 送信バインド先アドレスを設定します.sndPort - 送信バインド先ポート番号を設定します.sndCThread - 送信コアスレッドサイズを設定します.sndThread - 送信スレッドサイズを設定します.sndBuffer - 送信バッファ長を設定します.rcvAddr - 受信バインド先アドレスを設定します.rcvPort - 受信バインド先ポート番号を設定します.rcvCThread - 受信コアスレッドサイズを設定します.rcvThread - 受信スレッドサイズを設定します.rcvBuffer - 受信バッファ長を設定します.rcvDestroyTime - 受信パケット削除時間を設定します.packetLength - パケットサイズを設定します.sndResourceType - 送信リソースタイプを設定します.rcvResourceType - 受信リソースタイプを設定します.
InputException - 入力例外.public final void close()
public final void send(java.net.InetAddress addr,
int port,
byte[] binary)
addr - 送信対象のアドレスを設定します.port - 送信対象のポート番号を設定します.binary - 送信電文を設定します.
public final void send(ConnectAddress conn,
byte[] binary)
conn - 送信対象のアドレス+ポート番号を設定します.binary - 送信電文を設定します.
public final void sendByBinResource(java.net.InetAddress addr,
int port,
BinResource binary)
addr - 送信対象のアドレスを設定します.port - 送信対象のポート番号を設定します.binary - 送信電文を設定します.
public final void sendByBinResource(ConnectAddress conn,
BinResource binary)
conn - 送信対象のアドレス+ポート番号を設定します.binary - 送信電文を設定します.public final byte[] receive(ConnectAddress out)
out - 受信元のアドレス/ポート番号が返されます.
public final byte[] receive(ConnectAddress out,
int timeout)
throws ConnectTimeoutException,
ExecutionException
out - 受信元のアドレス/ポート番号が返されます.timeout - 受信タイムアウト値を設定します.ConnectTimeoutException - 受信タイムアウト例外.
ExecutionException - 実行例外.public final BinResource receiveByBinResource(ConnectAddress out)
out - 受信元のアドレス/ポート番号が返されます.
public final BinResource receiveByBinResource(ConnectAddress out,
int timeout)
throws ConnectTimeoutException,
ExecutionException
out - 受信元のアドレス/ポート番号が返されます.timeout - 受信タイムアウト値を設定します.ConnectTimeoutException - 受信タイムアウト例外.
ExecutionException - 実行例外.public final java.net.InetAddress getSendLocalAddress()
public final int getSendLocalPort()
public final int getSendCoreThread()
public final int getSendThread()
public final java.net.InetAddress getReceiveLocalAddress()
public final int getReceiveLocalPort()
public final int getReceiveCoreThread()
public final int getReceiveThread()
public final int getPacketLength()
public final int getDestroyReceivePacketTime()
public final boolean isOpen()
|
|||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | ||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | ||||||||