C# Post数据或文件到指定的服务器进行接收

简介: C# Post数据或文件到指定的服务器进行接收

应用场景

不同的接口服务器处理不同的应用,我们会在实际应用中将A服务器的数据提交给B服务器进行数据接收并处理业务。

比如我们想要处理一个OFFICE文件,由用户上传到A服务器,上传成功后,由B服务器负责进行数据处理和下载工作,这时我们就需要 POST A服务器的文件数据到B服务器进行处理。

实现原理

将用户上传的数据或A服务器已存在的数据,通过form-data的形式POST到B服务器,B服务由指定ashx文件进行数据接收,并转由指定的业务逻辑程序进行处理。如下图:

实现代码

PostAnyWhere类

创建一个 PostAnyWhere 类,

该类具有如下属性:

(1)public string PostUrl     要提交的服务器URL

(2)public List<PostFileItem> PostData   要准备的数据(PostFileItem类可包括数据和文件类型)

该类包含的关键方法如下:

(1)public void AddText(string key, string value)

        该方法将指定的字典数据加入到PostData中

(2)public void AddFile(string name, string srcFileName, string desName, string contentType = "text/plain")

        该方法将指定的文件添加到PostData中,其中 srcFileName 表示要添加的文件名,desName表示接收数据生成的文件名

(3)public string Send()

        该方法将开始POST传送数据

代码如下:

    public class PostAnyWhere
    {
        public string PostUrl { get; set; }
        public List<PostFileItem> PostData { get; set; }
 
        public PostAnyWhere()
        {
            this.PostData = new List<PostFileItem>();
        }
 
        public void AddText(string key, string value)
        {
            this.PostData.Add(new PostFileItem { Name = key, Value = value });
        }
 
        public void AddFile(string name, string srcFileName, string desName,string at, string contentType = "text/plain")
        {
            string[] srcName = Path.GetFileName(srcFileName).Split('.');
            string exName = "";
            if (srcName.Length > 1)
            {
                exName = "."+srcName[srcName.Length-1];
            }
            
            this.PostUrl = "https://www.xxx.com/test.ashx?guid=" + desName;
            ReadyFile(name, GetBinaryData(srcFileName), exName,contentType);
        }
         void ReadyFile(string name, byte[] fileBytes, string fileExName = "", string contentType = "text/plain")
        {
            this.PostData.Add(new PostFileItem
            {
                Type = PostFileItemType.File,
                Name = name,
                FileBytes = fileBytes,
                FileName = fileExName,
                ContentType = contentType
            });
        }
 
        public string Send()
        {
            var boundary = "----------------------------" + DateTime.Now.Ticks.ToString("x");
            var request = (HttpWebRequest)WebRequest.Create(this.PostUrl);
            request.ContentType = "multipart/form-data; boundary=" + boundary;
            request.Method = "POST";
            request.KeepAlive = true;
 
            Stream memStream = new System.IO.MemoryStream();
            var boundarybytes = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "\r\n");
            var endBoundaryBytes = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "--");
 
            var formdataTemplate = "\r\n--" + boundary + "\r\nContent-Disposition: form-data; name=\"{0}\";\r\n\r\n{1}";
 
            var formFields = this.PostData.Where(m => m.Type == PostFileItemType.Text).ToList();
            foreach (var d in formFields)
            {
                var textBytes = System.Text.Encoding.UTF8.GetBytes(string.Format(formdataTemplate, d.Name, d.Value));
                memStream.Write(textBytes, 0, textBytes.Length);
            }
 
            const string headerTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\nContent-Type: {2}\r\n\r\n";
            var files = this.PostData.Where(m => m.Type == PostFileItemType.File).ToList();
            foreach (var fe in files)
            {
                memStream.Write(boundarybytes, 0, boundarybytes.Length);
                var header = string.Format(headerTemplate, fe.Name, fe.FileName ?? "System.Byte[]", fe.ContentType ?? "text/plain");
                var headerbytes = System.Text.Encoding.UTF8.GetBytes(header);
                memStream.Write(headerbytes, 0, headerbytes.Length);
                memStream.Write(fe.FileBytes, 0, fe.FileBytes.Length);
            }
            memStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
            request.ContentLength = memStream.Length;
 
            HttpWebResponse response;
 
            try
            {
                using (var requestStream = request.GetRequestStream())
                {
                    memStream.Position = 0;
                    var tempBuffer = new byte[memStream.Length];
                    memStream.Read(tempBuffer, 0, tempBuffer.Length);
                    memStream.Close();
                    requestStream.Write(tempBuffer, 0, tempBuffer.Length);
                }
                response = (HttpWebResponse)request.GetResponse();
            }
            catch (WebException webException)
            {
                response = (HttpWebResponse)webException.Response;
            }
 
            if (response == null)
            {
                throw new Exception("HttpWebResponse is null");
            }
 
            var responseStream = response.GetResponseStream();
            if (responseStream == null)
            {
                throw new Exception("ResponseStream is null");
            }
 
            using (var streamReader = new StreamReader(responseStream))
            {
                return streamReader.ReadToEnd();
            }
        }
    }
 
    public class PostFileItem
    {
        public PostFileItem()
        {
            this.Type = PostFileItemType.Text;
        }
 
        public PostFileItemType Type { get; set; }
        public string Value { get; set; }
        public byte[] FileBytes { get; set; }
        public string Name { get; set; }
        public string FileName { get; set; }
        public string ContentType { get; set; }
    }
 
    public enum PostFileItemType
    {
        Text = 0,
        File = 1
    }
    public byte[] GetBinaryData(string filename)
    {
      if(!File.Exists(filename))
      {
        return null;
      }
      try
      {
        FileStream fs = new FileStream(filename, FileMode.Open, FileAccess.Read);
        byte[] imageData = new Byte[fs.Length];
        fs.Read( imageData, 0,Convert.ToInt32(fs.Length));
        fs.Close();
        return imageData;
      }
      catch(Exception)
      {
        return null;
      }
      finally
      {
        
      }
    }   

