Как найти диспетчер сообщений

(Эта статья первоначально производится в 2006.03.14, первая редакция составляет 2006.06.06, а после коррекции применяется к ESFRAMEWORK V0.3 +)

ПервоначальноTcp/udpКомпоненты являются единственным импортным и экспортом системы и внешних обменных сообщений, а такжеTcpКомпонент илиUdpУникальное соединение между компонентом проходит через сообщений дистрибьютор IMESSAGEDISPATHER, который эквивалентенESFrameworkДиспетчер сообщений является импорт и экспорт наших приложений и внешних сообщений обмена. IMESSAGEDISPATCHER не связан с соглашением, независимым компонентом компонента, то есть его можно использовать в протоколе UDP в протоколе TCP, и если общение с использованием удаления также может использовать IMESSAGEDISPatcher для назначения сообщений; его можно использовать в Сервер его можно использовать для клиента, такая высокая повторное использование делает верхнее приложение, построенное на основе разных базовых слоев (таких как TCP / UDP, Server / Client), что делает всю архитектуру Esframework Creler, сглаживание кривой.

IMESSAGEDISPATCER гарантирует, что каждое получено каждое сообщение, и каждое отправлено каждое сообщение, может быть все

HookсSpyМгновенныйПерехватить. Кроме того, диспетчер сообщений может потребоваться проверить, что полученный формат сообщения является правильным, является ли сообщение законно, соответствует ли сообщение конкретной спецификации. Ниже приведена композиция компонента распределителя сообщений:
Диспетчер сообщенияIMessageDispatcherОпределяется следующим образом:

publicinterfaceIMessageDispatcher
{
IEsbLoggerEsbLogger{set;}
INetMessageHookNetMessageHook{set;}//Может быть esbnetmessageHook.
IGatewayMessageSpyGatewayMessageSpy{set;}
IInnerMessageSpyInnerMessageSpy{set;}

IContractHelperContractHelper{

set;}//Должен установить
INakeDispatcherNakeDispatcher{set;}//Должен установить

NetMessageDispatchMessage(NetMessagereqMsg);///<summary>
///Если все Singlemessage необходимо передать цепочку крючков IMessagedispatcher, прежде чем отправить его, шпион
///</summary>
NetMessageBeforeSendMessage(NetMessagemsg);eventCbNetMessageMessageReceived;
}

ИзКомпоненты Imessediscatcher иОпределение интерфейса можно увидеть, чтоIMESSAGEDISPATCER гарантирует, что полученное сообщение подвергается каждому шпиону, крючкому, процессору сообщений и других компонентов в указанном порядке. Нет новостей не является исключением. Даже сообщения, созданные в системе (например, уведомление, отправленные клиенту), также должны пройтиПрежде чем IMESSAGEDISPatcher’s BeforesendMessage может быть благополучно отправлен.
Реализация IMESSAGEDISPATCER заключается в следующем:

