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);
        }
    }
}

[A 경제용어사전] '베어마켓·불마켓(bear·bull market)'


황소(Bull)
황소 시장(Bull Market)은 주가가 전반적으로 상승하는 시장 상태를 나타내며, 이는 경제의 성장, 기업 실적 호조, 투자자들의 신뢰 증가 등으로 인해 발생합니다.
황소는 뿔을 위로 치켜들며 공격하는 습성 때문에 상승을 상징하게 되었습니다.
황소 시장에서는 투자자들이 적극적으로 주식을 매수하며, 이러한 매수세는 주가를 더욱 끌어올립니다.
역사적으로, '황소'는 19세기 초부터 금융가들 사이에서 사용되기 시작했습니다.
이 용어는 특히 뉴욕 증권거래소(NYSE)가 발달하면서 더욱 널리 퍼졌습니다.
황소 시장은 경제의 번영기와 맞물리며, 투자자들에게 높은 수익을 안겨주는 시기로 평가받습니다.

곰 (Bear)
곰은 증권시장에서 비관적인 분위기와 하락장을 상징합니다.
곰 시장(Bear Market)은 주가가 전반적으로 하락하는 시장 상태를 의미하며, 이는 경제 불황, 기업 실적 악화, 투자자들의 불안감 증가 등으로 인해 발생합니다.
곰은 발톱을 아래로 내리치는 습성 때문에 하락을 상징하게 되었습니다.
곰 시장에서는 투자자들이 주식을 매도하며, 이러한 매도세는 주가를 더욱 끌어내립니다.
'곰' 역시 19세기 초부터 금융가들 사이에서 사용되기 시작했습니다.
곰 시장은 경제의 불황기와 맞물리며, 투자자들에게 큰 손실을 안겨주는 시기로 평가받습니다.

 

(한국.거래소의 황소와 곰의 모습)

KRX 정보분배데이타,수신서버및 HomeTrade 제작

내용)

1. KRX 정보분배데이타 송신 SYSTEM 제작
2. KRX 정보분배데이타 수신 SYSTEM 제작
2.1 - KRX 정보분배데이타 수신
2.2 - KRX 정보분배데이타 저장(SQLite)
2.3 - KRX 정보분배데이타 REDIS전송
2.4 - 클라이언트 로그인 관리
2.5 - 클라이언트 조회요청시 데이타 전송
3. Like HomeTradeSystem - Win MDI Application
3.1 - 로그인
3.2 - 조회및 데이타 실시간수신
4. 디버깅 - Windows SendMessage 활용


기술)
1. KRX 정보분배데이타 송신 SYSTEM 제작 -> c
2. KRX 정보분배데이타 수신 SYSTEM 제작 -> c# Console
2.1 - KRX 정보분배데이타 수신
2.2 - KRX 정보분배데이타 저장(SQLite) - SQLite DataBase
2.3 - KRX 정보분배데이타 REDIS전송 - Redis Server
2.4 - 클라이언트 로그인 관리
2.5 - 클라이언트 조회요청시 데이타 전송
3. Like HomeTradeSystem - Win MDI Application - c# Win Form
3.1 - 로그인
3.2 - 조회및 데이타 실시간수신


MENU& TREE를 동시에 구성


일별.캔들차드 추가(feat. CHAT.GPT)

 

REDIS.QUEUE.NAME WHEN RCV/SND
REDIS.QUEUE.NAME WHEN RCV/SND

 


dotnet new wpf -n sampleNM

error CS0246: 'Newtonsoft' 형식또는 네임스페이스 이름을 찾을 수 없습니다. using 지시문 또는 어셈블리 참조가 있는지 확인하세요.
>dotnet add package Newtonsoft.Json

error CS0246: 'ServiceStack' 형식 또는 네임스페이스 이름을 찾을 수 없습니다. using 지시문 또는 어셈블리 참조가 있는지 확인하세요.
>dotnet add package ServiceStack

error CS0246: 'RedisClient' 형식 또는 네임스페이스 이름을 찾을 수 없습니다. using 지시문 또는 어셈블리 참조가 있는지 확인하세요.
>dotnet add package ServiceStack.Redis

KeyValuePair<TKey, TValue>는 C#에서 제공하는 구조체(struct)로, 키와 값을 쌍으로 묶어서 관리할 수 있게 해줍니다. 주로 컬렉션에서 특정 항목의 키와 값을 함께 다룰 때 사용됩니다.

주요 특징

  1. 제네릭 타입: KeyValuePair는 제네릭 타입으로, 키와 값의 데이터 타입을 지정할 수 있습니다. 예를 들어, KeyValuePair<int, string>는 정수형 키와 문자열 값을 가지는 쌍을 의미합니다.
  2. 구성: KeyValuePair는 두 개의 읽기 전용 속성, Key와 Value,으로 구성됩니다. Key는 쌍의 키를, Value는 쌍의 값을 나타냅니다.
  3. 불변성: KeyValuePair의 키와 값은 읽기 전용 속성으로 정의되어 있으며, 한 번 생성된 후에는 변경할 수 없습니다.

사용 예제

