<a href="/" title="Ubuntu系統(tǒng)_Ubuntu軟件下載_Ubuntu電腦知識(shí)_Ubuntu服務(wù)器_中文網(wǎng)">

項(xiàng)目介紹

這節(jié)將要把《一步一步學(xué)Linq to sql（三）：增刪改》中留言簿的例子修改為使用WCF的多層構(gòu)架。我們將會(huì)建立以下項(xiàng)目：

l A，網(wǎng)站項(xiàng)目 WebSite：留言簿表現(xiàn)層

l B，類庫項(xiàng)目 Contract：定義數(shù)據(jù)訪問服務(wù)的契約

l C，類庫項(xiàng)目 Service：定義數(shù)據(jù)訪問服務(wù)

l D，類庫項(xiàng)目Entity：留言簿實(shí)體

l E，控制臺(tái)項(xiàng)目Host：承載數(shù)據(jù)訪問服務(wù)

項(xiàng)目之間的引用如下：

l A引用B和D；

l B引用D和System.ServiceModel程序集

l C引用B、D、System.ServiceModel以及System.Data.Linq程序集

l D引用System.Data.Linq程序集

l E引用C和System.ServiceModel程序集

生成映射文件和實(shí)體

打開VS2008命令行提示，執(zhí)行以下命令：

sqlmetal /conn:server=xxx;database=GuestBook;uid=xxx;pwd=xxx /map:c:/guestbook.map /code:c:/guestbook.cs /serialization:Unidirectional

注意到，這里我們使用了serialization開關(guān)，告知sqlmetal在生成實(shí)體的時(shí)候自動(dòng)把它們標(biāo)記為WCF數(shù)據(jù)對(duì)象。生成結(jié)束后把C:/GUESTBOOK.CS添加到Entity項(xiàng)目中。

系列文章導(dǎo)航：

編寫數(shù)據(jù)訪問服務(wù)

首先我們可以定義出留言簿數(shù)據(jù)訪問服務(wù)的契約（接口），把如下的代碼保存為IDataAccess.cs放在Contract類庫項(xiàng)目中：

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.ServiceModel;

namespace Contract

{

[ServiceContract]

public interface IDataAccess

{

[OperationContract]

void SendMessage(TbGuestBook gb);

[OperationContract]

List<TbGuestBook> GetData();

[OperationContract]

void DeleteMessage(string ID);

[OperationContract]

void SendReply(TbGuestBook gb);

}

在這里定義了四個(gè)方法：

l 創(chuàng)建留言

l 獲取所有留言

l 刪除留言

l 管理員發(fā)表回復(fù)

然后，我們來實(shí)現(xiàn)這個(gè)契約，把如下代碼保存為DataAccess.cs放在Service類庫項(xiàng)目中：

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using Contract;

using System.Data.Linq.Mapping;

using System.IO;

using System.ServiceModel;

namespace Service

{

[ServiceBehavior(IncludeExceptionDetailInFaults = true)]

public class DataAccess : IDataAccess

{

GuestBook ctx;

public DataAccess()

{

XmlMappingSource xms = XmlMappingSource.FromXml(File.ReadAllText("c://guestbook.map"));

ctx = new GuestBook("server=srv-devdbhost;database=GuestBook;uid=sa;pwd=Abcd1234", xms);

ctx.Log = Console.Out;

}

public void SendMessage(TbGuestBook gb)

{

ctx.TbGuestBook.Add(gb);

ctx.SubmitChanges();

}

public List<TbGuestBook> GetData()

{

var query = from gb in ctx.TbGuestBook orderby gb.PostTime descending select gb;

return query.ToList();

}

public void DeleteMessage(string ID)

{

TbGuestBook gb = ctx.TbGuestBook.Single(message => message.ID == new Guid(ID));

ctx.TbGuestBook.Remove(gb);

ctx.SubmitChanges();

}

public void SendReply(TbGuestBook gb)

{

//ctx.ExecuteCommand("update tbGuestBook set reply={0},isreplied=1 where ID={1}", gb.Reply, gb.ID);

TbGuestBook record = ctx.TbGuestBook.Single(message => message.ID == gb.ID);

record.IsReplied = true;

record.Reply = gb.Reply;

ctx.SubmitChanges();

}

這里需要注意幾點(diǎn)：

l 我們把DataContext的操作在控制臺(tái)輸出

l 在進(jìn)行發(fā)表回復(fù)（更新操作）的時(shí)候，注釋的代碼和沒有注釋的代碼雖然都能完成更新操作，但是前者更合理，因?yàn)楹笳邥?huì)先進(jìn)行SELECT再進(jìn)行UPDATE

系列文章導(dǎo)航：

WCF服務(wù)端與客戶端

打開Host項(xiàng)目中的Program.cs，使用下面的代碼來實(shí)現(xiàn)WCF的服務(wù)端：

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.ServiceModel;

using Service;

using Contract;

namespace Host

{

class Program

{

static void Main(string[] args)

{

Uri uri = new Uri("NET.tcp://localhost:8080/DataAccessService");

using (ServiceHost sh = new ServiceHost(typeof(DataAccess), uri))

{

NETTcpBinding ctb = new NETTcpBinding();

sh.AddServiceEndpoint(typeof(IDataAccess), ctb, string.Empty);

sh.Opened += delegate { Console.WriteLine("服務(wù)已經(jīng)啟動(dòng)"); };

sh.Open();

Console.ReadLine();

}

在WebSite項(xiàng)目中的App_Code文件夾下創(chuàng)建一個(gè)用戶調(diào)用服務(wù)的類，GetService.cs：

using System;

using System.Data;

using System.Configuration;

using System.Linq;

using System.Web;

using System.Web.Security;

using System.Web.UI;

using System.Web.UI.WebControls;

using System.Web.UI.WebControls.WebParts;

using System.Web.UI.HtmlControls;

using System.Xml.Linq;

using Contract;

using System.ServiceModel.Description;

using System.ServiceModel;

public class GetService

{

public static IDataAccess GetDataAccessService()

{

ServiceEndpoint sep = new ServiceEndpoint(ContractDescription.GetContract(typeof(IDataAccess)),

new NETTcpBinding(),

new EndpointAddress("NET.tcp://localhost:8080/DataAccessService"));

ChannelFactory<IDataAccess> cf = new ChannelFactory<IDataAccess>(sep);

return cf.CreateChannel();

}

系列文章導(dǎo)航：