使用WCF的一些问题

 一个扫描出库程序，采用单实例、单线程模型,主要防止同个号多台电脑同时扫描出库(因为支持手动批量出库)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ComponentModel;
using System.ServiceModel;
using System.Threading;
using DotNetHalfGoodsHouse.EFModel;
using System.Data.SqlClient;
namespace DotNetHalfGoodsHouse.Services
{
    #region 接口定义
    [ServiceContract]
    public interface IOutScanService
    {
        [OperationContract]
        OutScanResponse PostScan(OutScanRequest request);
        [OperationContract]
        string GetMaxOrderId();

    }
    #endregion

    #region 服务实现
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Single)]
    public class OutScanService : IOutScanService, IDisposable
    {


        public OutScanResponse PostScan(OutScanRequest request)
        {
          
            Console.WriteLine(string.Format("PN:{0},被调用了!:ThreadId:{1}", request.PN, Thread.CurrentThread.ManagedThreadId));

            var response = new OutScanResponse() 
            { 
               Code=2,
               ErrMsg="错误",
               Amount=0
            };

            try
            {
                #region 扫描出库
                using (JL_MFGEntities dbx = new JL_MFGEntities(ModelSetting.ModelConnString))
                {
                    var rmBreakEnt = dbx.RMBreak.FirstOrDefault(ent => ent.PFIFOID == request.PN);

                    //记录是否存在
                    if (rmBreakEnt == null) throw new ScanException("该PN不存在!", 401);

                    //PN相关信息
                    response.Batno = rmBreakEnt.batno.ToString().Trim();
                    response.CarType = rmBreakEnt.p_yw.Trim();
                    response.Output = rmBreakEnt.Poutput.Value;
                    response.PlanId = rmBreakEnt.PlanID;
                    response.MPartNo = rmBreakEnt.partno.Trim();
                    response.MPartName = rmBreakEnt.p_partnoName.Trim();
                    response.Amount = rmBreakEnt.partnototalqty.Value;

                    //检测状态
                    if (rmBreakEnt.IsOut.Trim() != "否") throw new ScanException("已发状态为'是',该记录已经被扫描出库!", 402);
                    //检测发料记录
                    var findItem = dbx.ExecuteStoreQuery<int?>("Select count(*) from storage_fixbin Where fifoid=@PN", new SqlParameter("@PN", request.PN)).FirstOrDefault();
                     if (findItem.HasValue && findItem.Value > 0) throw new ScanException("已存在发料记录,该记录已经被其他用户扫描",403);

                    //更改发料状态
                    rmBreakEnt.IsOut = "是";
                    rmBreakEnt.OutDate = DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss");
                    rmBreakEnt.OutOperator = request.Username;

                    //添加发料记录
                    var fixbin = new Storage_Fixbin()
                    {
                        #region
                        PlanID = rmBreakEnt.PlanID,
                        FGpartno = rmBreakEnt.FGpartno,
                        p_yw = rmBreakEnt.p_yw,
                        p_FGName = rmBreakEnt.p_FGName,
                        Batno = rmBreakEnt.batno,
                        Poutput = rmBreakEnt.Poutput,
                        FIFOID = rmBreakEnt.PFIFOID,
                        Barcode = request.EmpCard,
                        partno = rmBreakEnt.partno,
                        partname = rmBreakEnt.p_partnoName,
                        supplier = rmBreakEnt.p_supplier,
                        unit = rmBreakEnt.UM,
                        OutticketID = request.OrderId,//出库单号
                        OutSubID = request.OrderItemId,//子单号
                        OutQty = rmBreakEnt.partnototalqty,
                        OutDate = DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss"),
                        OutOperator = request.Username,
                        Shift = request.EmpGroup,
                        ShiftMonitor = request.EmpName,
                        TicketStatus = "生产性领料",
                        Ptype = "发料",
                        Machine = request.Machine,
                        Reason = "正常发送"
                        #endregion

                    };
                    dbx.Storage_Fixbin.AddObject(fixbin);
                    //更新预定量
                    var rmReserveEnt = dbx.RMHoldQty.FirstOrDefault(ent => ent.partno == fixbin.partno);
                    if (rmReserveEnt != null)
                    {

                        rmReserveEnt.holdqty -= rmBreakEnt.partnototalqty.Value;
                    }

                    #region 处理端子预定量
                    if (rmBreakEnt.Stock.Trim() == "端子")
                    {
                        var rmHandTEnt = dbx.HandTerminal.FirstOrDefault(ent => ent.partno == rmBreakEnt.partno && ent.Barcode == request.EmpCard);
                        if (rmHandTEnt == null) //执行添加
                        {
                            rmHandTEnt = new HandTerminal()
                            {
                                Barcode = request.EmpCard,
                                Name = request.EmpName,
                                Machine = request.Machine,
                                partno = rmBreakEnt.partno,
                                partname = rmBreakEnt.p_partnoName,
                                p_brand = rmBreakEnt.p_brand,
                                supplier = rmBreakEnt.p_supplier,
                                unit = rmBreakEnt.UM,
                                InQty = rmBreakEnt.partnototalqty,
                                Updatedate = DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss")


                            };
                            dbx.HandTerminal.AddObject(rmHandTEnt);
                        }
                        else //执行更新
                        {
                            if (!rmHandTEnt.InQty.HasValue) rmHandTEnt.InQty = 0;
                            rmHandTEnt.InQty += rmBreakEnt.partnototalqty;

                        }
                    }

                    #endregion

                    dbx.SaveChanges();

                }
                #endregion
                response.Msg = "成功";
                response.ErrMsg = "";
                response.Code = 1;
            }
            catch (ScanException ex)
            {


                response.ErrMsg = ex.Message;
                response.Code = ex.Code;
            }
            catch (Exception ex)
            {
                response.Code = 400;

                response.ErrMsg = ex.Message;
                if (ex.InnerException != null)
                    response.ErrMsg += string.Format("\r\n========Inner Exception=========\r\n{0}", ex.InnerException.Message);
            }


            return response;
        }

        
        public void Dispose()
        {
            
        }


        public string GetMaxOrderId()
        {
            using (JL_MFGEntities dbx = new JL_MFGEntities(ModelSetting.ModelConnString))
            {
                var list = dbx.ExecuteStoreQuery<string>("Select Max(OutTicketiD) from Storage_Fixbin").ToList();
                if (list.Count > 0)
                {
                    var orderId = list[0].Trim();
                    var newId=long.Parse(orderId) +1;
                    orderId="0000000000" + newId;
                    return orderId.Substring(orderId.Length - 10, 10);

                }

            }
            return "0000000001";
        }
    }
    #endregion

    #region 请求结构

    public class OutScanRequest
    {
        public string EmpName { get; set; }
        public string EmpCard { get; set; }
        public string EmpGroup { get; set; }
        public string Username { get; set; }
        public string PN { get; set; }
        public string Machine { get; set; }
        public string OrderId { get; set; }
        public int OrderItemId { get; set; }
    }
    public class OutScanResponse
    {
        /// <summary>
        /// 1成功，2失败
        /// </summary>
        public int Code { get; set; }
        public string ErrMsg { get; set; }
        public string Msg { get; set; }
        public string PlanId { get; set; }
        public string CarType { get; set; }
        public decimal Output { get; set; }
        public string Batno { get; set; }
        public string MPartNo { get; set; }
        public string MPartName { get; set; }
        public decimal Amount { get; set; }
    }
    [Serializable]
    public class ScanException : Exception
    {
        public int Code { get; set; }
        public ScanException(string msg,int code)
            : base(msg)
        {
            this.Code = code;
        }
    }
    #endregion
}