다음은 KeyValuePair를 사용하는 몇 가지 예제입니다.

1. 기본 사용

// KeyValuePair 생성 KeyValuePair<int, string> kvp = new KeyValuePair<int, string>(1, "Value"); // 키와 값에 접근 Console.WriteLine($"Key: {kvp.Key}, Value: {kvp.Value}");

2. Dictionary에서 사용

Dictionary 클래스는 내부적으로 KeyValuePair를 사용하여 키와 값을 저장합니다.

Dictionary<string, int> dictionary = new Dictionary<string, int>(); // 키와 값을 추가 dictionary.Add("Apple", 1); dictionary.Add("Banana", 2); // Dictionary의 모든 항목을 반복 foreach (KeyValuePair<string, int> kvp in dictionary) { Console.WriteLine($"Key: {kvp.Key}, Value: {kvp.Value}"); }

3. LINQ와 함께 사용

LINQ를 사용할 때 KeyValuePair를 반환하는 메서드를 사용할 수 있습니다.

var list = new List<KeyValuePair<string, int>>() { new KeyValuePair<string, int>("Apple", 1), new KeyValuePair<string, int>("Banana", 2), }; var result = list.Where(kvp => kvp.Value > 1); foreach (var kvp in result) { Console.WriteLine($"Key: {kvp.Key}, Value: {kvp.Value}"); }

이와 같이 KeyValuePair는 다양한 상황에서 유용하게 사용될 수 있으며, 특히 컬렉션과 관련된 작업에서 많이 활용됩니다.




1. 

포트 21111은 로컬 호스트(127.0.0.1)에서만 수신 대기 상태입니다. 
이는 이 포트가 현재 시스템 내의 로컬 네트워크 인터페이스에서만 접근 가능하다는 것을 의미합니다. 
외부 네트워크에서 이 포트에 접근할 수 없습니다.
root@sinfo:~# netstat -an | grep 21111
tcp        0      0 127.0.0.1:21111         0.0.0.0:*               LISTEN


2. 

포트 21111은 모든 네트워크 인터페이스(0.0.0.0)와 로컬 IPv6 주소(::1)에서 수신 대기 상태입니다. 
이는 포트 21111 가 외부 네트워크와 로컬 네트워크 모두에서 접근 가능하다는 것을 의미합니다. 
root@sinfo:~# netstat -an | grep 21111
tcp        1      0 0.0.0.0:21111           0.0.0.0:*               LISTEN
tcp6       0      0 :::21111                :::*                    LISTEN
root@sinfo:~#

1번과 2번의 소스차이는(?)

#if(false)
        private void Init()
        {
            //소켓 객체 생성 (TCP 소켓)
            listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            //엔드포인트에 소켓 바인드(Bind)
            IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 21111);
            listener.Bind(localEndPoint);

            //Listen소켓의 대기열의 길이를 설정합니다.
            listener.Listen(10);

            PublicApiNM.SendToDebug(3, "()(Init)(Listen)");

            while (true)
            {
                try
                {
                    Socket handler = listener.Accept();

                    PublicApiNM.SendToDebug(3, "()(Init)(Accept)");

                    //richTextBox1.Text = richTextBox1.Text + "Socket handler = listener.Accept() OK" + "\n";

                    Thread RealSocModel = new Thread(new ParameterizedThreadStart(SocketRunHandler));
                    RealSocModel.Start(handler);
                }
                catch (Exception ex)
                {
                    //
                }
            }
            listener.Close();
        }
#endif
#if(true)
private void Init()
{
    // IPv4와 IPv6 소켓 객체 생성 (TCP 소켓)
    ipv4Listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    ipv6Listener = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp);

    // IPv4와 IPv6 엔드포인트 설정
    IPEndPoint ipv4EndPoint = new IPEndPoint(IPAddress.Any, 21111); // 모든 IPv4 주소에서 수신 대기
    IPEndPoint ipv6EndPoint = new IPEndPoint(IPAddress.IPv6Any, 21111); // 모든 IPv6 주소에서 수신 대기

    // 소켓을 엔드포인트에 바인드
    ipv4Listener.Bind(ipv4EndPoint);
    ipv6Listener.Bind(ipv6EndPoint);

    // 소켓의 대기열 길이 설정
    ipv4Listener.Listen(10);
    ipv6Listener.Listen(10);

    PublicApiNM.SendToDebug(3, "()(Init)(Listen)");

    while (!_shouldStop)
    {
try
{
    // 소켓이 닫혔는지 확인하고, 닫혔으면 루프 종료
    if (ipv4Listener.Poll(1000, SelectMode.SelectRead) && ipv4Listener.Available == 0)
    {
break;
    }

    if (ipv6Listener.Poll(1000, SelectMode.SelectRead) && ipv6Listener.Available == 0)
    {
break;
    }

    // 클라이언트 연결 수신 대기
    Socket ipv4Handler = ipv4Listener.Accept();
    Socket ipv6Handler = ipv6Listener.Accept();

    PublicApiNM.SendToDebug(3, "()(Init)(Accept)");

    // 새 스레드에서 클라이언트 처리
    Thread ipv4Thread = new Thread(new ParameterizedThreadStart(SocketRunHandler));
    ipv4Thread.Start(ipv4Handler);

    Thread ipv6Thread = new Thread(new ParameterizedThreadStart(SocketRunHandler));
    ipv6Thread.Start(ipv6Handler);
}
catch (SocketException ex)
{
    if (_shouldStop)
    {
// _shouldStop이 true일 경우, listener가 닫히면서 예외 발생할 수 있음
break;
    }

    // 그 외의 소켓 예외 처리
    PublicApiNM.SendToDebug(3, "()(Init)(Exception):" + ex.Message);
}
catch (Exception ex)
{
    // 기타 예외 처리
    PublicApiNM.SendToDebug(3, "()(Init)(Exception):" + ex.Message);
}
    }

    // 소켓 닫기
    ipv4Listener.Close();
    ipv6Listener.Close();
    PublicApiNM.SendToDebug(3, "()(Init)(Stopped)");
}

