如何使用AppDomain限制静态类的范围以便线程安全使用？

Question

我被一个设计糟糕的解决方案所困扰.它不是线程安全的!

我在解决方案中有几个共享类和成员,在开发期间一切都很酷......
BizTalk已经沉没了我的战舰.

我们使用自定义BizTalk适配器来调用我的程序集.适配器正在调用我的代码并并行运行,所以我假设它在同一个AppDomain下使用多个线程.

我想做的是让我的代码在自己的AppDomain下运行,这样我所拥有的共享问题就不会相互混淆.

我有一个非常简单的类,BizTalk适配器实例化然后运行Process()方法.

我想在我的Process()方法中创建一个新的AppDomain,所以每次BizTalk旋转另一个线程时,它都会有自己的静态类和方法版本.

BizTalkAdapter代码:

  // this is inside the BizTalkAdapter and it is calling the Loader class //
  private void SendMessage(IBaseMessage message, TransactionalTransmitProperties properties)
    {

        Stream strm = message.BodyPart.GetOriginalDataStream();
        string connectionString = properties.ConnectionString;
        string msgFileName = message.Context.Read("ReceivedFileName", "http://schemas.microsoft.com/BizTalk/2003/file-properties") as string;


        Loader loader = new Loader(strm, msgFileName, connectionString);
        loader.Process();

        EventLog.WriteEntry("Loader", "Successfully processed: " + msgFileName);

    }

这是BizTalk调用类:

public class Loader
{

    private string connectionString;
    private string fileName;
    private Stream stream;
    private DataFile dataFile;

    public Loader(Stream stream, string fileName, string connectionString)
    {
        this.connectionString = connectionString;
        this.fileName = fileName;
        this.stream = stream;
    }  

    public void Process()
    {

        //*****  Create AppDomain HERE *****
        // run following code entirely under that domain
        dataFile = new DataFile(aredStream, fileName, connectionString);
        dataFile.ParseFile();
        dataFile.Save();
        // get rid of the AppDomain here...

    }

}

仅供参考:Loader类位于dataFile类的单独DLL中.

任何帮助,将不胜感激.我将继续努力使代码线程安全,但我觉得这可能是"简单"的答案.

如果有人有任何其他想法,请投入.

谢谢,
基思

只是为了完整.

我确实发现,如果我在"传输高级选项"对话框中将发送适配器标记为"有序传递",我就能避免出现我遇到的多线程问题.

我认为这是我的问题的另一个可能的答案,但不一定是问题.

Answer 1

使用应用程序域，您可以执行以下操作：

public class Loader
{

    private string connectionString;
    private string fileName;
    private Stream stream;
    private DataFile dataFile;

    public Loader(Stream stream, string fileName, string connectionString)
    {
        this.connectionString = connectionString;
        this.fileName = fileName;
        this.stream = stream;
    }  

    public void Process()
    {
        //*****  Create AppDomain HERE *****
        string threadID = Thread.CurrentThread.ManagedThreadId.ToString();
        AppDomain appDomain = AppDomain.CreateDomain(threadID);

        DataFile dataFile = 
            (DataFile) appDomain.CreateInstanceAndUnwrap(
                        "<DataFile AssemblyName>", 
                        "DataFile", 
                        true, 
                        BindingFlags.Default,
                        null,
                        new object[] 
                        { 
                            aredstream, 
                            filename, 
                            connectionString 
                        },
                        null,
                        null,
                        null);
        dataFile.ParseFile();
        dataFile.Save();

        appDomain.Unload(threadID);       
    }
}