WCF采用TCP方式，并且多个请求使用同个TCP连接（在完成调用请求后不使用proxy.close()关闭TCP链接)

        private IOutScanService _proxy;
        private IOutScanService ScanService
        {
            get
            {
                if (_proxy == null)
                {
                    TryOpenChannel();

                }
                else
                {
                    var cObj = _proxy as ICommunicationObject;
                    if (cObj.State == CommunicationState.Faulted
                        || cObj.State == CommunicationState.Closed
                        || cObj.State == CommunicationState.Closing

                        )
                    {
                        TryOpenChannel();
                    }
                }
                return _proxy;
            }

        }
        private void TryOpenChannel()
        {
            try
            {
                _proxy = WCFHelper.Factory.CreateChannel();
                (_proxy as ICommunicationObject).Open();
            }
            catch (Exception)
            {
                _proxy = null;
                throw;
            }
        }

在局域网使用不对绑定使用加密，需要注意的是该配置要在Server端与Client端同时设置。

    #region WCF帮助类
   
    public class WCFHelper
    {

        private static ChannelFactory<IOutScanService> _channelFac;

        public static ChannelFactory<IOutScanService>  Factory
        {
            get
            {
                if (_channelFac == null)
                {
                    _channelFac =
                        new ChannelFactory<IOutScanService>(new NetTcpBinding(SecurityMode.None),
                        EndpointStr);

                }
                return _channelFac;
            }
        }

        private static string EndpointStr
        {
            get
            {
                return DotNetHalfGoodsHouse.EFModel.ModelSetting.GetSetting("ServiceEndpoint",
                    "net.tcp://192.168.1.31:8888/OutScanService");
            }
        }
    }

 采用匿名异步委托调用，防止界面卡死

        private void txtPN_KeyDown(object sender, KeyEventArgs e)
        
        {
            if (e.KeyCode == Keys.Enter)
            {
                try
                {
                    SetEnabled(false);

                    Post();
                }
                catch (Exception ex)
                {
                    MessageBox.Show(ex.Message, "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
                }
                finally
                {
                    SetEnabled(true);
                    txtPN.Text = "";
                    txtPN.Focus();
                }
            }
        }
        #endregion
        private void SetEnabled(bool v)
        {
            if (v)
            {

                this.Cursor = Cursors.Arrow;

            }
            else
            {
                this.Cursor = Cursors.WaitCursor;

            }
            dgvScnList.Cursor = this.Cursor;

            txtPN.Enabled = v;
            btnOut.Enabled = v;
            cbxMaterialType.Enabled = v;
            cbxIncharge.Enabled = v;
            cbxEmpGroup.Enabled = v;
        }


        


        private OutScanRequest PreRequest(string pn)
        {
            var request = new OutScanRequest();


            if (string.IsNullOrWhiteSpace(pn)) throw new DataInputException("请输入PN码!");
            if (!pn.StartsWith("P"))
            {
                pn = "0000000000" + pn;
                pn = "P" + pn.Substring(pn.Length - 9);
            }
            request.PN = pn;
            request.EmpCard = txtEmpCard.Text.Trim();
            if (string.IsNullOrWhiteSpace(request.EmpCard)) throw new DataInputException("请提员工身份识别卡!");

            request.EmpGroup = cbxEmpGroup.Text.Trim();

            request.EmpName = txtName.Text.Trim();
            if (string.IsNullOrWhiteSpace(request.EmpName)) throw new DataInputException("请提供员工姓名!");

            request.Machine = txtStation.Text.Trim();

            request.Username = UserSetting.UserName.Trim();

            return request;
        }
        private void Post()
        {

            #region 
            string pn=txtPN.Text.Trim();
            var request = PreRequest(pn);

            Post(request);

            
            #endregion

        }
        
        private void Post(OutScanRequest request)
        {

            //获取定单号
            if (string.IsNullOrWhiteSpace(OrderId))
            {
                GetOrderId();
            }
            request.OrderId = OrderId;
            request.OrderItemId = OrderItemId;
            OrderItemId++;

            //异步处理
            var fun = new Func<OutScanResponse>(() => { return ScanService.PostScan(request);});
            var ar=fun.BeginInvoke(null,null);
            while (!ar.IsCompleted)
            {
                Application.DoEvents();
                Thread.Sleep(50);
            }
            var response = fun.EndInvoke(ar);

            //不是同一批次
            if (!string.IsNullOrWhiteSpace(response.PlanId) && string.Compare(response.PlanId.Trim(), PlanId, true) != 0)
            {
                PlanId = response.PlanId.Trim();

                var action = new Action(() => { LoadData(); });
                var loadDataAR = action.BeginInvoke(null, null);
                while (!loadDataAR.IsCompleted)
                {
                    Application.DoEvents();
                    Thread.Sleep(50);
                }
                
                BindData();
            }


            if (lsvOut.Items.Count >= 1000)
            {
                lsvOut.Items.RemoveAt(0);
            }

            if (response.Code == 1)
            {

                lsvOut.Items.Add(new ListViewItem(new string[] { request.PN, response.MPartNo, response.MPartName, response.Amount.ToString("0.00"), "成功", "成功发送!", DateTime.Now.ToString("yy-MM-dd HH:mm:ss") }));
                SuccessCount++;

                lblSuccesTips.Text = SuccessCount.ToString();


            }
            else
            {
                var item = lsvOut.Items.Add(new ListViewItem(new string[] { request.PN, response.MPartNo, response.MPartName, response.Amount.ToString("0.00"), "失败", response.ErrMsg, DateTime.Now.ToString("yy-MM-dd HH:mm:ss") }));
                item.BackColor = Color.Red;
                item.Tag = request;
                ErrCount++;
                lblErrTips.Text = ErrCount.ToString();

            }



            RemoveFromList(request.PN);


            lsvOut.EnsureVisible(lsvOut.Items.Count - 1);

           
        }
        private void GetOrderId()
        {
            var fun = new Func<string>(() => { return ScanService.GetMaxOrderId(); });
            var ar = fun.BeginInvoke(null, null);
            while (!ar.IsCompleted)
            {
                Thread.Sleep(50);
                Application.DoEvents();

            }
            OrderId = fun.EndInvoke(ar);
            OrderItemId = 1;
        }
        /// <summary>
        /// 将扫描过的记录从列表移除
        /// </summary>
        /// <param name="pn"></param>
        private void RemoveFromList(string pn)
        {
            if (ScanData == null) return;


            var row = ScanData.Table.Select(string.Format(" pfifoid='{0}'", pn)).FirstOrDefault();
            if (row != null)
            {
                ScanData.Table.Rows.Remove(row);
            }


        }

//==========发布配置部分============
1.使用TopShelf方式托管WCF，结果在XPsp3的系统上老是安装不了，不过放到win2003上就正常了

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using Topshelf;
using System.IO;
namespace OutScanServer
{
    using DotNetHalfGoodsHouse;
    using DotNetHalfGoodsHouse.Services;

    class Program
    {
        private static string EndpointStr
        {
            get
            {
                return DotNetHalfGoodsHouse.EFModel.ModelSetting.GetSetting("ServiceEndpoint",
                    "net.tcp://192.168.1.31:8888/OutScanService");
            }
        }
        static void Main(string[] args)
        {
           

            var wsHost = HostFactory.New(x => {
                x.Service<ServiceHost>(s =>
                {
                    s.SetServiceName("配料扫描出库");
                    s.ConstructUsing(name=> new ServiceHost(typeof(OutScanService)));
                    s.WhenStarted(tc => {
                        
                        tc.AddServiceEndpoint(typeof(IOutScanService), new NetTcpBinding(SecurityMode.None), EndpointStr);
                        tc.Opened += (sObj, e) =>
                        {
                            Console.WriteLine("服务启动!");
                        };
                        tc.Open();
                    });

                    s.WhenStopped(tc => {
                        tc.Close();
                    });
                });


                x.RunAsLocalSystem();

                x.StartAutomatically();
                x.DependsOnMsSql();
                x.SetDescription("配料扫描出库服务端!");
                x.SetDisplayName("HaoDaOutScanService");
                x.SetServiceName("HaoDaOutScanService");
             
            });

            wsHost.Run();
  
        }
    }
}

2.采用VS自带的Windows Service项目也不比TopShelf麻烦多少，而且XP上也可以装,就是安装时使用installuntil 注意要使用对应.net framework版本，不然会提示程序集找不到一类的错误。

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.ServiceProcess;
using System.Text;
using System.ServiceModel;
namespace OutScanWinSvr
{
    using DotNetHalfGoodsHouse;
    using DotNetHalfGoodsHouse.Services;

    public partial class OutScanWinSvr : ServiceBase
    {
        private ServiceHost _Host;
        public OutScanWinSvr()
        {
            InitializeComponent();

            #region  初始华服务
            _Host = new ServiceHost(typeof(OutScanService));
            _Host.AddServiceEndpoint(typeof(IOutScanService), new NetTcpBinding(),
                                     DotNetHalfGoodsHouse.EFModel.ModelSetting.GetSetting("ServiceEndpoint","")
                                     );

      

            
            #endregion

        }

        protected override void OnStart(string[] args)
        {
            _Host.Open();
        }

        protected override void OnStop()
        {
            _Host.Close();
        }
    }
}

 WCF客户端使用BasicHttpBinding时默认开启2条TCP，要开更多需要设置

 System.Net.ServicePointManager.DefaultConnectionLimit = 512;