public void StopInitThread()
{
    _shouldStop = true;

    // 소켓을 닫아 블로킹 호출에서 예외를 발생시키도록 함
    if (ipv4Listener != null)
    {
ipv4Listener.Close();
    }
    if (ipv6Listener != null)
    {
ipv6Listener.Close();
    }
}
#endif

windows->ubuntu migration(c#)

1. ubuntu.krx.recv.SQLite.redis.json Conver.redis send(by clientQueueKey)
- absolute path
- except using Forms

2. hometrade.redis.BlPOP.display.console


dotnet new console -o redisconsole
cd redisconsole
source coding..........................................................................................
dotnet build
dotnet run
dotnet add package Newtonsoft.Json
dotnet add package ServiceStack
dotnet add package ServiceStack.Redis

WPF에 Json데이타 표시(정보분배 - No Loop,Loop Case)

case1) 정보분배 - No Loop Case.
case2) 정보분배 - Loop Case.

<Window x:Class="sampleNM.MainWindow"
        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
        Title="REDIS Real Time BLPOP" Height="800" Width="1200"
        KeyDown="Window_KeyDown"
        WindowStartupLocation="Manual"
        Left="10"
        Top="10">
    <Grid>
        <!-- Define Rows for layout -->
        <Grid.RowDefinitions>
            <RowDefinition Height="0.1*" />  <!-- 10% of available space -->
            <RowDefinition Height="0.4*" />  <!-- 50% of available space -->
            <RowDefinition Height="0.2*" />  <!-- 40% of available space -->
            <RowDefinition Height="0.3*" />  <!-- 40% of available space -->
        </Grid.RowDefinitions>

        <!-- Container for Time data -->
        <ScrollViewer Grid.Row="0" VerticalScrollBarVisibility="Auto" HorizontalScrollBarVisibility="Disabled" Margin="10">
            <Border BorderBrush="Black" BorderThickness="1" Margin="5">
                <StackPanel Orientation="Vertical">
                    <TextBlock Text="[Time Information]" FontWeight="Bold" FontSize="12" Margin="0,0,0,0"/>
                    <StackPanel x:Name="TimeStackPanel" Orientation="Vertical">
                        <!-- Time data will be loaded here -->
                    </StackPanel>
                </StackPanel>
            </Border>
        </ScrollViewer>

        <!-- Container for JSON data -->
        <ScrollViewer Grid.Row="1" VerticalScrollBarVisibility="Auto" HorizontalScrollBarVisibility="Disabled" Margin="10">
            <Border BorderBrush="Black" BorderThickness="1" Margin="5">
                <StackPanel Orientation="Vertical">
                    <TextBlock Text="[REDIS JSON Information-NOT.LOOP.DATA]" FontWeight="Bold" FontSize="12" Margin="0,0,0,0"/>
                    <StackPanel x:Name="DataStackPanel" Orientation="Vertical">
                        <!-- JSON data will be loaded here -->
                    </StackPanel>
                </StackPanel>
            </Border>
        </ScrollViewer>

        <!-- Container for complex JSON data -->
        <ScrollViewer Grid.Row="2" VerticalScrollBarVisibility="Auto" HorizontalScrollBarVisibility="Disabled" Margin="10">
            <Border BorderBrush="Black" BorderThickness="1" Margin="5">
                <StackPanel Orientation="Vertical">
                    <TextBlock Text="[REDIS COMPLEX.JSON Information-SECURITIES.TRADE]" FontWeight="Bold" FontSize="12" Margin="0,0,0,0"/>
                    <DataGrid x:Name="DataGrid" AutoGenerateColumns="False" Margin="10">
                        <DataGrid.Columns>
                            <DataGridTextColumn Header="DataClass" Binding="{Binding DataClass}" />
                            <DataGridTextColumn Header="InfoMarketClass" Binding="{Binding InfoMarketClass}" />
                            <DataGridTextColumn Header="StockCode" Binding="{Binding StockCode}" />
                            <DataGridTextColumn Header="SerialNo" Binding="{Binding SerialNo}" />
                            <DataGridTextColumn Header="AskSecuritiesTradeNumber" Binding="{Binding AskSecuritiesTradeNumber}" />
                            <DataGridTextColumn Header="AskTradeVolume" Binding="{Binding AskTradeVolume}" />
                            <DataGridTextColumn Header="AskTradeAmount" Binding="{Binding AskTradeAmount}" />
                            <DataGridTextColumn Header="BidSecuritiesTradeNumber" Binding="{Binding BidSecuritiesTradeNumber}" />
                            <DataGridTextColumn Header="BidTradeVolume" Binding="{Binding BidTradeVolume}" />
                            <DataGridTextColumn Header="BidTradeAmount" Binding="{Binding BidTradeAmount}" />
                            <DataGridTextColumn Header="EndOfText" Binding="{Binding EndOfText}" />
                        </DataGrid.Columns>
                    </DataGrid>
                </StackPanel>
            </Border>
        </ScrollViewer>

        <!-- Container for complex JSON data -->
        <ScrollViewer Grid.Row="3" VerticalScrollBarVisibility="Auto" HorizontalScrollBarVisibility="Disabled" Margin="10">
            <Border BorderBrush="Black" BorderThickness="1" Margin="5">
                <StackPanel Orientation="Vertical">
                    <TextBlock Text="[REDIS COMPLEX.JSON Information-QUOTE.10]" FontWeight="Bold" FontSize="12" Margin="0,0,0,0"/>
                    <DataGrid x:Name="QuoteDataGrid" AutoGenerateColumns="False" Margin="10">
                        <DataGrid.Columns>
                            <DataGridTextColumn Header="DataClass" Binding="{Binding DataClass}" />
                            <DataGridTextColumn Header="InfoMarketClass" Binding="{Binding InfoMarketClass}" />
                            <DataGridTextColumn Header="DistributeStockIndex" Binding="{Binding DistributeStockIndex}" />
                            <DataGridTextColumn Header="BoardID" Binding="{Binding BoardID}" />
                            <DataGridTextColumn Header="SessionID" Binding="{Binding SessionID}" />
                            <DataGridTextColumn Header="StockCode" Binding="{Binding StockCode}" />
                            <DataGridTextColumn Header="StockSeq" Binding="{Binding StockSeq}" />
                            <DataGridTextColumn Header="TradingProcessingTime" Binding="{Binding TradingProcessingTime}" />
                            <DataGridTextColumn Header="AskQuote" Binding="{Binding AskQuote}" />
                            <DataGridTextColumn Header="BidQuote" Binding="{Binding BidQuote}" />
                            <DataGridTextColumn Header="AskQuoteVolume" Binding="{Binding AskQuoteVolume}" />
                            <DataGridTextColumn Header="BidQuoteVolume" Binding="{Binding BidQuoteVolume}" />
                            <DataGridTextColumn Header="TotalAskQuoteRemainder" Binding="{Binding TotalAskQuoteRemainder}" />
                            <DataGridTextColumn Header="TotalBidQuoteRemainder" Binding="{Binding TotalBidQuoteRemainder}" />
                            <DataGridTextColumn Header="EstimatedTradePrice" Binding="{Binding EstimatedTradePrice}" />
                            <DataGridTextColumn Header="EstimatedTradeVolume" Binding="{Binding EstimatedTradeVolume}" />
                            <DataGridTextColumn Header="EndText" Binding="{Binding EndText}" />
                        </DataGrid.Columns>
                    </DataGrid>
                </StackPanel>
            </Border>
        </ScrollViewer>
    </Grid>
