如何使用POCO将文件传输到电报和从电报传输文件(我不想使用任何中间件)



我目前正在开发一个电报机器人,最近我几乎完成了它的敏感部分,现在我想激活 webhook,但 webhook 要求我在激活之前将证书文件发送到电报,稍后我可能想为我们的客户发送文件,或以文件形式接收他们的回复(因为我们想通过电报向他们激活我们的网站功能)。

以下是对电报机器人 API 的引用: https://core.telegram.org/bots/api#inputfile

我,我自己,通过HttpClient类完成了我所有的api调用,我希望继续保持原样。 这是我失败的方法:

public static Exception SetWebhook(SetWebhook webhook)
{
try
{
using (var hc = new HttpClient())
{
HttpContent requestContent = new ObjectContent(typeof(SetWebhook), webhook,
new JsonMediaTypeFormatter
{
SerializerSettings = new JsonSerializerSettings
{
ContractResolver = new CustomPropertyNamesContractResolver
{
Case = IdentifierCase.UnderscoreSeparator
},
NullValueHandling = NullValueHandling.Ignore
},
SupportedEncodings = {Encoding.UTF8}
}, "multipart/form-data");
var responseMessage =
hc.PostAsync("https://api.telegram.org/bot" + AppSetting.Token + "/setWebhook",
requestContent).Result;
if (responseMessage.IsSuccessStatusCode)
{
return null;
}
else
{
return new Exception("Status Code: " + responseMessage.StatusCode + "nnRequest" + responseMessage.RequestMessage.ToString() + "nnResponse" + responseMessage.ToString() );
}
}
}
catch (Exception ex)
{
return ex;
}
}

这是我的模型: 由于电报没有定义证书的确切类型,我看一下这个:https://github.com/MrRoundRobin/telegram.bot 生成它。

public class SetWebhook
{
/// <summary>
/// Optional<br/>
/// If empty remove webhook
/// </summary>
public string Url { get; set; }
/// <summary>
/// Optional<br/>
/// Upload your public key certificate so that the root certificate in use can be checked. See our self-signed guide for details.
/// </summary>
public InputFile Certificate { get; set; }
}
/// <summary>
/// Represents information for a file to be sent
/// </summary>
public class InputFile
{
/// <summary>
/// Required <b/>
/// Gets or sets the filename.
/// </summary>
public string Filename { get; set; }
/// <summary>
/// Required <b/>
/// Gets or sets the content.
/// </summary>
public Stream Content { get; set; }
public InputFile()
{
}
/// <summary>
/// Initializes a new instance of the <see cref="InputFile"/> class.
/// </summary>
/// <param name="filename">The <see cref="Filename"/>.</param>
/// <param name="content">The <see cref="Content"/>.</param>
public InputFile(string filename, Stream content)
{
Filename = filename;
Content = content;
}
}

这是我称之为的方式:

public ActionResult SetWebhook()
{
var result = true;
var text = "-";
try
{
WebHook.SetWebhook("http://ravis.ir:444/Data/Message", Server.MapPath("~/Files/ravis.ir-PEM.cer"));
}
catch(Exception ex)
{
result = false;
text = ex.Message;
}
return View(new WebhookResult
{
Result = result,
Text = text
});
}

最后一种方式,错误:

((ex.InnerException).InnerException).Message->此流不支持超时。

(ex.InnerException).Message->从"System.IO.FileStream"上的"读取超时"获取值时出错。

ex.Message->发生一个或多个错误。

那么我应该如何发送文件?我应该如何接收它们?我应该定义什么样的实体才能更准确?

为了使它工作,您应该构建内部带有StreamContentMultipartFormDataContent(不是ObjectContent):

using (var httpClient = new HttpClient())
using (var form = new MultipartFormDataContent())
{
var content = new StreamContent(setWebhook.Certificate.Content);
form.Add(content, "certificate", setWebhook.Certificate.Filename);
form.Add(new StringContent(setWebhook.Url, Encoding.UTF8), "url");
var response = await httpClient.PostAsync(uri, form);
}

至于接收文件 - 首先你应该得到包含file_path的"文件信息",然后可以下载:

var fileId = "fileId";
using (var httpClient = new HttpClient())
{
var responseMessage = await httpClient.PostAsJsonAsync("https://api.telegram.org/bot" + token + "/getFile", new { file_id = fileId });
responseMessage.EnsureSuccessStatusCode();
var fileInfoResponse = await responseMessage.Content.ReadAsAsync<TelegramResponse<FileInfo>>();
var fileUri = new Uri("https://api.telegram.org/file/bot" + token + "/" + fileInfoResponse.result.file_path);
var fileStreamResponse = await httpClient.GetAsync(fileUri, HttpCompletionOption.ResponseHeadersRead);
//and here's downloaded file
var stream = await fileStreamResponse.Content.ReadAsStreamAsync();
}

在这里,TelegramResponseFileInfo将如下所示(*不是C#约定,但如果需要,可以解决此问题):

class TelegramResponse<T>
{
public bool ok { get; set; }
public T result { get; set; }
}
class FileInfo
{
public string file_path { get; set; }
}

最新更新