Hello! Hola! Hej!

- AMQP(Advanced Message Queue Protocol) + elang으로 구성.

1. 클라이언트들에서 메시지를 받아서 분배하는 역할
2. https://www.rabbitmq.com/dotnet.html 

* 나의 경우는 웹으로 모니터링 할 수 있게끔 c#으로 client를 구축

1. 홈페이지에서 rabbitmq-dotnet-client-3.3.4-dotnet-3.0.zip 을 받아, RabbitMQ.Client.dll 을 참조하여 RabbitMQ 사용할 준비를 끝낸다.

2. 이 토끼씨는... 예제가 잘 되어 있다. 언어별로... ㅎ 여기를 차근차근 따라하면 okay! (Tutorials : http://www.rabbitmq.com/getstarted.html)

또한, pdf도 제공하고 있으니,, 자세한것은 pdf 참고!! ( 나의 경우는 //2.8. Retrieving messages by subscription used. )

3. 기본 알고리즘

var factory = new ConnectionFactory()

{

UserName = "username",

Password = "password",

Protocol = Protocols.FromEnvironment(),

Port = AmqpTcpEndpoint.UseDefaultPort,

//factory.Uri = "amqp://user:pass@hostName:port/vhost";

Uri = "amqp://username:password@uri"

};

public class ConnectionFactory

{

public const ushort DefaultChannelMax = 0;

public const int DefaultConnectionTimeout = 30000;

public const uint DefaultFrameMax = 0;

public const ushort DefaultHeartbeat = 0;

public const string DefaultPass = "guest";

public const string DefaultUser = "guest";

public const string DefaultVHost = "/";

public AuthMechanismFactory[] AuthMechanisms;

public IDictionary<string, object> ClientProperties;

public static AuthMechanismFactory[] DefaultAuthMechanisms;

public string HostName;

public string Password;

public int Port;

public IProtocol Protocol;

public ushort RequestedChannelMax;

public int RequestedConnectionTimeout;

public uint RequestedFrameMax;

public ushort RequestedHeartbeat;

public ConnectionFactory.ObtainSocket SocketFactory;

public SslOption Ssl;

public string UserName;

public string VirtualHost;

public ConnectionFactory();

public AmqpTcpEndpoint Endpoint { get; set; }

public string Uri { set; }

public Uri uri { set; }

public AuthMechanismFactory AuthMechanismFactory(string[] mechs);

public virtual IConnection CreateConnection();

public virtual IConnection CreateConnection(int maxRedirects);

protected virtual IConnection CreateConnection(int maxRedirects, IDictionary<AmqpTcpEndpoint, int> connectionAttempts, IDictionary<AmqpTcpEndpoint, Exception> connectionErrors, params AmqpTcpEndpoint[] endpoints);

public static TcpClient DefaultSocketFactory(AddressFamily addressFamily);

protected virtual IConnection FollowRedirectChain(int maxRedirects, IDictionary<AmqpTcpEndpoint, int> connectionAttempts, IDictionary<AmqpTcpEndpoint, Exception> connectionErrors, ref AmqpTcpEndpoint[] mostRecentKnownHosts, AmqpTcpEndpoint endpoint);

public delegate TcpClient ObtainSocket(AddressFamily addressFamily);

}

IConnection conn = factory.CreateConnection();

public interface IConnection : IDisposable

{

bool AutoClose { get; set; }

ushort ChannelMax { get; }

IDictionary<string, object> ClientProperties { get; }

ShutdownEventArgs CloseReason { get; }

AmqpTcpEndpoint Endpoint { get; }

uint FrameMax { get; }

ushort Heartbeat { get; }

bool IsOpen { get; }

AmqpTcpEndpoint[] KnownHosts { get; }

IProtocol Protocol { get; }

IDictionary<string, object> ServerProperties { get; }

IList<ShutdownReportEntry> ShutdownReport { get; }

event CallbackExceptionEventHandler CallbackException;

event ConnectionBlockedEventHandler ConnectionBlocked;

event ConnectionShutdownEventHandler ConnectionShutdown;

event ConnectionUnblockedEventHandler ConnectionUnblocked;

void Abort();

void Abort(int timeout);

void Abort(ushort reasonCode, string reasonText);

void Abort(ushort reasonCode, string reasonText, int timeout);

void Close();

void Close(int timeout);

void Close(ushort reasonCode, string reasonText);

void Close(ushort reasonCode, string reasonText, int timeout);

IModel CreateModel();

void HandleConnectionBlocked(string reason);

void HandleConnectionUnblocked();

}

IModel channel = conn.CreateModel();

channel.QueueDeclare(inputQueueName, durable, autoDelete, autoDelete, arguments);

public interface IModel : IDisposable

{

ShutdownEventArgs CloseReason { get; }

IBasicConsumer DefaultConsumer { get; set; }

bool IsClosed { get; }

bool IsOpen { get; }

ulong NextPublishSeqNo { get; }

event BasicAckEventHandler BasicAcks;

event BasicNackEventHandler BasicNacks;

event BasicRecoverOkEventHandler BasicRecoverOk;

event BasicReturnEventHandler BasicReturn;

event CallbackExceptionEventHandler CallbackException;

event FlowControlEventHandler FlowControl;

event ModelShutdownEventHandler ModelShutdown;

[AmqpMethodDoNotImplement("")]

void Abort();

[AmqpMethodDoNotImplement("")]

void Abort(ushort replyCode, string replyText);

void BasicAck(ulong deliveryTag, bool multiple);

[AmqpMethodDoNotImplement("")]

void BasicCancel(string consumerTag);

[AmqpMethodDoNotImplement("")]

string BasicConsume(string queue, bool noAck, IBasicConsumer consumer);

[AmqpMethodDoNotImplement("")]

string BasicConsume(string queue, bool noAck, string consumerTag, IBasicConsumer consumer);

[AmqpMethodDoNotImplement("")]

string BasicConsume(string queue, bool noAck, string consumerTag, IDictionary<string, object> arguments, IBasicConsumer consumer);

[AmqpMethodDoNotImplement("")]

string BasicConsume(string queue, bool noAck, string consumerTag, bool noLocal, bool exclusive, IDictionary<string, object> arguments, IBasicConsumer consumer);

[AmqpMethodDoNotImplement("")]

BasicGetResult BasicGet(string queue, bool noAck);

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]

void BasicNack(ulong deliveryTag, bool multiple, bool requeue);

[AmqpMethodDoNotImplement("")]

void BasicPublish(PublicationAddress addr, IBasicProperties basicProperties, byte[] body);

[AmqpMethodDoNotImplement("")]

void BasicPublish(string exchange, string routingKey, IBasicProperties basicProperties, byte[] body);

[AmqpMethodDoNotImplement("")]

void BasicPublish(string exchange, string routingKey, bool mandatory, IBasicProperties basicProperties, byte[] body);

[AmqpMethodDoNotImplement("")]

void BasicPublish(string exchange, string routingKey, bool mandatory, bool immediate, IBasicProperties basicProperties, byte[] body);

void BasicQos(uint prefetchSize, ushort prefetchCount, bool global);

[AmqpMethodDoNotImplement("")]

void BasicRecover(bool requeue);

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]

void BasicRecoverAsync(bool requeue);

void BasicReject(ulong deliveryTag, bool requeue);

[AmqpMethodDoNotImplement("")]

void Close();

[AmqpMethodDoNotImplement("")]

void Close(ushort replyCode, string replyText);

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8")]

[AmqpMethodDoNotImplement("")]

void ConfirmSelect();

[AmqpContentHeaderFactory("basic")]

IBasicProperties CreateBasicProperties();

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9_1")]

[AmqpContentHeaderFactory("file")]

IFileProperties CreateFileProperties();

[AmqpContentHeaderFactory("stream")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9_1")]

IStreamProperties CreateStreamProperties();

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9_1")]

void DtxSelect();

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9_1")]

void DtxStart(string dtxIdentifier);

[AmqpMethodDoNotImplement("")]

void ExchangeBind(string destination, string source, string routingKey);

[AmqpMethodDoNotImplement("")]

void ExchangeBind(string destination, string source, string routingKey, IDictionary<string, object> arguments);

[AmqpMethodDoNotImplement("")]

void ExchangeDeclare(string exchange, string type);

[AmqpMethodDoNotImplement("")]

void ExchangeDeclare(string exchange, string type, bool durable);

[AmqpMethodDoNotImplement("")]

void ExchangeDeclare(string exchange, string type, bool durable, bool autoDelete, IDictionary<string, object> arguments);

[AmqpMethodDoNotImplement("")]

void ExchangeDeclarePassive(string exchange);

[AmqpMethodDoNotImplement("")]

void ExchangeDelete(string exchange);

[AmqpMethodDoNotImplement("")]

void ExchangeDelete(string exchange, bool ifUnused);

[AmqpMethodDoNotImplement("")]

void ExchangeUnbind(string destination, string source, string routingKey);

[AmqpMethodDoNotImplement("")]

void ExchangeUnbind(string destination, string source, string routingKey, IDictionary<string, object> arguments);

[AmqpMethodDoNotImplement("")]

void QueueBind(string queue, string exchange, string routingKey);

[AmqpMethodDoNotImplement("")]

void QueueBind(string queue, string exchange, string routingKey, IDictionary<string, object> arguments);

[AmqpMethodDoNotImplement("")]

QueueDeclareOk QueueDeclare();

[AmqpMethodDoNotImplement("")]

QueueDeclareOk QueueDeclare(string queue, bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments);

[AmqpMethodDoNotImplement("")]

QueueDeclareOk QueueDeclarePassive(string queue);

[AmqpMethodDoNotImplement("")]

uint QueueDelete(string queue);

[AmqpMethodDoNotImplement("")]

uint QueueDelete(string queue, bool ifUnused, bool ifEmpty);

[AmqpMethodDoNotImplement("")]

uint QueuePurge(string queue);

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]

void QueueUnbind(string queue, string exchange, string routingKey, IDictionary<string, object> arguments);

void TxCommit();

void TxRollback();

void TxSelect();

[AmqpMethodDoNotImplement("")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8")]

bool WaitForConfirms();

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]

[AmqpMethodDoNotImplement("")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9")]

bool WaitForConfirms(TimeSpan timeout, out bool timedOut);

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]

[AmqpMethodDoNotImplement("")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8")]

void WaitForConfirmsOrDie();

[AmqpMethodDoNotImplement("")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_9")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]

[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8")]

void WaitForConfirmsOrDie(TimeSpan timeout);

}

WEB API

SOAP, WS 보다 기본적인 HTTP 위에 노출된 서비스와 같은RESTful 서비스 개발 가능

1. 프로젝트 만들기
   1. ASP.NET MVC 4 PROJECT > project name : 'WorkManagerSimple '
   2. PROJECT TEMPLATE > Web API

      *NuGet 사용 : 패키지관리솔루션

       

2. Controller > ValuesController.cs
3. Models > Add > Class > WorkManager.cs 생성
   1. Entity Framework의 code First 컨벤션을 사용
      1. public class WorkManager
      2. {
      3. public int id { get; set; }
      4. public string name { get; set; }
      5. public string detail { get; set; }
      6. }
4. Controller에서 폴더 추가하여 Web API컨트롤러 분리시킨다.
   1. Controller > new folder > Apis
   2. Apis > add > Controller
      1. Controller name : workmgtController
      2. Tamplate : MVC controller with read/write actions and views, using Entity Framework
      3. Model class :
      4. ..... http://www.youtube.com/watch?v=Dkgr3lpE_LY

ORDER BY CASE 필드이름 WHEN '조건' THEN 1 <- '1'은 우선순위

WHEN '조건' THEN 2

WHEN '조건' THEN 3 END , INPUT_DATE DESC

예)

ORDER BY CASE DBO.FN_GET_ STANDARD_YN(A._SEQ)

WHEN 'N' THEN 1 WHEN 'Y' THEN 2 END, INPUT_DT DESC

=> 1순위로 GET_STANDARD_YN이 N 일때 정렬함.

MYSQL에서는 KEY값에다가 AUTOINCREMENT 라고 써주며 되었던 것 같은데, MSSQL에서는 조금 다른 것 같다.

| 방법1. CREATE TABLE

테이블 생성 할 때, 컬럼명 옆에 아래와 같이  IDENTITY 라고 작성해 준다. 

   [MEDIA_SEQ] [int] IDENTITY(1,1) NOT NULL,
    [CATEGORY] [nvarchar](50) NOT NULL,
    [FIMENAME] [nvarchar](50) NOT NULL,

| 방법2. Microsoft SQL Server Management studio 

유효성 검사

이 모든 것이 자동으로 생성된다! 완전 편리해~~~~~ sPRING할 때 유효성검사 다 지정해 줬어야 했는데 여기는 완전 할 필요도 없그만!

이 코드의 Model 개체는 강력한 형식이므로 (IEnumerable<Movie> 개체), 루프문 내부의 item 개체는 Movie 형식입니다. 결과적으로, 다른 여러 가지 장점들과 함께, 컴파일 시점 검사와 코드 편집기 상에서의 완벽한 인텔리센스를 지원 받을 수 있습니다. 

1. 컨트롤러에서 모델 데이터에 접근하기

스캐폴딩(Scaffolding) 기능을 이용하여 새로운 컨트롤러와 뷰를 추가한다.

(CRUD(Create, Read, Update, Delete)와 관련된 액션 메서드와 뷰들을 생성해주는 것입니다. (이런 방식으로 자동으로 만들어진 CRUD 액션 메서드와 뷰들을 다른 말로 스캐폴딩(Scaffolding)이라고도 부릅니다)

- 컨트롤러 추가

: Controller 폴더 > 우클릭 > Add > Controller

DB가 잘 연결될 수 있도록 해당사항에 잘 연결한다.

db에서 key인 것에 키를 등록한다.

using System.ComponentModel.DataAnnotations;

[Key]

public int SEQ { get; set; }

그러면 오류생기지 않고 컨트롤러 만들 수 있다!

* 전체적 흐름

기본화면

* 컨트롤러에서 뷰로 정보를 전달하는 방법

컨트롤러 클래스 : URL 요청에 대한 응답과정을 호출 -> 전달된 브라우저 요청을 처리 -> DB에서 데이터를 가져온다 -> 어떤 형식의 응답을 브라우저에 전송할 것인지를 결정하는 코드들이 작성되는 위치! -> 그 후에, 브라우저로 전달될 HTML 응답을 생성하고 형식화하기 위해 컨트롤러에 뷰 템프릿을 사용

뷰템플릿은 업무 로직을 수해아거나, 직접 연결해서는 안된다! 모든 데이터는 컨트롤러에서부터 받아서 작업을 수행! => 이로써 유지보수가 용이한 코드를 유지할 수 있다.

1. 모델추가하기
2. Modes 폴더 > 우클릭 Add > New Item > Code > Class 선택 > Work.cs
   1. 만들어진 해당 클래스에 데이터베이스에서 정보를 가지고 올 수 있도록 선언한다.
      1. public class Work
      2. {
      3. // 데이터베이스의 정보를 나타내기 위한 것,
      4. // 각각의 work 개체 인스턴스는 db 테이블의 'Row'에 해당하고,
      5. // Work 클래스의 각 속성들을 테이블의 'column'과 맵핑된다.
      7. public int SEQ {get; set;}
      8. public string TYPES_ { get; set; }
      9. public string VERSIONS { get; set; }
      10. public string SUMMARY { get; set; }
      11. public string DETAILS { get; set; }
      12. public string Title { get; set; }
      13. public DateTime INITDAES { get; set; }
      14. public DateTime FINDATES { get; set; }
      15. public DateTime ReleaseDate { get; set; }
      16. public decimal YN { get; set; }
      17. }//Work

           

   2. 동일한 파일에 데이터베이스를 연결할 Context를 만든다.

1. public class WorkDBContext : DbContext
2. {
3. // db에서 work 클래스의 인스턴스를 가져오고, 저장하고, 갱신하는 작업을 처리
4. // Entity FrameWork로부터 제공되는 dbContext 기본클래스를 상속받는다.
6. public DbSet<Work> Works { get; set; }
7. }//WorkDBContext

1. 연결 문자열 생성 및 SQL 서버 LocaDB 작업하기
   프로젝트의 Web.config 에서 다음과 같이 연결한다.

    

   1. <add name="WorkDBContext" connectionString="Data Source=.\SQLEXPRESS;Initial Catalog=aspnet-MvcMovies-20131008092844;Integrated Security=SSPI"
   2. providerName="System.Data.SqlClient" />

ASP.NET MVC는 전달된 URL을 기준으로 선택된 컨트롤러 클래스를 (그리고, 그 클래스에 존재하는 선택된 메서드를) 호출합니다. ASP.NET MVC가 사용하는 기본 URL 라우팅 로직은, 실행할 컨트롤러와 메서드를 결정하기 위해서 다음과 같은 형태의 URL을 사용합니다: 

View

Razor뷰 엔진

 ASP.NET MVC 3에서 처음 도입된 Razor 뷰 엔진을 사용해서 작성해 볼 것입니다. Razor 기반의 뷰 템플릿은 .cshtml 이라는 파일 확장자를 갖고 있으며, C#을 이용한 우아한 HTML 출력 생성 방식을 제공해줍니다. Razor를 이용하면 뷰 템플릿 작성을 위해 필요한 글자수와 키입력을 최소화할 수 있으며, 빠르고 자연스러운 코딩이 가능해집니다. 

1. _Layout.cshtml : 웹페이지에서 공통으로 사용되는 페이지 ( cf. 마스터 페이지)

상단의 로고 위치라던지, page 메뉴들을 공통으로 지정할 수 있다.

1. Index.cshtml

1. 새로운 프로젝트 만들기
   1. 새 프로젝트 > ASP.NET MVC 2 웹 응용 프로그램 > 프로젝트 생성
2. DB연결
   1. APPDATA > 우클릭 > 추가 > SQL Server 데이터베이스 > 이름 : (DB이름).mdf > 추가
3. MODEL 만들기 위해서 model 폴더에서 우클릭 > LINQ to SQL 생성 (workClass.dbml)
   1. 서버탐색기 > 테이블 > VIEW에 보여질 테이블을 선택해서 화면에 드래그앤 드롭 > 저장

       

      

*workClass.designer.cs 에 자동으로 db관련하여 생성된다.

1. 모델 작업 끝.

웹 어플리케이션의 구조를 Model(모델), View(뷰), Controller(컨트롤러)로 분리하는 패턴

 - Model(모델) : 실제 로직을 구현하는 부분. 일반적으로 데이터베이스로부터 데이터를 가져와서 담아두거나, 데이터 베이스로 저장하는 역할

- View (뷰) : 사용자 인터페이스, 즉, UI부분. 화면 출력과 관계된 로직을 포함할 수는 있지만, 사용자 입력이나 인터랙션, 업무와 관계된 로직은 View가 가져서는 안된다. 오로지 화면출력!

- Controller (컨트롤러) : mvc에서 가장 핵심이 되는 패턴. 사용자의 인터렉션을 처리하고, 모델을 조작하며, 최종 UI로 출력할 수 있는 뷰를 담당한다.

이를 사용하는 이유,

1. 각 요소 간에 연결을 보다 느슨하게 구성할 수가 있게 되어, 복잡한 애플리케이션을 관리하기에 용이하다.
2. 병행 개발(동시에 각각의 컴포넌트를 개발하는 방식)이 가능하다.
3. 이러한 분리로 인하여, 기존의 ASP.NET 애플리케이션보다 훨씬 테스트하기가 용이하다.
   1. 기존의 ASP.NET을 테스트 하기 위해서는 사용자 입력에 따라 반드시 웹 서버가 요구된다는 제약이 있었지만, MVC 패턴을 적용하면 개별적인 컴포넌트를 독립적으로 테스트 할 수 있게 된다. ?? (응? 뭔소릴가.)

         

위 액션 결과는 ActionResult 클래스를 상속한다. 대부분의 경우 ViewResult를 반환한다.

웹 폼 기반의 웹 애플리케이션의 장점

· 각각의 페이지 단위로 기능을 작성하는 Page Controller 패턴을 사용한다. 
: 개별 화면 단위 중심적인 업무를 개발하기에 매우 적합하다.

· 이벤트 중심의 프로그래밍 모델을 제공한다. 
: 다양한 이벤트를 제공하는 수 많은 서버 컨트롤이 제공되기에, 이벤트 중심적인 개발을 통해 업무 화면을 직관적으로 작성할 수 있다.

· 뷰상태(ViewState)와 서버 기반의 폼을 사용하기에, 상태 정보를 관리하기에 용이하다.

MVC 기반의 웹 애플리케이션의 장점

· 모든 요청을 단일 컨트롤러를 통해서 처리하는 Front Controller 패턴을 사용한다 
: 모든 요청을 단일 컨트롤러를 통해 처리하므로, 라우팅(routing) 하부구조를 지원하는 애플리케이션을 개발할 수 있다.

· 애플리케이션을 3개의 논리 모듈로 분리하기에 애플리케이션의 복잡성을 관리하기 쉽게 한다.

· 뷰상태나 서버 기반의 폼을 사용하지 않는다 
: 개발자가 애플리케이션의 동작방식을 전체적으로 제어할 수 있으므로 세밀하게 애플리케이션을 조작하고 싶은 이들에게 적합하다. 단, 이러한 기능(상태정보 관리)이 필요할 경우 추가적인 작업이 요구된다.

출처 : TAEYO.NET ASP.NET 강좌 웹 폼 기반의 개발과 MVC 기반의 개발 http://www.taeyo.net/Columns/View.aspx?SEQ=214&PSEQ=35&IDX=0