</Window>

Linux sinfo 5.4.0-165-generic #182-Ubuntu 에서 정보분배/REDIS/SQLite/실행하기/BUILD/RUN/
Linux sinfo 5.4.0-165-generic #182-Ubuntu 에서 정보분배/REDIS/SQLite/실행하기/ BUILD/RUN/

root@sinfo:~# uname -a
Linux sinfo 5.4.0-165-generic #182-Ubuntu SMP Mon Oct 2 19:43:28 UTC 2023 x86_64 x86_64 x86_64 GNU/Linux
root@sinfo:~#

 

콘솔프로그램을 작성시에 쓰레드를 발생시키고 종료를 막기위해서 반복문을 사용하는것 외에는
방법이 없는것 같았지만, 아래와 같은 방법을 쓰면 될듯함/

 

using System;
using System.Threading;

class Program
{
    // ManualResetEvent 객체 생성
    private static ManualResetEvent manualResetEvent = new ManualResetEvent(false);

    static void Main()
    {
        Console.WriteLine("Main 스레드 시작");

        // 새로운 스레드 시작
        Thread thread = new Thread(WorkerThread);
        thread.Start();

        // ManualResetEvent를 통해 메인 스레드를 대기시킴
        manualResetEvent.WaitOne();

        Console.WriteLine("Main 스레드 종료");
    }

    static void WorkerThread()
    {
        Console.WriteLine("Worker 스레드 시작");

        // 일부 작업을 수행
        Thread.Sleep(3000); // 예: 3초 동안 작업을 수행한다고 가정

        Console.WriteLine("Worker 스레드 종료");

        // 작업이 완료되면 ManualResetEvent를 설정하여 Main 스레드를 깨움
        manualResetEvent.Set();
    }
}