ashx文件部署

在B服务器上部署ashx文件接收数据,ashx程序即,一般处理程序(HttpHandler),一个httpHandler接受并处理一个http请求,需要实现IHttpHandler接口,这个接口有一个IsReusable成员,一个待实现的方法ProcessRequest(HttpContextctx) 。.ashx程序适合产生供浏览器处理的、不需要回发处理的数据格式。

示例代码如下:

<%@ WebHandler Language="C#" Class="Handler" %>
 
using System;
using System.Web;
using System.IO;
 
public class Handler : IHttpHandler {
    
public void ProcessRequest (HttpContext context) {
   if (context.Request.Files.Count > 0)
   {
      string strPath = System.Web.HttpContext.Current.Server.MapPath("~/app_data/test/");
      string strName = context.Request.Files[0].FileName;
      string ext=Path.GetExtension(strName);
      string filename =HttpContext.Current.Request.QueryString["guid"].ToString()+Path.GetFileNameWithoutExtension(strName);
      if(ext!=""){
         filename = filename  + ext;
      }
      context.Request.Files[0].SaveAs(System.IO.Path.Combine(strPath, filename));
   }
}
 
public bool IsReusable {
   get {
      return false;
   }
}
 
}

小结

ashx处理接收的数据后,后续还需要配合实际的接口功能继续处理应用。另外,对于ashx页面,实际的应用则需要使用安全访问控制,只有正常登录或提供合法访问令牌的用户才可以进行访问。

以上代码仅供参考,欢迎大家指正,再次感谢您的阅读!

