Ví dụ mẫu .Net Remoting & Windows Services

namespace ProxyObject{

public class PrimeProxy:MarshalByRefObject{//Biến lưu số lần client gọi hàm lấy danh sách nguyên tố

private int m_RequestNumber = 0;

//Biến lưu tên Client hiện tại gọi hàm

private string m_strCurrentClient = “”;

//Biến lưu danh sách tên các client đã connect tới server

private List<string> m_listClient = new List<string>();

//hàm kiểm tra số nguyên tố

public bool isPrime(int k)

{

if (k < 2) return false;

for (int i = 2; i <= Math.Sqrt(k); i++)

if (k % 2 == 0) return false;

return true;

}

//hàm thiết lập client hiện tại connect tới server và

//lưu client vào danh sách đã kết nối

public void setConnectClient(string clientName)

{

m_strCurrentClient = clientName;

if (!m_listClient.Contains(clientName))

m_listClient.Add(clientName);

}

//Hàm trả về danh sách các số nguyên tố

public List<int> getListPrime(int n)

{

m_RequestNumber++;

List<int>lst=new List<int>();

for (int i = 2; i <= n; i++)

if (isPrime(i))

lst.Add(i);

return lst;

}

public int RequestNumber

{

get { return this.m_RequestNumber;}

}

public string CurrentClient

{

get { return this.m_strCurrentClient; }

}

public List<string> ListClient

{

get { return this.m_listClient; }

}

}

}

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Runtime.Remoting;

using System.Runtime.Remoting.Channels;

using System.Runtime.Remoting.Channels.Tcp;

using ProxyObject;

namespace TangServer

{

public partial class frmServer : Form

{

private TcpChannel tcpChannel = null;

private int port = 8998;

private Type type;

private WellKnownObjectMode wellKnownMode;

private string objURI;

public frmServer()

{

InitializeComponent();

}

private void btnStart_Click(object sender, EventArgs e)

{

try

{

btnStop.PerformClick();

port = Int32.Parse(txtPort.Text);

//tạo kênh truyền dữ liệu

tcpChannel = new TcpChannel(port);

ChannelServices.RegisterChannel(tcpChannel, false);

//đăng ký remote object với Remoting framework

type = typeof(PrimeProxy);

objURI = “PRIME_URI”;

if (radSingleTon.Checked == true)

wellKnownMode = WellKnownObjectMode.Singleton;

else

wellKnownMode = WellKnownObjectMode.SingleCall;

RemotingConfiguration.RegisterWellKnownServiceType

(type, objURI, wellKnownMode);

txtStatus.Text = “khởi động server tại por ” + port.ToString() + ” lúc ” + DateTime.Now.ToString();

}

catch (Exception ex)

{

MessageBox.Show(“Lỗi”, ex.Message);

}

}

private void btnStop_Click(object sender, EventArgs e)

{

if (ChannelServices.GetChannel(“tcp”) != null)

{

ChannelServices.UnregisterChannel(tcpChannel);

txtStatus.Text = “tắt server tại port ” + port.ToString() + ” lúc ” +   DateTime.Now.ToString();

}

}

}

}

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Runtime.Remoting;

using System.Runtime.Remoting.Channels;

using System.Runtime.Remoting.Channels.Tcp;

using ProxyObject;

namespace TangClient

{

public partial class frmClient : Form

{

#region variables

string URL = “”;

Type type;

PrimeProxy primeObject;

#endregion

public frmClient()

{

InitializeComponent();

}

private void enableControl(bool b)

{

btnGetResult.Enabled = b;

txtClient.Enabled = b;

txtN.Enabled = b;

}

private void btnConnect_Click(object sender, EventArgs e)

{

try

{

//xây dựng chuỗi URL để truy tìm tài nguyên trên server

URL = “tcp://” + txtIP.Text + “:” + txtPort.Text + “/PRIME_URI”;

//đăng ký remote object

type = typeof(PrimeProxy);

RemotingConfiguration.RegisterWellKnownClientType(type, URL);

//tạo proxy

primeObject = new PrimeProxy();

lblStatus.Text = “Đã tạo xong proxy, vui lòng nhập Client, nhập N:”;

enableControl(true);

}

catch (Exception ex)

{

MessageBox.Show(ex.Message);

enableControl(false);

URL = “”;

}

}

private void frmClient_Load(object sender, EventArgs e)

{

enableControl(false);

}

private void btnGetResult_Click(object sender, EventArgs e)

{

string client = txtClient.Text;

int n = Int32.Parse(txtN.Text);

//Gửi tên client lên server

primeObject.setConnectClient(client);

//Lấy danh sách các số nguyên tố từ server về

List<int> listPrime= primeObject.getListPrime(n);

//Đưa danh sách số nguyên tố lên ListBox

lstbListPrime.Items.Clear();

foreach(int x in listPrime)

lstbListPrime.Items.Add(x);

//Lấy danh sách Client tồn tại trên server

List<string> listClient = primeObject.ListClient;

//Đưa danh sách client lên Listbox

lstbListClient.Items.Clear();

lstbListClient.Items.AddRange(listClient.ToArray());

string message = “”;

message =”Hello [” + primeObject.CurrentClient + “] Hàm này được triệu gọi ”

+ primeObject.RequestNumber +”\n”;

if(primeObject.RequestNumber==1)

message += ” Bạn là người đầu tiên triệu gọi hàm này!”;

else

message += ” Người gọi hàm này trước đó là [” +

listClient[listClient.Count-2] + “]”;

lblMessage.Text = message;

}

}

}