publicclassMessageDispatcher:IMessageDispatcher
{
#regionproperty
#regionLogger
privateIEsbLoggeresbLogger=newEmptyEsbLogger();
publicIEsbLoggerEsbLogger
{
set
{
if(value!=null)
{
this.esbLogger=value;
}
}
}
#endregion#regionNakeDispatcher
privateINakeDispatchernakeDispatcher;
publicINakeDispatcherNakeDispatcher
{
set
{
this.nakeDispatcher=value;
}
}
#endregion#regionNetMessageHook
privateINetMessageHooknetMessageHook=newEmptyNetMessageHook();
publicINetMessageHookNetMessageHook
{
set
{
this.netMessageHook=value;
}
}
#endregion#regionInnerMessageSpy
privateIInnerMessageSpyinnerMessageSpy=newEmptyInnerMessageSpy();
publicIInnerMessageSpyInnerMessageSpy
{
set
{
if(value!=null)
{
this.innerMessageSpy=value;
}

}
}

#endregion#regionGatewayMessageSpy
privateIGatewayMessageSpygatewayMessageSpy=newEmptyGatewayNetMessageSpy();
publicIGatewayMessageSpyGatewayMessageSpy
{
set
{
if(value!=null)
{
this.gatewayMessageSpy=value;
}
}
}
#endregion#regionContractHelper
privateIContractHelpercontractHelper=null;
publicIContractHelperContractHelper
{
set
{
this.contractHelper=value;
}
}
#endregionpubliceventCbNetMessageMessageReceived;
#endregion#regionУчастник ImessagedispatcherpublicNetMessageDispatchMessage(NetMessagereqMsg)
{
try
{
if(this.MessageReceived!=null)
{
this.MessageReceived(reqMsg);
}this.gatewayMessageSpy.SpyReceivedMsg(reqMsg);

NetMessagemsgHooked

=this.netMessageHook.CaptureReceivedMsg(reqMsg);this.innerMessageSpy.SpyReceivedMsg(msgHooked);
NetMessageresMsg=this.nakeDispatcher.DispatchMessage(msgHooked);
if(reqMsg==null)
{
returnnull;
}returnthis.BeforeSendMessage(resMsg);
}
catch(Exceptionee)
{
this.esbLogger.Log(ee.GetType().ToString(),ee.Message,“ESFramework.Network.MessageDispatcher.DispatchMessage“,ErrorLevel.High);
returnthis.contractHelper.GetResponseByServiceResultType(reqMsg,ServiceResultType.HandleFailure);
}
}publicNetMessageBeforeSendMessage(NetMessagemsg)
{
this.innerMessageSpy.SpyToBeSendedMsg(msg);
NetMessagemsgHooked=this.netMessageHook.CaptureBeforeSendMsg(msg);
this.gatewayMessageSpy.SpyToBeSendedMsg(msgHooked);returnmsgHooked;
}#endregion
}

Мы видели,IMESSAGEDISPATCHER использует компоненты INAKACEDISPATHER, обязанности INAKEDISPATHER просты, и для соответствующего процессора позвонит IDatArecaactory для сообщения, который необходимо отправлять, а затем оплатить сообщение для обработки процессора, вернуть результат. Интерфейс определяется следующим образом:

publicinterfaceINakeDispatcher
{
NetMessageDispatchMessage(NetMessagemsg);
}

Реализация индиудаспатчика также очень проста:

publicclassNakeDispatcher:INakeDispatcher
{
#regionDataDealerFactory
privateIDataDealerFactorydataDealerFactory=null;
publicIDataDealerFactoryDataDealerFactory
{
set
{
this.dataDealerFactory=value;
}
}
#endregion#regionContractHelper
privateIContractHelpercontractHelper=null;
publicIContractHelperContractHelper
{
set
{
this.contractHelper=value;
}
}
#endregion#regionУчастник интуикливаштераpublicNetMessageDispatchMessage(NetMessagemsg)
{
IDataDealerdealer=this.dataDealerFactory.CreateDealer(msg.Header.ServiceKey,msg.Header.TypeKey);
if(dealer==null)
{
returnthis.contractHelper.GetResponseByServiceResultType(msg,ServiceResultType.ServiceIsNotExist);
}returndealer.DealRequestMessage(msg);
}#endregion
}

Как правило, когда клиент использует компоненты ImessedIscatcher, нам не нужно использовать ворота-ворота, если это так, то мы не будем Messagedispatcher.Свойство GatewayMessage можно вводить в объект.

Предыдущий:ESFRAMEWORK Введение (4) – Интернет-передача сообщений inetmessageHook

Перейти к:Esframework может быть мультиплексированной связи связи (порядок)

Время на прочтение
6 мин

Количество просмотров 19K

