EWS 通过SubscribeToPullNotifications订阅Exchange新邮件提醒

摘要

在ews中提供了一种拉通知的方式获取服务端邮件的操作，通过这种方式客户端可以订阅该通知，在邮箱有变化的时候，可以收到通知。

工作方式

EWS 通知是在订阅的基础上处理的。通常是一个订阅每个邮箱，以及邮箱订阅中您可以订阅部分或全部文件夹。您决定何种通知订阅 (流、请求或推) 以及哪种类型的事件您想要接收 (NewMail，创建、删除、修改日期，等等)，然后创建订阅。EWS 事件然后发送以异步方式从邮箱服务器到客户端。

EWS 流式处理通知

流式处理通知依赖悬挂 get 请求在服务器上保留流订阅连接以便连接处于活动状态时所发生的任何事件传送到客户端立即打开。过程中的一个连接，并连接保持打开直到间隔过期，或最多 30 分钟可以发送多个通知。连接到期后，客户端发送悬挂再次 get 请求。图 2 显示了流订阅和流式处理通知的工作方式。

EWS 通过SubscribeToPullNotifications订阅Exchange新邮件提醒

EWS 拉通知

拉通知依赖于在客户端上的时间间隔，客户端管理通知的请求。这可能会导致任何的通知与 GetEvents 响应。图 3 显示了请求订阅和请求通知的工作方式。

EWS 通过SubscribeToPullNotifications订阅Exchange新邮件提醒

一个例子

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Exchange.WebServices;
using Microsoft.Exchange.WebServices.Data;
using System.Net;
using System.Timers;
namespace Wolfy.Calendar_Email
{
class Program
    {
static ExchangeService service = new ExchangeService(ExchangeVersion.Exchange2010_SP2);
static PullSubscription Subscription;
static void Main(string[] args)
        {
            SubscribePullNotifications(WellKnownFolderName.Inbox);
            Timer mytimer = new Timer();
            mytimer.Elapsed += mytimer_Elapsed;
            mytimer.Interval = 10000;
            mytimer.Start();
            Console.Read();
        }

static void mytimer_Elapsed(object sender, ElapsedEventArgs e)
        {
            Console.WriteLine("running");
            GetPullNotifications();
        }
public static void SubscribePullNotifications(FolderId folderId)
        {
            service.Url = new Uri("https://mail.testsssss.com/ews/exchange.asmx");
            service.Credentials = new NetworkCredential("www", "12345", "domain");
            Subscription = service.SubscribeToPullNotifications(new FolderId[] { folderId }, 1440, null, EventType.NewMail, EventType.Created, EventType.Deleted);
        }
public static void GetPullNotifications()
        {
            IEnumerable<ItemEvent> itemEvents = Subscription.GetEvents().ItemEvents;
foreach (ItemEvent itemEvent in itemEvents)
            {
switch (itemEvent.EventType)
                {
case EventType.Copied:
                        Console.WriteLine("Copied");
break;
case EventType.Created:
                        Console.WriteLine("Created");
break;
case EventType.Deleted:
                        Console.WriteLine("Deleted");
break;
case EventType.FreeBusyChanged:
                        Console.WriteLine("FreeBusyChanged");
break;
case EventType.Modified:
                        Console.WriteLine("Modified");
break;
case EventType.Moved:
                        Console.WriteLine("Moved");
break;
case EventType.NewMail:
                        Console.WriteLine("New mail");
                        Console.WriteLine(itemEvent.ItemId.UniqueId);
                        EmailMessage emailMessage = EmailMessage.Bind(service, itemEvent.ItemId.UniqueId);
                        Console.WriteLine(emailMessage.Subject);
                        Console.WriteLine(emailMessage.Body.Text);
                        Console.WriteLine(emailMessage.From);
                        Console.WriteLine(emailMessage.DateTimeReceived);
                        Console.WriteLine(string.Join(";", emailMessage.ToRecipients.Select(x => x.Address).ToArray()));
break;
case EventType.Status:
                        Console.WriteLine("Status");
break;
default:
break;
                }
            }
        }
    }
}