A Client - Server App using .NET Remoting

This is a basic client-server application where the client is able to view and insert records to the database using the server. Both applications have been created as Console applications, just to keep it simple ;-)

Before you start you must have,
- Visual Studio 2005/2008 Installed
- MS SQL Server 2005 Installed

Step 1 : Creating the Server
Before you start to do anything
Open Visual Studio and create a Console Application in C# named ServeWithDL.
Create the following folder structure and the files.

Before you start to do anything, right click on References and add reference to
System.Runtime.Remoting
System.Runtime.Serialization
System.Runtime.Serialization.Formatters.Soap

Then open the Supplier.cs within the BusinessEntities folder and paste the following code;

====================================================================

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections;
using System.IO;

namespace ServeWithDL.BusinessEntities
{
   #region Supplier
   /// <summary>
   /// Class which represents the Supplier object
   /// </summary>
   [Serializable]
   public class Supplier
   {
   public string SupID {get; set;}
   public string SName {get; set;}
   public string UserName {get; set;}
   public string UPassword {get; set;}
   public string SAddress {get; set;}
   public string SMail {get; set;}
   public string SMobile {get; set;}
   public string SFax { get; set; }

   public override string ToString()
   {
   return "Id : " + this.SupID + "\nName : " + this.SName + "\nUser Name : " + this.UserName + "\nPassword : " + this.UPassword
   + "\nAddress : " + this.SAddress + "\nMail Address : " + this.SMail + "\nMobile : " + this.SMobile + "\nFax : " + this.SFax+"\n\n";
   }

   public override bool Equals(object obj)
   {
   if (obj.GetType() != typeof(Supplier))
   throw new InvalidOperationException();
   else
   {
   Supplier objSupplier = (Supplier)obj;
   return this.SupID.Equals(objSupplier.SupID);

   }
   }
   }
#endregion

   #region Suppliers
   /// <summary>
   /// Class to represent the Suppliers object
   /// </summary>
   [Serializable]
   public class Suppliers : ICollection<Supplier>
   {

   public Suppliers()
   {
   SupplierList = new List<Supplier>();
   }

   private List<Supplier> SupplierList;

   #region ICollection<Supplier> Members

   public void Add(Supplier item)
   {
   this.SupplierList.Add(item);
   }

   public void Clear()
   {
   for (int x = 0; x < this.SupplierList.Count; x++)
   {
   this.SupplierList.RemoveAt(x);
   }
   }

   public bool Contains(Supplier item)
   {
   return SupplierList.Contains(item);
   }

   public void CopyTo(Supplier[] array, int arrayIndex)
   {
   foreach (Supplier objSupplier in SupplierList)
   {
   array.SetValue(objSupplier, arrayIndex);
   arrayIndex++;
   }

   }

   public int Count
   {
   get { return this.SupplierList.Count; }
   }

   public bool IsReadOnly
   {
   get { return false; }
   }

   public bool Remove(Supplier item)
   {
   if (SupplierList.Contains(item))
   {
   return SupplierList.Remove(item);
   }
   return false;
   }

   #endregion

   #region IEnumerable<Supplier> Members

   public IEnumerator<Supplier> GetEnumerator()
   {
   return SupplierList.GetEnumerator();
   }

   #endregion

   #region IEnumerable Members

   IEnumerator IEnumerable.GetEnumerator()
   {
   return new Enumerator(SupplierList.ToArray());
   }

   #endregion
   }

   #endregion

   #region Enumerator
   /// <summary>
   /// Class to make the Supplier class, Enumerable
   /// </summary>
   public class Enumerator : IEnumerator
   {
   private Supplier[] suppliers;
   private int Cursor;

   public Enumerator(Supplier[] supplierArr)
   {
   this.suppliers = supplierArr;
   Cursor = -1;
   }

   void IEnumerator.Reset()
   {
   Cursor = -1;
   }

   bool IEnumerator.MoveNext()
   {
   if (Cursor < suppliers.Length)
   Cursor++;

   return (!(Cursor == suppliers.Length));
   }

   object IEnumerator.Current
   {
   get
   {
   if ((Cursor < 0) || (Cursor == suppliers.Length))
   throw new InvalidOperationException();
   return suppliers[Cursor];
   }
   }
   }

   #endregion
}

====================================================================

Then open the ServeWithDL.cs within the BusinessServiceLayer folder and paste following code;

====================================================================

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using ServeWithDL.BusinessEntities;

using ServeWithDL.DataAccess;

namespace ServeWithDL.BusinessServiceLayer

