C# WCF REST调用

【实例截图】

【核心代码】

客户端：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.IO;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System.Security.Cryptography.X509Certificates;

namespace CallWcfRest
{
    public class UserInfo
    {
        public string userName { get; set; }
        public string userPassword { get; set; }
    }
    class Program
    {
        static void Main(string[] args)
        {
            //客户端证书的处理
            X509Certificate2 cert = GetX509Certificate();
            string dataUrl = Properties.Settings.Default["DataUrl"].ToString();
            string loginUrl = Properties.Settings.Default["LoginUrl"].ToString();
            bool isAnoymous = true;
            Console.WriteLine("请输入用户名:");
            string user = Console.ReadLine();
            Console.WriteLine("请输入密码:");
            string pwd = Console.ReadLine();
            UserInfo info = new UserInfo
            {
                userName = user,
                userPassword = pwd
            };
            //先访问LoginService，得到授权
            var request = (HttpWebRequest)WebRequest.Create(loginUrl);
            request.ContentType = "application/json;charset=utf-8";
            request.Method = "POST";
            request.KeepAlive = true;
            //request.ClientCertificates.Add(cert);
            //使用JSON.NET将对象序列化成JSON字符串
            var requestBody = JsonConvert.SerializeObject(info);
            byte[] databytes = Encoding.UTF8.GetBytes(requestBody);
            request.ContentLength = databytes.Length;
            using (var writer = request.GetRequestStream())
            {
                writer.Write(databytes, 0, databytes.Length);
            }
            var response = request.GetResponse();
            var encryptedCookie = response.Headers["Set-Cookie"];
            using (var stream = response.GetResponseStream())
            {
                using (var reader = new StreamReader(stream))
                {
                    if (reader.ReadToEnd() == "true")
                    {
                        Console.WriteLine("登录成功");
                        isAnoymous = false;
                    }
                }
            }
            //如果未能通过Forms身份验证
            if (isAnoymous)
            {
                Console.WriteLine("登录失败");
                return;
            }
            //访问DataService
            var request1 = (HttpWebRequest)WebRequest.Create(dataUrl);
            request1.Method = "GET";
            request1.Headers["Cookie"] = encryptedCookie;
            var response1 = request1.GetResponse();
            using (var stream = response1.GetResponseStream())
            {
                using (var reader = new StreamReader(stream))
                {
                    string res = reader.ReadToEnd();
                    //使用JSON.NET进行反序列化
                    var obj = JsonConvert.DeserializeObject<dynamic>(res);
                    Console.WriteLine("......你将得到数据.....");
                    Console.WriteLine(obj[1].StringValue);
                }
            }
        }

        private static X509Certificate2 GetX509Certificate()
        {
            X509Store store = new X509Store(StoreName.Root, StoreLocation.LocalMachine);
            store.Open(OpenFlags.ReadOnly);
            X509Certificate2Collection certs = store.Certificates.Find(X509FindType.FindBySubjectName, "MyEggSoft", false);
            return certs[0];
        }
    }
}

服务端：

using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.ServiceModel.Activation;
using System.ServiceModel.Web;
using System.Text;
using System.IO;
using System.Web;

namespace WcfRestService5
{
    [ServiceContract]
    [AspNetCompatibilityRequirements(RequirementsMode = AspNetCompatibilityRequirementsMode.Allowed)]
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall)]
    public class FileService
    {

        [WebGet(UriTemplate = "")]
        public string ShowTest()
        {
            return "只是测试一下";
        }

        /// <summary>
        /// 显示图片
        /// </summary>
        /// <param name="image">图片名</param>
        /// <returns>图片字节流</returns>
        [WebGet(UriTemplate = "Show/{image}")]
        public Stream ShowImage(string image)
        {
            string folder = System.Web.Hosting.HostingEnvironment.MapPath("~/images");
            WebOperationContext.Current.OutgoingResponse.ContentType = "image/jpeg";
            var file = Path.Combine(folder, image);
            return File.OpenRead(file);
        }

        /// <summary>
        /// 下载文件，以HTTP响应方式写回
        /// </summary>
        /// <param name="filename">文件名</param>
        [WebGet(UriTemplate = "DownLoad/{filename}")]
        public void  GetFile(string filename)
        {
            string folder = System.Web.Hosting.HostingEnvironment.MapPath("~/files");
            var FullName = Path.Combine(folder, filename);
            if (File.Exists(FullName))
            {
                FileInfo DownLoadFile = new FileInfo(FullName);
                HttpContext.Current.Response.Clear();
                HttpContext.Current.Response.ClearHeaders();
                HttpContext.Current.Response.Buffer = false;
                HttpContext.Current.Response.ContentType = "application/octer-stream";
                HttpContext.Current.Response.AppendHeader("Content-Disposition", "attachment:filename="  
                    HttpUtility.UrlEncode(DownLoadFile.FullName, System.Text.Encoding.UTF8));
                HttpContext.Current.Response.AppendHeader("Content-Length", DownLoadFile.Length.ToString());
                HttpContext.Current.Response.WriteFile(DownLoadFile.FullName);
                HttpContext.Current.Response.Flush();
                HttpContext.Current.Response.End();
            }

        }

       
        /// <summary>
        /// 上传文件,这个地方用form表单提交文件测试是成功了的,file是要保存的文件名
        /// </summary>
        /// <param name="stream">上传文件字节流</param>
        /// <param name="file">要保存的文件名</param>
        /// <returns></returns>
        [WebInvoke(UriTemplate = "Add/{file}", Method = "POST")]
        public bool AddFile(Stream stream, string file)
        {
            if (!string.IsNullOrEmpty(file))
            {
                string folder = System.Web.Hosting.HostingEnvironment.MapPath("~/Files");
                if (!Directory.Exists(folder))
                {
                    Directory.CreateDirectory(folder);
                }
                string path = Path.Combine(folder, file);
                using (FileStream fs = new FileStream(path, FileMode.Create, FileAccess.Write))
                {
                    long ByteLength = WebOperationContext.Current.IncomingRequest.ContentLength;
                    byte[] fileContent = new byte[ByteLength];
                    stream.Read(fileContent, 0, fileContent.Length);
                    fs.Write(fileContent, 0, fileContent.Length);
                    fs.Flush();
                    return true;
                }
            }
            return false;
        }
    }
}