jviol.com

ひょんなことで、C#.NETで作成したWindowsアプリケーションとTomcat5（Java）で作成したWebアプリケーションとのHTTP通信を行うシステムを作成したので、覚書します。

サーバ側は、テーブル及びビュー単位にSQL抽出クラスを準備して、
各メソッドは、必ずメッセージクラスを介して実行されるように作成していたので、今回の通信は、メッセージクラスを動的に呼び出すだけでできました。※よかったよかった
ですので、Tomcat（Java）側では、クラスとメソッドとフィールドを動的に判断しXMLデータを返すように作ってみました。

おかげで、Strutsの設定も1個だけでした。

今回は、クライアント側のプログラムだけ覚書します。

詳しい方はご指摘お願いしますね（ｗ

なお、気になるサーバ側は次回覚書します。

＜クライアント：C#側＞

—————————————————————————-
■通信実行を指示するクラス

jp.seemo.xml.msg.XXXMLMsg　 ：　XMLデータセット
jp.seemo.xml.XXXMLFacility ：　通信クラス

この２つのクラスを使って、サーバのクラスに対してメッセージを投げてみました。
サーバ側では、動的にクラスやメソッドを実行したいので、以下の様に実行してほしい機能を呼び出しました。

<xml_facility_class> ：　データベースからデータを抽出しXMLデータを生成するクラス
<xml_facility_method> ：　実際に呼び出すメソッド
<xml_message> ：　やり取りするデータを表現する型

private jp.seemo.xml.msg.XXXMLMsg getList()
{
//通信メッセージの作成
jp.seemo.xml.msg.XXXMLMsg inMsg = new jp.seemo.xml.msg.XXXMLMsg();

//通信クラスを生成
jp.seemo.xml.XXXMLFacility xf = new jp.seemo.xml.XXXMLFacility(inMsg);

//通信実行
xf.execute(”<xml_facility_class>”, “<xml_facility_method>”, “<xml_message>”);

//レスポンスデータの取得
jp.seemo.xml.msg.XXXMLMsg bean = (jp.seemo.xml.msg.XXXMLMsg)xf.Items;

return bean;

}

—————————————————————————-
■XML通信を行うアブストラクトクラス

次のアブストラクト・クラスを継承して実際の通信処理を実装してみました。これでいちいち通信ロジックを書かなくてこれ一個でいけますね。
※コード内のTool.showSystemErrorは、システムエラーを簡易処理するメソッドです。

using System;

namespace jp.seemo.xml
{
public abstract class XMLFacility
{

protected System.Data.DataSet _items; //実際のキャリア
protected string class_name; //サーバのクラス名
protected string method_name; //サーバのメソッド名
protected string message_class; //サーバのメッセージ名

public XMLFacility(System.Data.DataSet inMsg)
{
this._items = inMsg; //送り側のメッセージ
}

public XMLFacility()
{}

/// <summary>
/// Java側で動的にクラス・メソッド・メッセージを選択する為に名称をセットしリクエストする
/// </summary>
/// <param name=”class_name”>クラス名</param>
/// <param name=”method_name”>メソッド名</param>
/// <param name=”message_class”>メッセージキャリア名</param>
public void execute(string class_name, string method_name, string message_class)
{
this.class_name = class_name;
this.method_name = method_name;
this.message_class = message_class;

httpRequest(); //実際の通信
}

/// <summary>
/// レスポンスデータを解析し、データをセットします。
/// </summary>
/// <param name=”resStream”></param>
protected void httpResponse(System.Xml.XmlTextReader resStream)
{
// XMLをリード
_items.Clear();
_items.ReadXml(resStream);
}

/// <summary>
/// 要求をPOSTし、結果をサーバから得ます。
/// </summary>
protected void httpRequest()
{
const string methodName = “httpRequest”;

System.IO.Stream reqStream = null;
System.Net.WebResponse res = null;
System.IO.Stream resStream = null;
System.IO.TextReader sr = null;

try
{

//バイト型配列に変換
byte[] postDataBytes = System.Text.Encoding.ASCII.GetBytes(postData());

//Requestの作成
System.Net.WebRequest req = System.Net.WebRequest.Create(”http://localhost:8080/xxxx/xmlf.do”);

req.Method = “POST”;
req.ContentType = “application/x-www-form-urlencoded”;
req.ContentLength = postDataBytes.Length;

reqStream = req.GetRequestStream();
reqStream.Write(postDataBytes, 0, postDataBytes.Length);
reqStream.Close();

//response
res = req.GetResponse();
resStream = res.GetResponseStream();

//受信して表示
sr = new System.IO.StreamReader(resStream, Tool.encode);

System.Xml.XmlTextReader tr = new System.Xml.XmlTextReader(sr);

//TEST
//Console.WriteLine(sr.ReadToEnd());

httpResponse(tr);

}
catch(Exception ex)
{
Tool.showSystemError(”XMLFacility”, methodName, ex);
}
finally
{
try
{
if (sr != null)
{
sr.Close();
}
}
catch(Exception ex)
{
Tool.showSystemError(”XMLFacility”, methodName, ex);
}

try
{
if (reqStream != null)
{
reqStream.Close();
}
}
catch(Exception ex)
{
Tool.showSystemError(”XMLFacility”, methodName, ex);
}

try
{
if (resStream != null)
{
resStream.Close();
}
}
catch(Exception ex)
{
Tool.showSystemError(”XMLFacility”, methodName, ex);
}

try
{
if (res != null)
{
res.Close();
}
}
catch(Exception ex)
{
Tool.showSystemError(”XMLFacility”, methodName, ex);
}

}
}

/// <summary>
/// レスポンスデータ
/// </summary>
public System.Data.DataSet Items
{
get
{
return this._items;
}
}

}
}

—————————————————————————-
■XMLFacility（通信用クラス）を継承して作成したクラス

POSTデータをセットして、送信するクラスを完成させます。

namespace jp.seemo.xml
{
/// <summary>
/// 通信ネタ（POSTデータ）を作成し、通信を行う
/// </summary>
public class XXXXMLFacility : XMLFacility
{

private string postData()
{
msg.XXXMLMsg inMsg = (msg.XXXMLMsg)Items;

System.Text.StringBuilder sb = new System.Text.StringBuilder();

int count = inMsg.row.Count;

sb.Append(”class_name=” + System.Web.HttpUtility.UrlEncode(this.class_name));
sb.Append(”&method_name=” + System.Web.HttpUtility.UrlEncode(this.method_name));
sb.Append(”&message_class=” + System.Web.HttpUtility.UrlEncode(this.message_class));

for (int i=0; i<count; i++)
{
sb.Append(”&user_id=” + System.Web.HttpUtility.UrlEncode(inMsg.row[i].user_id, Tool.encode));
sb.Append(”&password=” + System.Web.HttpUtility.UrlEncode(inMsg.row[i].password, Tool.encode));

}

string mystr = sb.ToString();

return mystr;

}

/// <summary>
/// リクエストメッセージを投入する
/// </summary>
/// <param name=”inMsg”></param>
public XXXXMLFacility(System.Data.DataSet inMsg): base(inMsg)
{}

public XXXXMLFacility(){}

}
}

以上です。

PROGRAM SAMPLE