Появился свободный день, и я решил поиграться с библиотекой google::protobuf. Данная библиотека предоставляет возможность кодирования и декодирования структурированных данных. На базе этой библиотеки я построю простенький диспетчер, который может обрабатывать любые сообщения. Необычность данного диспетчера состоит в том, что он не будет знать типы передаваемых сообщений, и будет обрабатывать сообщения только с помощью зарегистрированных обработчиков.

Краткое описание библиотеки protobuf

Итак, сначала вкратце рассмотрим библиотеку google::protobuf, она поставляется в виде двух компонент:
собственно, сама библиотека + заголовочные файлы
компилятор файлов *.proto — генерирует из описания сообщения C++ класс (также есть возможность генерации для других языков программирования: Java, Python и т.д.)
В отдельном файле создается описание сообщения, из которого будет сгенерирован класс, синтаксис очень простой:

package sample.proto;

message ServerStatusAnswer {
    optional int32 threadCount = 1;
    repeated string listeners = 2;
}

Здесь мы описываем сообщение ServerStatusAnswer, которое имеет два необязательных поля:

• threadCount — необязательный целочисленный параметр
• listeners — необязательная строка, которая может несколько раз повторяться

Данному описанию удовлетворяет, например, следующее сообщение:

ServerStatusAnswer {
    threadCount = 3
    listeners = {
        "one",
        "two"
    }
}

На самом деле формат protobuf — бинарный, здесь я привел сообщение в читаемом формате только для удобства восприятия

Компилятор автоматически генерирует C++ код для сериализации и десериализации подобных сообщений. Библиотека protobuf также предоставляет дополнительные возможности: сериализация в файл, в поток, в буфер.

Я использую CMake в качестве системы сборки, и в нем уже есть поддержка protobuf:

cmake_minimum_required(VERSION 2.8)

project(ProtobufTests)

find_package(Protobuf REQUIRED)
include_directories(${PROTOBUF_INCLUDE_DIRS})
include_directories(${CMAKE_CURRENT_BINARY_DIR})
#...
set (ProtobufTestsProtoSources
    Message.proto
    ServerStatus.proto
    Echo.proto
)
#...
PROTOBUF_GENERATE_CPP(PROTO_SRCS PROTO_HDRS ${ProtobufTestsProtoSources})
add_executable(ProtobufTests ${ProtobufTestsSources} ${PROTO_SRCS} ${PROTO_HDRS})

target_link_libraries(ProtobufTests
    #...
    ${PROTOBUF_LIBRARY}
)

PROTOBUF_GENERATE_CPP — данный макрос вызывает компилятор protoc для каждого *.proto файла, и генерирует соответствующие cpp и h файлы, которые добавляются к сборке.
Все делается автоматически, и никаких дополнительных приседаний делать не надо (Под *nix может понадобиться дополнительный пакет Threads и соответствующий флаг линковщику).

Описание диспетчера

Я решил попробовать написать диспетчер сообщений, который принимает какое-то сообщение, вызывает соответствующий обработчик и отправляет ответ на полученное сообщение. При этом диспетчер не должен знать типы передаваемых ему сообщений. Это может быть необходимо в случае, если диспетчер добавляет или удаляет соответствующие обработчики в процессе работы (например, подгрузив соответствующий модель расширения, *.dll, *.so).

Для того чтобы обрабатывать произвольные сообщения, у нас должен быть класс, который обрабатывает абстрактное сообщение. Очевидно, если у нас будут описания сообщений в *.proto файле, то компилятор нам сгенерирует соответствующие классы, но к сожалению все они будут наследованы от google::protobuf::Message. У данного класса проблематично вытащить все данные из сообщения (сделать это в принципе можно, но тогда мы будем делать кучу лишней работы), к тому же мы не будем знать, как нам сформировать ответ.
На помощь приходит высказывание: «Любую проблему можно решить путём введения дополнительного уровня абстракции, кроме проблемы слишком большого количества уровней абстракции».
Нам надо отделить определение типа сообщения от самого сообщения, мы это можем сделать следующим способом:

package sample.proto;

message Message {
    required string id = 1;
    optional bytes data = 2;
}

Мы запакуем наше сообщение внутрь еще одного сообщения:

• обязательное поле id содержит уникальный идентификатор сообщения
• необязательное поле data содержит наше сообщение

Таким образом, наш диспетчер будет по полю id искать соответствующий обработчик сообщения:

#ifndef MESSAGEDISPATCHER_H
#define MESSAGEDISPATCHER_H

#include <map>
#include <stdexcept>

#include <boost/noncopyable.hpp>
#include <boost/smart_ptr/shared_ptr.hpp>

#include "message.pb.h"

class MessageProcessingError: public std::runtime_error
{
public:
    MessageProcessingError(const std::string & e): std::runtime_error(e)
    {
    }
};

class MessageProcessorBase: private boost::noncopyable
{
public:

    virtual ~MessageProcessorBase()
    {
    }

    virtual std::string id() const = 0;

    virtual sample::proto::Message process(const sample::proto::Message & query) = 0;
};

typedef boost::shared_ptr<MessageProcessorBase> MessageProcessorBasePtr;

class MessageDispatcher
{
public:
    MessageDispatcher();

    void addProcessor(MessageProcessorBasePtr processor);

    sample::proto::Message dispatch(const sample::proto::Message & query);

    typedef std::map<std::string, MessageProcessorBasePtr> DispatcherImplType;

    const DispatcherImplType & impl() const;

private:
    DispatcherImplType mImpl;
};

#endif // MESSAGEDISPATCHER_H

Но теперь мы получаем, что каждый обработчик должен проводить распаковку сообщения sample::proto::Message в свое собственное сообщение. А этот процесс будет дублироваться для каждого такого обработчика. Мы хотим избежать дублирования кода, поэтому возьмем паттерн Type Erasure. Данный паттерн позволяет скрыть тип обрабатываемой сущности за общим интерфейсом, однако каждый обработчик будет работать с конкретным типом, известным только ему.

Итак, реализация очень проста:

template <typename ProtoQueryT, typename ProtoAnswerT>
class ProtoMessageProcessor: public MessageProcessorBase
{
public:
    virtual sample::proto::Message process(const sample::proto::Message & query)
    {
        ProtoQueryT underlyingQuery;
        if (!underlyingQuery.ParseFromString(query.data()))
        {
            throw MessageProcessingError("Failed to parse query: " +
                query.ShortDebugString());
        }

        ProtoAnswerT underlyingAnswer = doProcessing(underlyingQuery);

        sample::proto::Message a;
        a.set_id(query.id());

        if (!underlyingAnswer.SerializeToString(a.mutable_data()))
        {
            throw MessageProcessingError("Failed to prepare answer: " +
                underlyingAnswer.ShortDebugString());
        }
        return a;
    }

private:
    virtual ProtoAnswerT doProcessing(const ProtoQueryT & query) = 0;
};

Мы определяем виртуальную функцию process, но также добавляем виртуальную функцию doProcess, которая уже работает с нашими конкретными сообщениями! Данный прием основан на механизме инстанцирования шаблонов: типы подставляются в момент реального использования шаблона, а не в момент декларации. А так как данный класс наследуется от MessageProcessorBase, то мы смело можем передавать наследников данного класса в наш диспетчер. Также необходимо заметить, что данный класс осуществляет сериализацию и десериализацию наших конкретных сообщений и кидает исключения в случае возникновения ошибок.

Ну и напоследок приведу пример использования данного диспетчера, допустим у нас есть два вида сообщений:

package sample.proto;

message ServerStatusQuery {
}

message ServerStatusAnswer {
    optional int32 threadCount = 1;
    repeated string listeners = 2;
}

package sample.proto;

message EchoQuery {
    required string msg = 1;
}

message EchoAnswer {
    required string echo = 1;
}

