wcf纯代码实现http服务

数据结构

public enum AgvUpgradeStep
    {
        VersionCheck = 0,
        Downloading = 1,
        Updating = 2,
        Booting = 3
    }
    public enum AgvUpgradeResult
    {
        Success = 0,
        Running = 1,
        Failed = 2
    }
    [DataContract]
    public class AgvUpgradeProgress
    {
        [DataMember]
        public AgvUpgradeStep step;
        [DataMember]
        public AgvUpgradeResult status;
        [DataMember]
        public string errinfo;
    }

1 定义协定

[ServiceContract]
    public interface TestHttpInterface
    {
        [OperationContract]
        [WebGet(UriTemplate = "DownloadFile")] //DownloadFile?Path={path}
        Stream DownloadFile();



        [WebInvoke(Method = "POST", UriTemplate = "TestJson", ResponseFormat = WebMessageFormat.Json, RequestFormat = WebMessageFormat.Json)]
        [OperationContract]
        Stream TestJson(AgvUpgradeProgress progress);

    }

2 实现协定

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]
    public class TestHttpService : TestHttpInterface
    {
        public string upgradeFile;
        public Stream DownloadFile()
        {
            if (WebOperationContext.Current == null) throw new Exception("WebOperationContext not set");
            if (string.IsNullOrEmpty(upgradeFile))
            {
                return null;
            }
            if (File.Exists(upgradeFile) == false)
            {
                return null;
            }
            var fileName = Path.GetFileName(upgradeFile);
            WebOperationContext.Current.OutgoingResponse.ContentType = "application/octet-stream";
            WebOperationContext.Current.OutgoingResponse.Headers.Add("content-disposition", "inline; filename=" + Uri.EscapeDataString(fileName));

            return File.OpenRead(upgradeFile);
        }

        public Stream TestJson(AgvUpgradeProgress progress)
        {
            JObject o = new JObject();
            o["ret"] = "ok";

            WebOperationContext.Current.OutgoingResponse.ContentType = "application/json; charset=utf-8";
            return new MemoryStream(Encoding.UTF8.GetBytes(o.ToString()));
        }
    }

3 创建/配置服务

//创建服务
var wcf_file_service = new TestHttpService;
//创建服务主机 
var file_service_host = new ServiceHost(wcf_file_service);
//获取协定          
var wcfcontract = ContractDescription.GetContract(typeof(AgvUpgradeHttpInterface));

string address = @"http://0.0.0.0:8888";

            var binding = new WebHttpBinding();
            binding.MaxBufferPoolSize = 524288;
            binding.MaxBufferSize = 67108864;
            binding.MaxReceivedMessageSize = 67108864;
            binding.TransferMode = TransferMode.Streamed;

            var serviceEndpoint = new ServiceEndpoint(wcfcontract, binding, new EndpointAddress(address));

            var httpBehavior = new WebHttpBehavior();
            httpBehavior.DefaultOutgoingRequestFormat = WebMessageFormat.Json;
            httpBehavior.DefaultOutgoingResponseFormat = WebMessageFormat.Json;
            serviceEndpoint.EndpointBehaviors.Add(new WebHttpBehavior());

            file_service_host.AddServiceEndpoint(serviceEndpoint);

            var serviceMetadata = new ServiceMetadataBehavior();
            serviceMetadata.HttpGetEnabled = true;
            serviceMetadata.HttpsGetEnabled = true;
            serviceMetadata.HttpGetUrl = new Uri($"{address}/services");
            file_service_host.Description.Behaviors.Add(serviceMetadata);



            file_service_host.Opened += delegate { Console.WriteLine("WCF file server 已经启动！"); };
            file_service_host.Open();

//获取本机ip
/*            String strHostName = string.Empty;
            IPHostEntry ipEntry = Dns.GetHostEntry(Dns.GetHostName());
            IPAddress[] addr = ipEntry.AddressList;

            for (int i = 0; i < addr.Length; i++)
            {
                Console.WriteLine("IP Address {0}: {1} ", i, addr[i].ToString());
            }*/