1. 속성창 수정안하고, 코드에서 부르기
새 콘솔 창 생성하기
또 다른 방법으로는 프로그램 실행 중에 콘솔 창을 동적으로 생성하는 방법이 있습니다.

[System.Runtime.InteropServices.DllImport("kernel32.dll")]
private static extern bool AllocConsole();

public Form1()
{
    InitializeComponent();
    
    AllocConsole();
    
    Console.WriteLine("이것은 콘솔 창에 출력됩니다.");
}


2. 프로젝트 설정 변경하기

C# Windows Forms 애플리케이션에서 Console.WriteLine()을 사용하여 명령 프롬프트 창에 메시지를 출력하려면, 프로젝트 설정을 변경하여 애플리케이션을 "콘솔 애플리케이션"으로 설정해야 합니다. 이렇게 하면 Windows Forms 애플리케이션이 실행될 때 콘솔 창이 함께 나타나고, Console.WriteLine()으로 메시지를 출력할 수 있습니다.

방법 1: 프로젝트 설정 변경하기

  1. Visual Studio에서 Windows Forms 프로젝트를 엽니다.
  2. 솔루션 탐색기에서 프로젝트를 마우스 오른쪽 버튼으로 클릭하고, "속성"을 선택합니다.
  3. "애플리케이션" 탭에서 "출력 형식"을 콘솔 응용 프로그램으로 변경합니다.

1. Redis를 이용한 실시간 push데이타 전송(서버측)
2. Redis를 이용한 실시간 push데이타 수신(클라이언트측)

1. Redis를 이용한 실시간 push데이타 전송(서버측)
1.1 KRX 정보분배 데이타를 수신후 서버측에서 파싱
1.2 클라이언트 로그인처리, 로그인키와 로그인 시간등
1.3 서버측에서 파싱후, 로그인되어진 클라이언트키로 Redis에 각각 Json포맷 데이타 전송
1.4 조회부분도 마찬가지

2. Redis를 이용한 실시간 push데이타 수신(클라이언트측)
2.1 서버측에 로그인키전달(DebugNumber + RedisServerAddress + RedisServerPort + ClientAddress)
2.2 Redis에 로그인키로 POP 연속적으로 수신
2.3 조회도 마찬가지

결론)
Redis를 이용한 실시간 push데이타 전송 & 수신은
서버측에서 클라이언트에 직접 데이타 전송과 마찬가지의 효과를 얻는다.

 

CodePagesEncodingProvider 사용 예제

CodePagesEncodingProvider를 사용하는 방법은 다음과 같습니다. 이 방법은 EUC-KR을 포함한 다양한 코드 페이지를 지원합니다.

  • EUC-KR 인코딩: C#에서는 Encoding.GetEncoding("euc-kr")를 통해 EUC-KR 인코딩을 사용할 수 있습니다. 그러나, euc-kr이 지원되지 않는 환경에서는 다른 방법을 사용해야 할 수 있습니다. 이 경우, CodePagesEncodingProvider를 추가하여 EUC-KR을 지원할 수 있습니다.
  • 버퍼 크기: UTF-8 인코딩은 가변 길이 문자 인코딩이므로, 변환 후 버퍼의 크기를 적절히 관리해야 합니다.
using System;
using System.Text;

class Program
{
    static void Main()
    {
        // EUC-KR 인코딩 제공자를 등록
        Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);

        // 예제 EUC-KR 인코딩된 바이트 데이터
        byte[] eucKrBytes = new byte[] { /* EUC-KR로 인코딩된 바이트 데이터 */ };

        // EUC-KR 인코딩으로 바이트 배열을 문자열로 변환
        Encoding eucKrEncoding = Encoding.GetEncoding("euc-kr");
        string eucKrString = eucKrEncoding.GetString(eucKrBytes);

        // 문자열을 UTF-8 인코딩으로 변환
        Encoding utf8Encoding = Encoding.UTF8;
        byte[] utf8Bytes = utf8Encoding.GetBytes(eucKrString);

        // UTF-8 바이트 배열을 문자열로 변환
        string utf8String = utf8Encoding.GetString(utf8Bytes);

        // 결과 출력
        Console.WriteLine("EUC-KR String: " + eucKrString);
        Console.WriteLine("UTF-8 String: " + utf8String);
    }
}