정보분배수신/SQLite저장/REDIS전송/REDIS BLPOP/WPF/

1. KRX정보분배 TCP 데이타 수신
2. SQLite DataBase 저장
3. JSON포맷으로 변환
4. REDIS전송
5. REDIS BLPOP Designed by WPF(기존 Prompt) - 해당부분 아래 이미지로 제공

5.1 <string,stgring> JSON 타입
5.2 <string,List>  JSON 타입으로 나누어서 표시해야 합니다.

1. KRX

2. MDIRedisTicker Server
2.1 - Tcp Recv & Parse
2.2 - SQLite Database
2.3 - Push TO Redis Server

3. HomeTradeCli.exe
3.1 - Pop From Redis Server


KRX)
[2024-08-01 19:18:53.316][00099][00079][IA000K2S09PKRD020020354090034000970.33+000000.55000000000202000000035314    ]
HTS)
[Title+Time]:ExturePlusTotalKseIndex[2024-08-01 19:18:53.326]
[Redis++Key];1127001637919216845106
[POP---Data];{"data_tp_val":"IA","info_tp_val":"000","if_idx_id":"K2S09P","std_cd":"KRD020020354","idx_calc_tm":"090034","if_calc_idx":"000970.33","cmpprevdd_idx_sgn":"+","cmpprevdd_calc_idx":"000000.55","idx_acc_trdvol":"000000000202","idx_acc_trdval":"000000035314","filr_val4":"    ","ms_msg_end_keywrd":"NULL"}

KRX -> HTS까지 걸린시간은( [2024-08-01 19:18:53.316] - [2024-08-01 19:18:53.326] ) 의 시간 차이를 보이고 있다.

제목) 정보분배/SQLite/Cache/Redis/WebHttp/Manual Program

1. 정보분배 TCP데이타 제공처(KRX)
증권정보데이타(Securities Information Data)는 주식, 채권, 파생상품 등 다양한 금융 상품에 대한 정보를 제공하는 데이터입니다. 
이 데이터는 투자자, 금융 기관, 애널리스트 및 연구원들이 시장 동향을 파악하고 투자 결정을 내리는 데 중요한 역할을 합니다.
주식 데이터:
가격 정보: 시가, 종가, 고가, 저가, 거래량, 거래대금 등.
주식 지표: PER(주가수익비율), PBR(주가순자산비율), EPS(주당순이익) 등.
파생상품 데이터:
선물/옵션 정보: 기초 자산, 만기일, 행사가격, 거래량 등.
파생상품 지표: 변동성, 델타, 감마, 세타 등 그릭스(Greeks) 값.
거래소 정보:
지수 정보: 종합주가지수, 섹터별 지수, 글로벌 지수 등.
시장 통계: 거래소 전체의 거래량, 거래대금, 상장 종목 수 등.
데이터 제공 방법
실시간 데이터: 거래소와 데이터 제공업체가 실시간으로 업데이트되는 데이터를 제공합니다.
주요 제공 업체
한국거래소: 국내 주식, 채권, 파생상품의 거래 데이터를 제공합니다.
증권정보데이타는 금융 시장 참여자들이 시장을 이해하고 효과적으로 대응할 수 있도록 돕는 중요한 도구입니다. 

프로그램 테스트를 위한 과거데이타 전송)

2. Manual Program(직접만든프로그램) - mdimmmcache.exe

2.1 정보분배 TCP데이타 수신(21111 포트)
2.2 정보분배 TCP데이타를 SQLite DB에 저장(파일저장)
2.3 정보분배 TCP데이타를 Web Browser의 Request에 Response 응답(JSON데이타 포맷) - 8080포트
2.4 정보분배 TCP데이타를 Manual Program - sendrcvredis.exe 의 Request에 Response 응답(JSON데이타 포맷)
- 6379포트

비고) SendMessage를 이용한 Debugging(Windows에서 SendMessage를 이용해서 로그를 보는것이 편하다.)


비고) Web Browser에서 Request시에, JSON포맷으로 Response 받는예.


3. SQLite DataBase
SQLite는 가벼운 디스크 기반 데이터베이스 관리 시스템(DBMS)입니다. 
여기서 "가벼운"은 소프트웨어의 크기와 자원 소비가 적다는 것을 의미합니다. 
SQLite는 서버 기반 DBMS와 달리 클라이언트-서버 구조가 아닌 내장형 데이터베이스로, 어플리케이션에 직접 통합됩니다.

주요 특징
독립형:

SQLite는 단일 파일로 모든 데이터베이스를 저장합니다. 이는 배포와 백업을 간단하게 만듭니다.
제로 설정:
설치나 초기 설정이 필요 없습니다. SQLite 라이브러리 파일을 어플리케이션에 포함시키면 바로 사용할 수 있습니다.
서버리스:
별도의 서버 프로세스가 필요 없습니다. 어플리케이션이 직접 SQLite 데이터베이스 파일을 읽고 쓸 수 있습니다.
크로스 플랫폼:
다양한 운영체제에서 동작하며, 동일한 데이터베이스 파일이 여러 플랫폼에서 호환됩니다.
높은 신뢰성:
SQLite는 트랜잭션을 지원하며, ACID(Atomicity, Consistency, Isolation, Durability) 속성을 보장합니다.
표준 SQL 지원:
대부분의 SQL-92 표준을 지원합니다. 하지만 몇 가지 고급 기능은 지원하지 않을 수 있습니다.
사용 사례
임베디드 시스템:
모바일 장치, IoT 기기, 가전제품 등에서 많이 사용됩니다.
테스트 및 프로토타이핑:
서버 기반 DBMS의 복잡성을 피하기 위해 초기 개발 단계에서 사용됩니다.
데스크탑 응용 프로그램:
여러 데스크탑 애플리케이션에서 데이터 저장을 위해 사용됩니다.
웹 브라우저:
브라우저 내부에서 사용자의 데이터를 저장하기 위해 사용됩니다. 예: Google Chrome, Firefox의 내부 데이터 저장.
장단점
장점:
매우 가볍고 빠릅니다.
설정이 간단하고 사용이 편리합니다.
소스 코드가 공개되어 있어 수정 및 커스터마이징이 가능합니다.
파일 기반이므로 이동성과 백업이 용이합니다.
단점:
동시성이 필요한 대규모 애플리케이션에서는 성능이 떨어질 수 있습니다.
고급 기능(예: 저장 프로시저, 사용자 정의 함수 등)이 부족할 수 있습니다.
대용량 데이터를 처리하는 데는 적합하지 않을 수 있습니다.



4. REDIS
Redis는 오픈 소스 인메모리 데이터 구조 저장소로, 주로 고성능의 실시간 애플리케이션을 위해 사용됩니다. 
Redis는 "Remote Dictionary Server"의 약자로, 다양한 데이터 구조를 지원하며, 높은 속도와 확장성을 제공하는 것이 특징입니다.

주요 특징
인메모리 데이터베이스:
Redis는 데이터를 메모리에 저장하므로 매우 빠른 읽기 및 쓰기 속도를 제공합니다. 디스크에도 비동기적으로 데이터를 저장할 수 있어 내구성을 보장합니다.
다양한 데이터 구조 지원:
문자열, 리스트, 셋(set), 해시(hash), 정렬된 셋(sorted set), 비트맵(bitmap), 하이퍼로그로그(hyperloglog), 지오스페이셜 인덱스(geospatial index) 등의 다양한 데이터 구조를 지원합니다.
퍼시스턴스:
데이터를 디스크에 저장하여 메모리에서 데이터가 손실되는 것을 방지할 수 있습니다. RDB(Snapshotting)와 AOF(Append Only File) 두 가지 방식으로 퍼시스턴스를 제공합니다.
사용 사례
캐싱:빠른 데이터 액세스를 위해 자주 사용되는 데이터를 캐시합니다.
세션 저장소:웹 애플리케이션의 사용자 세션 데이터를 저장합니다.
실시간 분석:실시간 로그 처리 및 데이터 분석에 사용됩니다.
메시지 큐:Pub/Sub 메시징 시스템을 통해 메시지 큐로 사용할 수 있습니다.
장점:
매우 빠른 속도와 낮은 지연 시간.
다양한 데이터 구조 지원.
높은 가용성과 확장성.
단순하고 직관적인 API.
단점:
메모리에 데이터를 저장하므로 메모리 용량에 제한이 있음.



6. Manual Program(직접만든프로그램) - sendrcvredis.exe

REDIS PUSH/POP을 테스트할수 있는 프로그램

윈도우에서 특정 프로그램의 네트워크 상태를 확인하기 위해 사용할 수 있는 몇 가지 명령어가 있습니다. 
대표적으로 netstat 명령어가 많이 사용되며, tasklist와 findstr을 조합하여 특정 프로그램에 대한 정보를 확인할 수 있습니다.

netstat:

네트워크 연결 상태를 확인할 수 있는 기본 명령어입니다.
특정 프로그램의 네트워크 연결을 확인하려면 -b 옵션을 사용하여 실행 중인 각 연결의 실행 파일을 표시할 수 있습니다. 이 명령은 관리자 권한으로 실행해야 합니다.
netstat -anob

tasklist:

현재 실행 중인 프로세스 목록을 확인할 수 있습니다.
특정 프로그램의 PID(Process ID)를 찾을 때 유용합니다.

tasklist | findstr [프로그램 이름]

netstat과 findstr 조합:

특정 프로그램의 네트워크 연결 상태를 PID를 통해 필터링할 수 있습니다.
먼저 프로그램의 PID를 찾습니다:

tasklist | findstr [프로그램 이름]

그런 다음 해당 PID로 네트워크 상태를 필터링합니다:

netstat -ano | findstr [PID]
예를 들어, 특정 프로그램(예: redis-server.exe)의 네트워크 상태를 확인하려면 다음과 같은 단계를 따릅니다:

redis-server.exe의 PID를 찾습니다:

tasklist | findstr redis-server.exe
찾은 PID를 사용하여 네트워크 상태를 확인합니다(예를 들어, PID가 1234라면):