{

#region ServerWithDL

/// <summary>

/// This is the Class which is used by the Client directly

/// </summary>

public class ServerWithDL : MarshalByRefObject

{

public Suppliers GetSuppliers()

{

SupplierDAC objSupplierDAC = new SupplierDAC();

return objSupplierDAC.GetAll();

}

public bool AddSupplier(Supplier objSupplier)

{

SupplierDAC objSupplierDAC = new SupplierDAC();

return objSupplierDAC.Insert(objSupplier);

}

#endregion

====================================================================

Then open the SupplierDAC.cs within the DataAccess folder and paste the following code;

====================================================================

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using ServeWithDL.BusinessEntities;

using System.Data.SqlClient;

using System.Configuration;

using System.Data;

namespace ServeWithDL.DataAccess

{

#region SupplierDAC

/// <summary>

/// Class which does the talking with the Database

/// </summary>

public class SupplierDAC

{

#region Public Methods

#region GetAll

public Suppliers GetAll()

{

Suppliers objSuppliers = new Suppliers();

using (SqlConnection con = new SqlConnection(ConfigurationManager.ConnectionStrings["ServerConnectionString"].ToString()))

{

using (SqlCommand cmd = new SqlCommand("SELECT * FROM Supplier", con))

{

con.Open();

Supplier objSupplier;

using (SqlDataReader rdr = cmd.ExecuteReader())

{

while (true)

{

objSupplier = FillSupplier(rdr);

if (objSupplier != null)

objSuppliers.Add(objSupplier);

else

break;

}

return objSuppliers;

}

#endregion

#region Insert

public bool Insert(Supplier objSupplier)

{

using (SqlConnection con = new SqlConnection(ConfigurationManager.ConnectionStrings["ServerConnectionString"].ToString()))

{

using (SqlCommand cmd = new SqlCommand("INSERT INTO Supplier VALUES (@ID,@Name,@UserName,@Password,@Address,@Mail,@Mobile,@Fax)", con))

{

con.Open();

SetCommonParams(cmd, objSupplier);

return cmd.ExecuteNonQuery() > 0;

}

#endregion

#region Private Methods

#region FillSupplier

private Supplier FillSupplier(SqlDataReader rdr)

{

if (rdr.Read())

{

Supplier objSupplier = new Supplier();

objSupplier.SupID = rdr.GetString(0);

objSupplier.SName = rdr.GetString(1);

objSupplier.UserName = rdr.GetString(2);

objSupplier.UPassword = rdr.GetString(3);

objSupplier.SAddress = rdr.GetString(4);

objSupplier.SMail = rdr.GetString(5);

objSupplier.SMobile = rdr.GetString(6);

objSupplier.SFax = rdr.GetString(7);

return objSupplier;

}

else

return null;

}

#endregion

#region SetCommonParams

private void SetCommonParams(SqlCommand cmd, Supplier objSupplier)

{

cmd.Parameters.Add(new SqlParameter("@Id", objSupplier.SupID));

cmd.Parameters.Add(new SqlParameter("@Name", objSupplier.SName));

cmd.Parameters.Add(new SqlParameter("@UserName", objSupplier.UserName));

cmd.Parameters.Add(new SqlParameter("@Password", objSupplier.UPassword));

cmd.Parameters.Add(new SqlParameter("@Address", objSupplier.SAddress));

cmd.Parameters.Add(new SqlParameter("@Mail", objSupplier.SMail));

cmd.Parameters.Add(new SqlParameter("@Mobile", objSupplier.SMobile));

cmd.Parameters.Add(new SqlParameter("@Fax", objSupplier.SFax));

}

#endregion

}

#endregion

}

====================================================================

Then open the App.config and change the ConnectionString named "ServerConnectionString" accordingly;

The database, I am connecting to is called UserLogin.

<?xml version="1.0" encoding="utf-8" ?>

</connectionStrings>

</configuration>

====================================================================

Then open Program.cs file and paste the following code;

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Runtime.Remoting;

using System.Runtime.Remoting.Channels;

using System.Runtime.Remoting.Channels.Tcp;

namespace ServeWithDL

{

class Program

{

static void Main(string[] args)

{

// Create an instance of a channel

TcpChannel channel = new TcpChannel(8070);

ChannelServices.RegisterChannel(channel);

// Register as an available service with the name Server

RemotingConfiguration.RegisterWellKnownServiceType(

typeof(BusinessServiceLayer.ServerWithDL),

"Server",

WellKnownObjectMode.Singleton);

System.Console.WriteLine("Press the enter key to exit...");

System.Console.ReadLine();

}

Well, that is it for the Server, just build the application now we will move on to the Client.

Step 2 : Creating the Client

Open Visual Studio and create a Console Application in C# named Client.

Before you start to do anything, right click on References ->Add Reference->Click on Browse tab and navigate to the Debug folder of the ServeWithDL application, then select ServeWithDL.exe.

Then open the Program.cs and paste the following code;

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Runtime.Remoting;

using System.Runtime.Remoting.Channels;

using System.Runtime.Remoting.Channels.Tcp;

using ServeWithDL;

using ServeWithDL.BusinessEntities;

using ServeWithDL.BusinessServiceLayer;

namespace Client

{

class Program

{

static void Main(string[] args)

{

ServerWithDL obj = (ServerWithDL)Activator.GetObject(

typeof(ServeWithDL.BusinessServiceLayer.ServerWithDL),

"tcp://localhost:8070/Server");

if (obj.Equals(null))

{

System.Console.WriteLine("Error: unable to locate server");

}

else

{

Console.WriteLine(":::::::: Welcome to the Client ::::::::::");

Console.WriteLine("Press 1 to Insert a New Supplier.");

Console.WriteLine("Press 2 to View All Suppliers.");

Console.WriteLine("Press Q to Quit.");

string response = Console.ReadLine();

while (!response.Contains("Q"))

{

if (response == "1")

{

Supplier objSupplier = new Supplier();

Console.Write("Enter Supplier Id : ");

objSupplier.SupID = Console.ReadLine();

Console.Write("Enter Supplier Name : ");

objSupplier.SName = Console.ReadLine();

Console.Write("Enter Supplier User Name : ");

objSupplier.UserName= Console.ReadLine();

Console.Write("Enter Supplier Password : ");

objSupplier.UPassword = Console.ReadLine();

Console.Write("Enter Supplier Address : ");

objSupplier.SAddress = Console.ReadLine();

Console.Write("Enter Supplier Mail : ");

objSupplier.SMail = Console.ReadLine();

Console.Write("Enter Supplier Mobile : ");

objSupplier.SMobile = Console.ReadLine();

Console.Write("Enter Supplier Fax : ");

objSupplier.SFax = Console.ReadLine();

if (obj.AddSupplier(objSupplier))

{

Console.WriteLine("Supplier Added Successfully!");

}

else

{

Console.WriteLine("Supplier Didn't Added Successfully!");

}

else if (response == "2")

{

foreach (Supplier objSupplier in obj.GetSuppliers())

{

Console.WriteLine(objSupplier.ToString());

}

else

{

Console.WriteLine("Invalid Choice. Press Q to Quit.");

response = Console.ReadLine();

}

Console.WriteLine("Enter a Choice. Press Q to Quit.");

response = Console.ReadLine();

}

Step 3 : Creating Database and Supplier Table

Open SQL Server Management Studio and Create a New Database named UserLogin. Then execute the following script;

USE [UserLogin]

/****** Object: Table [dbo].[Supplier] Script Date: 10/26/2010 11:28:13 ******/

SET ANSI_NULLS ON

SET QUOTED_IDENTIFIER ON

SET ANSI_PADDING ON

CREATE TABLE [dbo].[Supplier](

[SupID] [varchar](50) COLLATE SQL_Latin1_General_CP1_CI_AS NOT NULL,

[SName] [varchar](100) COLLATE SQL_Latin1_General_CP1_CI_AS NULL,

[UserName] [varchar](50) COLLATE SQL_Latin1_General_CP1_CI_AS NULL,

[UPassword] [varchar](50) COLLATE SQL_Latin1_General_CP1_CI_AS NULL,

[SAddress] [varchar](100) COLLATE SQL_Latin1_General_CP1_CI_AS NULL,

[SMail] [varchar](50) COLLATE SQL_Latin1_General_CP1_CI_AS NULL,

[SMobile] [varchar](20) COLLATE SQL_Latin1_General_CP1_CI_AS NULL,

[SFax] [varchar](20) COLLATE SQL_Latin1_General_CP1_CI_AS NULL,

CONSTRAINT [pk_Supplier] PRIMARY KEY CLUSTERED

(

[SupID] ASC

)WITH (PAD_INDEX = OFF, IGNORE_DUP_KEY = OFF) ON [PRIMARY]

) ON [PRIMARY]

SET ANSI_PADDING OFF

Now we are ready to go,

1. Start the Server application first. (Double click on ServeWithDL.exe)

2. Start the Client application.

3. First We will add a new Supplier.

As you can see a New row with the values we provided has been created. In the table Supplier.

4. Now we will view the Record from the Client application

We have come to the end of this post, feel free to drop your suggestions and comments.

.NET Force

Search This Blog

A Client - Server App using .NET Remoting

Comments

Post a Comment