1

我正在尝试编写一个应用程序来监控几个邮箱，当找到邮件时，从每个项目中获取一些信息，然后一旦我有了项目列表，我就可以采取适当的措施。

但无论我如何处理它，我都会达到 Exchange 强制执行的 255 RPC 连接限制。

我完全不知道是什么导致了错误——据我所知，我已经把所有东西都捆绑在一个方法中，并且正在调用 Marshal.ReleaseComObject.... 我什至接受了打开和关闭 Outlook 应用程序句柄本身。

任何建议都将不胜感激......（我似乎无法弄清楚为什么我的代码在预览中看起来有问题，所以为了安全起见，我也把它放在了 pastebin 上...... http://pastebin.com/m637eb95 )

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Microsoft.Office.Interop.Outlook;
using Microsoft.Office.Interop;
using System.Runtime.InteropServices;

namespace HandleMailingResponses
{
    class OutlookFolderTableScraper
    {
        public List<OutlookItem> GetItemsFromFolder(string folderName)
        {
            List<OutlookItem> returnList = new List<OutlookItem>();

            Application outlookHandle = new Application();
            NameSpace outlookNamespace = outlookHandle.GetNamespace("MAPI");
            Folders rootOutlookFolders = outlookNamespace.Folders;

            outlookNamespace.Logon(null, null, null, true);

            Folder requestedRoot = enumerateFolders(rootOutlookFolders, folderName);
            Folders theseFolders = requestedRoot.Folders;
            Folder thisInbox = enumerateFolders(theseFolders, "Inbox");

            Marshal.ReleaseComObject(requestedRoot);
            requestedRoot = null;
            Marshal.ReleaseComObject(rootOutlookFolders);
            rootOutlookFolders = null;

            string storeID = thisInbox.StoreID;

            Table thisTable = thisInbox.GetTable("",OlTableContents.olUserItems);

            //By default each item has the columns EntryID, Subject, CreationTime, LastModificationTime and MessageClass
            //we can add any of the other properties the MailItem or ReportItem object would have....
            Columns theseColumns = thisTable.Columns;
            theseColumns.Add("SenderEmailAddress");

            Marshal.ReleaseComObject(thisInbox);
            thisInbox = null;

            outlookNamespace.Logoff();
            Marshal.ReleaseComObject(outlookNamespace);
            outlookNamespace = null;
            outlookHandle.Quit();
            Marshal.ReleaseComObject(outlookHandle);
            outlookHandle = null;

            int count = 0;
            while (!thisTable.EndOfTable)
            {
                Row thisRow = thisTable.GetNextRow();
                object[] theseValues = (object[]) thisRow.GetValues();
                Console.WriteLine("processed {0}",count++);

                //get the body from this item
                string messageClass = (string)theseValues[4];
                string entryID = (string)theseValues[0];
                string body = getItemBody(entryID,storeID, messageClass);

                returnList.Add(new OutlookItem((string)theseValues[5], (string)theseValues[1], body, messageClass, entryID));
            }



            return returnList;
        }

        private string getItemBody(string entryID, string storeID, string messageClass)
        {
            Application outlookHandle = new Application();
            NameSpace outlookNamespace = outlookHandle.GetNamespace("MAPI");
            outlookNamespace.Logon(null, null, null, true);
            string body;

            if (messageClass.ToLower().StartsWith("report"))
            {
                ReportItem thisItem = (ReportItem)outlookNamespace.GetItemFromID(entryID, storeID);
                body = thisItem.Body;
                thisItem.Close(OlInspectorClose.olDiscard);
                //release this com reference
                int releaseResult;
                do
                {
                    releaseResult = Marshal.ReleaseComObject(thisItem);
                } while (releaseResult != 0);
            }
            else
            {
                MailItem thisItem = (MailItem)outlookNamespace.GetItemFromID(entryID, storeID);
                body = thisItem.Body;
                thisItem.Close(OlInspectorClose.olDiscard);
                //release this com reference
                int releaseResult;
                do
                {
                    releaseResult = Marshal.ReleaseComObject(thisItem);
                } while (releaseResult != 0);
            }

            outlookNamespace.Logoff();
            outlookNamespace = null;
            outlookHandle.Quit();
            outlookHandle = null;


            GC.Collect();
            GC.WaitForPendingFinalizers();

            return body;
        }

                    /// <summary>
        /// Iterates through an Outlook.Folders object searching for a folder with the given name
        /// </summary>
        /// <param name="rootFolder">An Outlook.Folder object</param>
        /// <param name="targetFolder"></param>
        /// <returns></returns>
        private Folder enumerateFolders(Folders rootFolders, string targetFolder)
        {
            Folder returnFolder = null;
            System.Collections.IEnumerator thisEnumerator = rootFolders.GetEnumerator();
            while (thisEnumerator.MoveNext())
            {
                Folder f = (Folder)thisEnumerator.Current;
                string name = f.Name;
                if (targetFolder.ToLower().Equals(name.ToLower()))
                {
                    returnFolder = f;
                    break;
                }
            }
            ICustomAdapter adapter = (ICustomAdapter)thisEnumerator;
            Marshal.ReleaseComObject(adapter.GetUnderlyingObject());
            adapter = null;
            return returnFolder;
        }
        }

}
4

1 回答 1

0

不要在每次调用函数时创建新的 Application 对象，将其作为类的私有成员变量保存，直到不再需要它为止。这样，您只需要在构造函数中调用 Namespace.Logon。

于 2010-01-27T00:49:01.917 回答