KRX.TCP.DATA - EUC-KR로 전달되어짐
c#이 서버역할을 할떄에 EUC-KR필드만 따로 분리해서 처리해야 한다.(예, 한글종목코드)

Redis는 클라이언트의 연결 수를 제한하는 기능을 제공합니다. 이를 통해 Redis 서버가 과도한 연결로 인해 리소스가 소모되는 것을 방지할 수 있습니다. 기본적으로 Redis는 클라이언트 연결 수에 대한 제한을 설정하지 않지만, 몇 가지 방법으로 이를 조정할 수 있습니다:

  1. maxclients 설정: Redis의 설정 파일(redis.conf)에서 maxclients 옵션을 사용하여 허용할 최대 클라이언트 연결 수를 설정할 수 있습니다. 예를 들어, maxclients 10000이라고 설정하면 최대 10,000개의 클라이언트가 동시에 연결될 수 있습니다. 이 값은 Redis 서버의 메모리와 시스템의 자원에 따라 조정해야 합니다.
  2.  
    maxclients 10000
  3. 운영 체제의 파일 핸들 제한: Redis는 운영 체제의 파일 핸들 수에 따라 제한을 받을 수 있습니다. Redis는 각 클라이언트 연결을 파일 핸들로 처리하므로, 운영 체제에서 허용하는 파일 핸들의 수에 따라 Redis의 최대 연결 수가 제한될 수 있습니다. 이를 조정하려면 운영 체제의 설정을 변경해야 합니다. 예를 들어, Linux에서는 ulimit 명령어를 사용하여 파일 핸들 수를 조정할 수 있습니다.
  4.  
    ulimit -n 10000
  5. 클라이언트 연결 수의 모니터링: Redis 서버의 연결 상태를 모니터링하는 것도 중요합니다. INFO clients 명령어를 사용하여 현재 연결된 클라이언트의 수를 확인할 수 있습니다.
  6.  
    INFO clients
  7. client-output-buffer-limit 설정: Redis는 클라이언트의 출력 버퍼가 너무 커지는 것을 방지하기 위해 client-output-buffer-limit 설정을 제공합니다. 이 설정은 클라이언트가 보내는 데이터의 크기를 제한하여 서버가 과도한 메모리를 소비하지 않도록 합니다.
  8.  
    client-output-buffer-limit pubsub 33554432 8388608 60

Redis 서버의 연결 제한을 적절히 설정하면 성능을 안정적으로 유지할 수 있으며, 시스템 자원을 효율적으로 관리할 수 있습니다.

Linux에서 C# 프로젝트를 설정하고 빌드하는 과정은 다음과 같습니다. 이 과정에서는 .NET Core 또는 .NET 5/6/7 SDK를 사용하여 C# 프로젝트를 설정하고 빌드합니다. 이 가이드는 Ubuntu 시스템을 기준으로 작성되었습니다.

1. .NET SDK 설치

패키지 목록 업데이트 및 필수 패키지 설치
sudo apt update
sudo apt install -y wget apt-transport-https software-properties-common
wget https://packages.microsoft.com/keys/microsoft.asc
sudo apt-key add microsoft.asc
sudo sh -c 'echo "deb [arch=amd64] https://packages.microsoft.com/ubuntu/20.04/prod focal main" > /etc/apt/sources.list.d/dotnetdev.list'

.NET SDK 설치
sudo apt update
sudo apt install -y dotnet-sdk-7.0

설치 확인
dotnet --version

2. C# 프로젝트 생성
dotnet new console -o MyConsoleApp
이 명령어는 MyConsoleApp이라는 새 폴더를 생성하고 그 안에 C# 콘솔 애플리케이션 프로젝트를 생성합니다.
dotnet new console -o mdiwebrowser


프로젝트 디렉토리로 이동

프로젝트 빌드 및 실행

프로젝트 빌드
dotnet build


1. Systehttp://m.Data.SQLite 라이브러리 추가
2. Newtonsoft.Json 라이브러리 추가
3. ServiceStack.Redis 라이브러리 추가