相关文章
|
4月前
|
机器学习/深度学习 存储 监控
内部文件审计:企业文件服务器审计对网络安全提升有哪些帮助?
企业文件服务器审计是保障信息安全、确保合规的关键措施。DataSecurity Plus 是由卓豪ManageEngine推出的审计工具,提供全面的文件访问监控、实时异常告警、用户行为分析及合规报告生成功能,助力企业防范数据泄露风险,满足GDPR、等保等多项合规要求,为企业的稳健发展保驾护航。
121 0
|
4月前
|
安全 Linux Shell
使用SCP命令在CentOS 7上向目标服务器传输文件
以上步骤是在CentOS 7系统上使用SCP命令进行文件传输的基础,操作简洁,易于理解。务必在执行命令前确认好各项参数,尤其是目录路径和文件名,以避免不必要的传输错误。
497 17
|
4月前
|
自然语言处理 Unix Linux
解决服务器中Jupyter笔记本的文件名字符编码问题
通过上述步骤,可以有效解决Jupyter笔记本的文件名字符编码问题,确保所有文件能在服务器上正常访问并交互,避免因编码问题引起的混淆和数据丢失。在处理任何编码问题时,务必谨慎并确保备份,因为文件名变更是
180 17
|
4月前
|
安全 Linux 网络安全
Python极速搭建局域网文件共享服务器:一行命令实现HTTPS安全传输
本文介绍如何利用Python的http.server模块,通过一行命令快速搭建支持HTTPS的安全文件下载服务器,无需第三方工具,3分钟部署,保障局域网文件共享的隐私与安全。
935 0
|
7月前
|
Python
使用Python实现multipart/form-data文件接收的http服务器
至此,使用Python实现一个可以接收 'multipart/form-data' 文件的HTTP服务器的步骤就讲解完毕了。希望通过我的讲解,你可以更好地理解其中的逻辑,另外,你也可以尝试在实际项目中运用这方面的知识。
339 69
|
6月前
|
存储 监控 算法
基于 C# 的局域网计算机监控系统文件变更实时监测算法设计与实现研究
本文介绍了一种基于C#语言的局域网文件变更监控算法,通过事件驱动与批处理机制结合,实现高效、低负载的文件系统实时监控。核心内容涵盖监控机制选择(如事件触发机制)、数据结构设计(如监控文件列表、事件队列)及批处理优化策略。文章详细解析了C#实现的核心代码,并提出性能优化与可靠性保障措施,包括批量处理、事件过滤和异步处理等技术。最后,探讨了该算法在企业数据安全监控、文件同步备份等场景的应用潜力,以及未来向智能化扩展的方向,如文件内容分析、智能告警机制和分布式监控架构。
184 3
|
9月前
|
物联网 数据处理 C#
C#实现上位机开发,串口通信,读写串口数据并处理16进制数据
C#实现上位机开发,串口通信,读写串口数据并处理16进制数据。在自动化、物联网以及工业控制行业中,上位机开发是一项重要的技能。本教程主要介绍使用C#进行上位机开发,重点在于串口通信和数据处理。
1781 82
|
8月前
|
前端开发 Cloud Native Java
Java||Springboot读取本地目录的文件和文件结构,读取服务器文档目录数据供前端渲染的API实现
博客不应该只有代码和解决方案,重点应该在于给出解决方案的同时分享思维模式,只有思维才能可持续地解决问题,只有思维才是真正值得学习和分享的核心要素。如果这篇博客能给您带来一点帮助,麻烦您点个赞支持一下,还可以收藏起来以备不时之需,有疑问和错误欢迎在评论区指出~
Java||Springboot读取本地目录的文件和文件结构,读取服务器文档目录数据供前端渲染的API实现
|
10月前
|
存储 安全 网络安全
服务器感染了.baxia勒索病毒,如何确保数据文件完整恢复?
近年来,勒索病毒如.baxia不断演变,利用漏洞、社交工程等手段加密文件,威胁范围扩大。加密货币的兴起使其支付方式更匿名,追踪困难。技术支持尤为重要,添加技术服务号(shuju315),专业团队提供数据恢复方案。面对复杂解密要求,包括赎金支付、个人信息提供和执行特定操作,需保持冷静并寻求帮助。防御措施包括加强安全意识、定期备份数据、安装杀毒软件、避免未知文件、更新系统及制定应急响应计划。
442 11
|
2月前
|
XML 前端开发 C#
C#编程实践:解析HTML文档并执行元素匹配
通过上述步骤,可以在C#中有效地解析HTML文档并执行元素匹配。HtmlAgilityPack提供了一个强大而灵活的工具集,可以处理各种HTML解析任务。
178 19