Как видно из описания — данные сообщения запрашивают у сервера его внутреннее состояние (ServerStatus), и просто возвращает полученный запрос (Echo). Реализация самих обработчиков тривиальна, я приведу реализацию только ServerStatus:

#ifndef SERVERSTATUSMESSAGEPROCESSOR_H
#define SERVERSTATUSMESSAGEPROCESSOR_H

#include "MessageDispatcher.h"

#include "ServerStatus.pb.h"

class ServerStatusMessageProcessor:
        public ProtoMessageProcessor<sample::proto::ServerStatusQuery, sample::proto::ServerStatusAnswer>
{
public:

    typedef sample::proto::ServerStatusQuery query_type;
    typedef sample::proto::ServerStatusAnswer answer_type;

    ServerStatusMessageProcessor(MessageDispatcher * dispatcher);

    virtual std::string id() const;

private:
    MessageDispatcher * mDispatcher;

    virtual answer_type doProcessing(const query_type & query);
};

#endif // SERVERSTATUSMESSAGEPROCESSOR_H

Сама реализация:

#include "ServerStatusMessageProcessor.h"

using namespace sample::proto;

ServerStatusMessageProcessor::ServerStatusMessageProcessor(MessageDispatcher * dispatcher)
    : mDispatcher(dispatcher)
{
}

std::string ServerStatusMessageProcessor::id() const
{
    return "ServerStatus";
}

ServerStatusAnswer ServerStatusMessageProcessor::doProcessing(const ServerStatusQuery & query)
{
    ServerStatusAnswer s;

    s.set_threadcount(10);

    typedef MessageDispatcher::DispatcherImplType::const_iterator md_iterator;

    const MessageDispatcher::DispatcherImplType & mdImpl = mDispatcher->impl();

    for (md_iterator it = mdImpl.begin(); it != mdImpl.end(); ++it)
    {
        s.add_listeners(it->first);
    }

    return s;
}

Вот как это работает:

#include "MessageDispatcher.h"

#include "ServerStatusMessageProcessor.h"
#include "EchoMessageProcessor.h"

#include <iostream>
#include <boost/smart_ptr/make_shared.hpp>

using namespace sample::proto;

int main()
{
    try
    {
        MessageDispatcher md;

        md.addProcessor(boost::make_shared<ServerStatusMessageProcessor>(&md));
        md.addProcessor(boost::make_shared<EchoMessageProcessor>());

        Message q;
        q.set_id("ServerStatus");
        Message ans = md.dispatch(q);

        std::cout << "query:  " << q.DebugString() << std::endl;
        std::cout << "answer: " << ans.DebugString() << std::endl;
    }
    catch (const std::exception & e)
    {
        std::cerr << e.what() << std::endl;
    }

    return 0;
}

P.S. Для написания данной статьи использовались:

• gcc-4.4.5-linux
• cmake-2.8.2
• boost-1.42
• protobuf-2.3.0

Пример выложен на github

• Download source – 57.11 KB
• Download Windows Service Installer – 386.91 KB

Introduction

While programming various WEB applications, I have many times come across the need to send a message to interested users. For example, when a customer purchases a good from my e-shop, I want to send him an e-mail with the order details.

The piece of code that I am publishing here helps me out with this task as follows:

• It is a DLL that offers me an API to send an e-mail.

• Delivery is asynchronous. Hence, the application returns immediately and the actual delivery of the e-mail takes place later on. This has serious advantages over a synchronous delivery. Such as:

  • E-mail delivery may take some time, since it requires connection to SMTP server. With asynchronous delivery, the user does not perceive this delay.

  • SMTP server might be down and not responding to e-mail delivery. With asynchronous communication, I can build a nice retry mechanism.

Using the Code

In order to use it in your programs, you need to take care of the following:

• Prepare your database. You need a Microsoft SQL Database. This is used to hold the messages that are queued for delivery. Note that in the folder database of MessageDispatcherDAL project, you will find the script named create_and_initialize_tables.sql that you can use to create and initialize the tables. IMPORTANT: The script DOES NOT create the database neither the login to access it. You have to do that. This is done, because it assumes that the whole set of the necessary tables would be most probably live inside a bigger database, designed to serve the needs of the application that would host the Message Dispatcher. What does the script do?

  • Creates the table Messages. It holds the messages that you want to be delivered.

  • Creates the table MessageTypes. Currently only email is really supported. But in the future, I may introduce the features to support sms too. You may find the value sms in the table, but this is not supported yet.

  • Creates the table MessageStatuses. It contains the values of the statuses of the messages. The supported statuses are:

    • NEW: Non-final Status. This is the status of a message that has just been put in the queue.

    • SENT: Final Status. This is the status of a message that has been successfully sent out.

    • FAILED: Non-Final Status. This is the status of a message that has not been sent out, due to some error. However, this is not a final status. MessageDispatcher will retry the delivery.

    • ERROR: Final Status. This is a final status that indicates that the message has failed to be delivered, even if MessageDispatcher has tried more than once.

  • Creates the table MessageBodyTypes. This is a lookup table that contains two values:

    • plain

    • html

    If you are delivering an e-mail that contains HTML content, then you need to use html. If not, but just plain text, you need to use plain. Note that if you choose html then both plain text and HTML versions are combined in the same message.

  • Schema: The schema in which all objects are created is dbo. If you want to change the default schema name, you need to:

    • Edit MessageDispatcherDAL.edmx file in project MessageDispatcherDAL and change the Schema entries to have the value you want, when now they have the value dbo.

    • Also, in the same file, change the value of DefaultDatabaseSchema from dbo to whatever you want.

    • Save and rebuild project MessageDispatcherDAL.

• Install the Message Dispatcher Windows Service. Messages are being processed asynchronously with the help of a Windows Service. So, you need to install it. These are the instructions:

  • Project MessageDispatcherWindowsServiceSetup creates the setup.exe that you can use to install the service.

    OR

  • You can run the setup.exe that exists inside the zip MessageDispatcherWindowsServiceInstaller.zip that you can download from the top of the article.

  Note that the installer installs the windows service and sets its Startup Type to be Manual. After the installation on your production server, change this to Automatic, so that whenever your server starts up, this service is started up automatically too.

• Configure Message Dispatcher Windows Service. Message Dispatcher windows service needs to know:

  • How to connect to the database to find out the messages that need to be processed.

  • How to connect to the SMTP Server in order to send the e-mails.

  Configuration of the Message Dispatcher Windows Service is done by setting appropriately the values in the configuration file with name MessageDispatcherWindowsService.exe.config that resides in the folder where the service has been installed.

  • Configure database connection: Set the appropriate connection string with name MessageDispatcherDALContainer. An example is given below:

    <connectionStrings>
        <add name="MessageDispatcherDALContainer" 
    	connectionString="metadata=res://*/MessageDispatcherDAL.csdl|
    	res://*/MessageDispatcherDAL.ssdl|res://*/MessageDispatcherDAL.msl;
    	provider=System.Data.SqlClient;
    	provider connection string="Data Source=MYSQLSERVER,50708SQLEXPRESS;
    	Initial Catalog=my_db;Persist Security Info=True;User ID=my_db;
    	Password=my_db;MultipleActiveResultSets=True"" 
    	providerName="System.Data.EntityClient"/>
    </connectionStrings>

  • SMTP Connection settings: In the same file, MessageDispatcherWindowsService.exe.config sets the following values appropriately, as in the example:

    <appSettings>
        <add key="MessageDispatcherWindowsService.Smtp.Server" 
    	value="mail.foo.com"/>
        <add key="MessageDispatcherWindowsService.Smtp.Username" 
    	value="user@foo.com"/>
        <add key="MessageDispatcherWindowsService.Smtp.Password" value="password"/>
    </appSettings>

    If your SMTP server does not require authentication, then set an empty string as value for both MessageDispatcherWindowsService.Smtp.Username and MessageDispatcherWindowsService.Smtp.Password.

  • Other minor service configuration settings:

    • Sleep Between Processing: The seconds between processing messages. Windows service sleeps this number of seconds before checking again for new messages.

      <appSettings>
          <add key="MessageDispatcherWindowsService.MainThreadSleepSeconds" 
      	value="3"/>
      </appSettings>  

    • Maximum number of failures before error: For each message that fails to be delivered, the service will retry that maximum number of times. If it fails all the times, the status of the message becomes ERROR.

      <appSettings>
          <add key="MessageDispatcherWindowsService.
      	MaximumNumberOfFailuresBeforeError" value="3"/>
      </appSettings>

    • Timeout Between Retries In Minutes: For each message that fails delivery, the next retry will be later than this amount of minutes.

      <appSettings>
          <add key="MessageDispatcherWindowsService.
      	TimeoutBetweenRetriesInMinutes" value="3"/>
      </appSettings>