1. Systehttp://m.Data.SQLite 라이브러리 추가
dotnet add package Systehttp://m.Data.SQLite
2. Newtonsoft.Json 라이브러리 추가
dotnet add package Newtonsoft.Json
3. ServiceStack.Redis 라이브러리 추가
dotnet add package ServiceStack.Redis

프로젝트 실행
dotnet run

TCP 연결 종료 과정 (4-way handshake)

C:\Users\B210145_BK\Downloads\exture_3_5_ubuntu_ticker\send>netstat -an | findstr 21111
  TCP    0.0.0.0:21111          0.0.0.0:0              LISTENING
  TCP    127.0.0.1:52028        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52039        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52041        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52042        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52043        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52044        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52045        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52047        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52048        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52049        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52050        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52054        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52059        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52060        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52062        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52064        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52065        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52066        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52067        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52068        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52069        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52070        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52071        127.0.0.1:21111        TIME_WAIT
  TCP    127.0.0.1:52072        127.0.0.1:21111        TIME_WAIT

TIME_WAIT 상태가 발생하는 이유는 TCP 연결이 정상적으로 종료될 때 클라이언트 또는 서버가 잠시 동안 연결을 유지하는 과정에서 발생합니다. 이 상태는 연결이 완전히 종료되기 전에 남아있는 패킷들이 네트워크에서 잘못 전달되는 것을 방지하고, 이전에 사용된 소켓 번호가 재사용될 때 발생할 수 있는 문제를 방지하기 위해 설계되었습니다.

TCP 연결 종료 과정 (4-way handshake):

  1. FIN_WAIT-1: 클라이언트가 연결 종료를 요청하며 FIN 패킷을 전송합니다.
  2. CLOSE_WAIT: 서버가 FIN 패킷을 받고 ACK(확인 응답)를 보냅니다.
  3. FIN_WAIT-2: 서버가 연결 종료를 요청하며 FIN 패킷을 전송합니다.
  4. TIME_WAIT: 클라이언트가 서버로부터 FIN 패킷을 받고, ACK를 보낸 후 일정 시간 동안 기다립니다.


    TIME_WAIT 상태가 생기는 이유:
    1. 잔여 패킷 방지: 네트워크에서 늦게 도착한 패킷이 새로운 연결에 영향을 주지 않도록 하기 위해, TCP는 TIME_WAIT 상태를 유지하여 그 연결에 대한 패킷이 모두 소진되었음을 확인합니다.
    2. 포트 재사용 방지: 동일한 소켓 번호(포트)를 사용하는 새 연결이 바로 발생할 경우, 이전 연결의 잔여 패킷이 새 연결에 영향을 줄 수 있습니다. TIME_WAIT 상태는 이러한 상황을 방지하는 역할을 합니다.
    기본적으로 TIME_WAIT 상태는 일정 시간이 지나면 자동으로 종료되며, 이는 운영체제에 따라 다를 수 있습니다(일반적으로 2배의 Maximum Segment Lifetime, MSL). TIME_WAIT 상태가 너무 많으면 시스템의 소켓 리소스를 소모할 수 있지만, 이는 TCP 프로토콜의 정상적인 동작의 일환이므로 필요 이상으로 걱정할 필요는 없습니다.

Title) Multi HomeTrade & Redis Connect & Data Request - Response

HomeTrade(1) - LOGIN -> Private QueueName Send - (212700163791921682149)

HomeTrade(2) - LOGIN -> Private QueueName Send - (112700163791921682149)


DIAGRAM.BASIC LOGIN

 

 

Linux에서)

1. 리눅스 종류

sinfo@sinfo:~$ uname -a
Linux sinfo 5.4.0-192-generic #212-Ubuntu SMP Fri Jul 5 09:47:39 UTC 2024 x86_64 x86_64 x86_64 GNU/Linux

2. 네트워크 연결상태