netstat -ano | findstr 1234
이 명령어들을 통해 특정 프로그램의 네트워크 연결 상태를 쉽게 확인할 수 있습니다.

ex)
예로써 개발되어진 프로그램은 다음의 네트웍 통신을 할수 있다.
mdiwebrowser.exe
1. 21111 포트로 정보분배 데이타를 수신한다.
2. 6379 포트로 REDIS서버에 송수신을 한다.
3. 8080 포트로 HTTP Request & Response를 한다.

B210145_BK@DESKTOP-QNNUCER MINGW64 ~
$ tasklist | findstr mdiweb
mdiwebrowser.exe             42720 Console                    3     52,844 K

B210145_BK@DESKTOP-QNNUCER MINGW64 ~
$ netstat -ano | findstr 42720
  TCP    127.0.0.1:21111        0.0.0.0:0              LISTENING       42720
  TCP    127.0.0.1:64279        127.0.0.1:6379         ESTABLISHED     42720
  TCP    127.0.0.1:64285        127.0.0.1:6379         ESTABLISHED     42720

B210145_BK@DESKTOP-QNNUCER MINGW64 ~
$


8080포트가 나오지 않는 이유는?

command)
>msbuild mdiwebrowser.sln /p:Configuration=Release

 

만약 Visual Studio를 사용하지 않고 명령줄에서 빌드하려면, MSBuild를 사용할 수 있습니다. MSBuild는 Visual Studio와 함께 설치되며, 명령줄에서 프로젝트를 빌드할 수 있는 도구입니다.

MSBuild 명령 실행:

  • 다음 명령어를 입력하여 솔루션을 빌드합니다: 
  • msbuild mdiwebrowser.sln
  • 기본적으로 MSBuild는 Release 또는 Debug 모드로 빌드할 수 있으며, 모드를 지정하려면 다음과 같이 명령어를 수정합니다:
    msbuild mdiwebrowser.sln /p:Configuration=Release
    또는
    msbuild mdiwebrowser.sln /p:Configuration=Debug

이 방법으로 프로젝트를 빌드하면, 결과물은 솔루션의 설정에 따라 bin\Release 또는 bin\Debug 폴더에 생성됩니다.

REIDS서버
REDIS클라이언트 - 접속상태

 

  TCP    0.0.0.0:6379           0.0.0.0:0              LISTENING
  TCP    127.0.0.1:6379         127.0.0.1:64279        ESTABLISHED
  TCP    127.0.0.1:6379         127.0.0.1:64285        ESTABLISHED
  TCP    127.0.0.1:64279        127.0.0.1:6379         ESTABLISHED
  TCP    127.0.0.1:64285        127.0.0.1:6379         ESTABLISHED
  TCP    [::]:6379              [::]:0                 LISTENING

 

> netstat -an | grep 6379 명령의 출력 결과를 해석하면 다음과 같습니다:

이 TCP 연결 정보를 해석하면 다음과 같습니다:

  1. 0.0.0.0:6379가 0.0.0.0:0에 대해 LISTENING 상태에 있음:
    • 이 행은 서버가 모든 네트워크 인터페이스에서 6379 포트를 듣고 있음을 나타냅니다.
    • 0.0.0.0는 모든 IPv4 주소를 의미합니다.
  2. 127.0.0.1:6379가 127.0.0.1:64279에 대해 ESTABLISHED 상태에 있음:
    • 이 행은 로컬 호스트(127.0.0.1)에서 6379 포트와 로컬 호스트에서 64279 포트 사이에 확립된 연결이 있음을 나타냅니다.
    • 즉, 이 연결은 같은 컴퓨터 내에서 이루어졌습니다.
  3. 127.0.0.1:6379가 127.0.0.1:64285에 대해 ESTABLISHED 상태에 있음:
    • 이 행도 유사하게 로컬 호스트에서 6379 포트와 로컬 호스트에서 64285 포트 사이에 확립된 연결이 있음을 나타냅니다.
  4. 127.0.0.1:64279가 127.0.0.1:6379에 대해 ESTABLISHED 상태에 있음:
    • 이 행은 위의 두 번째 행과 쌍을 이룹니다. 64279 포트에서 6379 포트로의 연결이 확립됨을 나타냅니다.
  5. 127.0.0.1:64285가 127.0.0.1:6379에 대해 ESTABLISHED 상태에 있음:
    • 이 행은 위의 세 번째 행과 쌍을 이룹니다. 64285 포트에서 6379 포트로의 연결이 확립됨을 나타냅니다.
  6. [::]:6379가 [::]:0에 대해 LISTENING 상태에 있음:
    • 이 행은 서버가 모든 IPv6 인터페이스에서 6379 포트를 듣고 있음을 나타냅니다.
    • [::]는 모든 IPv6 주소를 의미합니다.

요약하면, 이 정보는 서버가 6379 포트를 통해 여러 연결을 처리하고 있으며, 이 포트는 IPv4 및 IPv6 주소 모두에서 LISTENING 상태에 있습니다. 로컬 호스트에서 몇몇 확립된 연결(ESTABLISHED)이 존재합니다. 6379 포트는 일반적으로 Redis 서버가 사용하는 포트입니다.