• Integrate in your Code. You need to use the MessageDispatcher API in your project in order to be able to send messages from your project. Follow the next instructions alongside the MessageDispatcherWindowsConsoleDemo project:

  • Reference MessageDispatcherDAL.dll in your project.

  • Create a database connection configuration string. This is necessary so that MessageDispatcherDAL knows where is the persistence storage of the message queues.

    For example, you can configure that in your app.config file (<configuration> section), if you have a Windows Console Application, as follows:

    <connectionStrings>
       <add name="MessageDispatcherDALContainer" 
    	connectionString="metadata=res://*/MessageDispatcherDAL.csdl|
    	res://*/MessageDispatcherDAL.ssdl|res://*/MessageDispatcherDAL.msl;
    	provider=System.Data.SqlClient;
    	provider connection string="Data Source=MYSQLSERVER,50708SQLEXPRESS;
    	Initial Catalog=my_db;Persist Security Info=True;User ID=my_db;
    	Password=my_db;MultipleActiveResultSets=True"" 
    	providerName="System.Data.EntityClient"/>
    </connectionStrings>         

    Make sure you set correctly the server host name, the server port, the initial catalog, the user id and the password.

  • Create a message using the Message.CreateEmailMessage(...) method, as in the following example:

    
    
    
    
    Message.CreateEmailMessage(no_reply@foo.com, 
    	"customer1@gmail.com;customer2@yahoo.gr", null, null,
           	"Your Order Details", "Order ID: 5, 
    	Date of Purchase: 25-Nov-2011, Amount: 29.00 Euro", false);

    This will create a new entry in the table Messages and on status NEW. Message Dispatcher Windows Service will take care from there.

  • Catch exception. Don’t forget to wrap Message.CreateEmailMessage(....) in a try { ... } catch (...) {...} block. Otherwise, make sure you catch any exception that this method might throw. You do not want your application to crash just because a message cannot be saved. Here is another example of using this method to send HTML message, wrapped to catch exceptions:

    try
    {
        Message.CreateEmailMessage(no_reply@foo.com, 
    	"customer1@gmail.com;customer2@yahoo.gr", null, null,
           	"Your Order Details", 
    	"<html><head></head><body><b>Order ID:</b> 5<br />
    	<b>Date of Purchase:</b> 25-Nov-2011<br /><b>Amount:</b> 
    	29.00 Euro<body></body></html>", true);
    }
    catch (EntityException ex)
    {
        System.Console.WriteLine("Cannot create message: " + ex.Message);
    }  

Summary

I believe it is quite easy for you to send your e-mails asynchronously, using this DLL and Windows Service.

• Install the Windows Service
• Configure Windows Service
• Integrate in your code

Your comments are welcome and thanks for reading this far.

History

• 27^th November, 2011: Initial post