sinfo@sinfo:~$ netstat -an | grep 21111
tcp        0      0 0.0.0.0:21111           0.0.0.0:*               LISTEN
tcp        0      0 192.168.45.48:21111     192.168.45.106:50236    ESTABLISHED
tcp        0      0 192.168.45.48:21111     192.168.45.106:50232    ESTABLISHED
sinfo@sinfo:~$ netstat -an | grep 6379
tcp        0      0 0.0.0.0:6379            0.0.0.0:*               LISTEN
tcp        0      0 192.168.45.48:6379      192.168.45.106:50237    ESTABLISHED
tcp        0      0 127.0.0.1:6379          127.0.0.1:44420         ESTABLISHED
tcp        0      0 127.0.0.1:6379          127.0.0.1:45878         ESTABLISHED
tcp        0      0 192.168.45.48:6379      192.168.45.106:50243    ESTABLISHED
tcp        0      0 192.168.45.48:6379      192.168.45.106:50233    ESTABLISHED
tcp        0      0 127.0.0.1:45878         127.0.0.1:6379          ESTABLISHED
tcp        0      0 127.0.0.1:44420         127.0.0.1:6379          ESTABLISHED
sinfo@sinfo:~$

3. 프로세스 확인

sinfo@sinfo:~$ ps -ef | grep redis
redis       1056       1  0 21:36 ?        00:00:13 /usr/bin/redis-server 0.0.0.0:6379
sinfo       5828    5350  0 23:02 pts/1    00:00:00 grep --color=auto redis
sinfo@sinfo:~$ ps aux | grep dotnet
sinfo       5538  1.2  2.6 274724316 215040 pts/0 Sl  22:53   0:07 /usr/share/dotnet/dotnet exec /usr/share/dotnet/sdk/7.0.410/Roslyn/bincore/VBCSCompiler.dll -pipename:MhsDIaqs8oyke8Na2IDl4QN9EwVUpE+Cpyfj50fyAN4
sinfo       5676  0.5  2.0 274830744 163780 pts/0 Sl+ 22:56   0:02 dotnet run
sinfo       5844  0.0  0.0   6432   720 pts/1    S+   23:03   0:00 grep --color=auto dotnet
sinfo@sinfo:~$ ps aux | grep mdi
sinfo       5706  0.3  1.3 274329620 112340 pts/0 Sl+ 22:56   0:01 /data/sinfo/exture_3_0_ticker/mdiwebrowser/bin/Debug/net7.0/mdiwebrowser
sinfo       5852  0.0  0.0   6300   656 pts/1    S+   23:03   0:00 grep --color=auto mdi
sinfo@sinfo:~$


4. 클라이언트는 Windows////////

 

GetInstance를 활용한 List<string> 예제,ㅡㅡㅡ,ㅡㅡㅡ
GetInstance를 활용한 List<string> 예제,ㅡㅡㅡ,ㅡㅡㅡ

public List<string> redisSenderQueueNM

using System;
using System.Collections.Generic;

public class APMMemory
{
    private static APMMemory apmMemory;
    private List<string> redissenderqueuenm = new List<string>();

    public List<string> redisSenderQueueNM
    {
        get { return redissenderqueuenm; }
        set { redissenderqueuenm = value; }
    }

    private APMMemory() { }

    public static APMMemory GetInstance
    {
        get
        {
            if (apmMemory == null)
                apmMemory = new APMMemory();
            return apmMemory;
        }
    }

    // 문자열을 추가할 때 중복을 체크하는 메서드
    public void AddQueueName(string queueName)
    {
        if (!redissenderqueuenm.Contains(queueName))
        {
            redissenderqueuenm.Add(queueName);
            Console.WriteLine($"Added: {queueName}");
        }
        else
        {
            Console.WriteLine($"Queue name '{queueName}' already exists and was not added.");
        }
    }
}

public class Program
{
    public static void Main(string[] args)
    {
        // Singleton instance 가져오기
        APMMemory apmMemory = APMMemory.GetInstance;

        // 중복되지 않게 문자열을 리스트에 추가
        apmMemory.AddQueueName("Queue1");
        apmMemory.AddQueueName("Queue2");
        apmMemory.AddQueueName("Queue3");

        // 중복되는 문자열 추가 시도
        apmMemory.AddQueueName("Queue2");  // 이미 존재하는 문자열
        apmMemory.AddQueueName("Queue4");

        // redisSenderQueueNM 리스트 출력
        Console.WriteLine("\nFinal Redis Sender Queue Names:");
        foreach (string queueName in apmMemory.redisSenderQueueNM)
        {
            Console.WriteLine(queueName);
        }
    }
}

+ Recent posts