SetVisibleCore 메서드는 Windows Forms에서 컨트롤의 가시성을 설정할 때 사용되는 메서드입니다. 이를 재정의(override)하면 컨트롤이 표시되거나 숨겨질 때 실행되는 기본 동작을 사용자 정의할 수 있습니다.

기본 정의

SetVisibleCore는 System.Windows.Forms.Control 클래스에 다음과 같이 정의되어 있습니다:

protected override void SetVisibleCore(bool value)

여기서 value는 컨트롤을 보이게 할지(true) 숨기게 할지(false)를 나타내는 부울 값입니다.

기본 동작

기본적으로 SetVisibleCore 메서드는 Visible 속성을 설정하고, 컨트롤의 기본 가시성 변경 작업을 처리합니다. 예를 들어, 컨트롤이 처음 생성될 때 보이도록 설정하거나, 가시성을 변경할 때 적절한 이벤트를 발생시키는 등의 작업이 포함됩니다.

사용자 정의

파생 클래스에서 SetVisibleCore를 재정의하여 특정 조건에 따라 컨트롤의 가시성을 제어할 수 있습니다. 다음은 SetVisibleCore를 재정의하여 특정 조건에 따라 컨트롤을 보이게 또는 숨기게 하는 예제입니다:

public class MyCustomControl : Form
{
     bool allowshowdisplay = false;
#if(true)
    protected override void SetVisibleCore(bool value)
    {
        base.SetVisibleCore(allowshowdisplay ? value : allowshowdisplay);
    }
#endif
#if(false)
    protected override void SetVisibleCore(bool value)
    {
        // 특정 조건을 만족할 때만 컨트롤을 표시
        if (ShouldControlBeVisible())
        {
Console.WriteLine("Show");
            base.SetVisibleCore(value);
        }
        else
        {
Console.WriteLine("Hide");
            base.SetVisibleCore(false);
        }
    }
#endif
    private bool ShouldControlBeVisible()
    {
        // 사용자 정의 조건 로직
        //return DateTime.Now.Second % 2 == 0; // 예: 현재 초가 짝수일 때만 보이도록
        return false;
    }
}
public class Program
{
    public static void Main()
    {
        Application.Run(new MyCustomControl());
    }
}

$ find ./ -name "*.cs" | xargs grep "Data Source"

grep 명령어 실행 시 "No such file or directory" 메시지를 피하려면, 다음과 같은 방법을 사용할 수 있습니다.
grep 명령어 실행 시 "No such file or directory" 메시지를 피하려면, 다음과 같은 방법을 사용할 수 있습니다.

B210145_BK@DESKTOP-QNNUCER MINGW64 ~/Downloads/EXTURE_3_0_APM_BASIC
$ find ./ -name "*.cs" | xargs grep "Data Source"
./APM/APM/APMMain.cs:            APMSQLite.GetInstance.Conn = new SQLiteConnection("Data Source=:memory:;Version=3;");
./APM/APM/APMMainForm.cs:            APMSQLite.GetInstance.Conn = new SQLiteConnection("Data Source=:memory:;Version=3;");
grep: ./APM/Screen/Live-Charts-master/Examples/UWP/CartesianChart/Basic: No such file or directory
grep: Bars/BasicColumn.xaml.cs: No such file or directory
grep: ./APM/Screen/Live-Charts-master/Examples/UWP/CartesianChart/Basic: No such file or directory
grep: Bars/BasicRowExample.xaml.cs: No such file or directory
grep: ./APM/Screen/Live-Charts-master/Examples/UWP/CartesianChart/Basic: No such file or directory
grep: Stacked: No such file or directory
grep: Bar/BasicStackedColumnExample.xaml.cs: No such file or directory
grep: ./APM/Screen/Live-Charts-master/Examples/UWP/CartesianChart/Basic: No such file or directory
grep: Stacked: No such file or directory
grep: Bar/BasicStackedRowPercentageExample.xaml.cs: No such file or directory
grep: ./APM/Screen/Live-Charts-master/Examples/UWP/CartesianChart/Chart: No such file or directory
grep: to: No such file or directory
grep: Image/ChartToImageSample.xaml.cs: No such file or directory
grep: ./APM/Screen/Live-Charts-master/Examples/UWP/CartesianChart/Customized: No such file or directory
grep: Series/CustomizedLineSeries.xaml.cs: No such file or directory

1. 오류 메시지 무시하기: grep 명령어의 표준 오류를 /dev/null로 리디렉션하여 오류 메시지를 무시할 수 있습니다.

find ./ -name "*.cs" | xargs grep "Data Source" 2>/dev/null

2. 존재하는 파일만 찾기: find 명령어로 실제 존재하는 파일만 대상으로 하여 grep을 실행하도록 합니다. -exec 옵션을 사용하면 find 명령어가 각각의 파일에 대해 grep을 실행하게 할 수 있습니다.

find ./ -name "*.cs" -exec grep "Data Source" {} +

 

+ Recent posts