석수코딩교육

mysql> select * from RB_OCUS_POS_TEST2 limit 10;
+-------+------------+----------------------+--------------+---------------+---------------+------------+------------+------------------------+
| seqno | account_no | stock_symbol         | start_volume | start_amount | start_price   | stock_type | trustee_id | regtime                |
+-------+------------+----------------------+--------------+---------------+---------------+------------+------------+------------------------+
|     1 | 0016100    | BANPU                | 0000045000   | 0000645569.57 | 000014.345990 | 02         |            | 20190829 15:31:55(410) |
|     2 | 0016100    | BBL                  | 0000001500   | 0000266962.22 | 000177.974813 | 02         |            | 20190829 15:31:55(410) |
|     3 | 0016100    | BPP                  | 0000002000   | 0000042000.00 | 000021.000000 | 02         |            | 20190829 15:31:55(410) |
|     4 | 0016100    | CK                   | 0000015375   | 0000296816.51 | 000019.305139 | 02         |            | 20190829 15:31:55(410) |
|     5 | 0016100    | IEC                  | 0012286603   | 0000308909.54 | 000000.025142 | 02         |            | 20190829 15:31:55(410) |
|     6 | 0016100    | IVL                  | 0000011769   | 0000309729.03 | 000026.317362 | 02         |            | 20190829 15:31:55(410) |
|     7 | 0016100    | KTB                  | 0000005000   | 0000103785.51 | 000020.757102 | 02         |            | 20190829 15:31:55(410) |
|     8 | 0055920    | ASAP                 | 0000001000   | 0000003106.87 | 000003.106870 | 02         |            | 20190829 15:31:55(411) |
|     9 | 0055920    | BCP                  | 0000001000   | 0000033574.22 | 000033.574220 | 02         |            | 20190829 15:31:55(411) |
|    10 | 0055920    | CBG                  | 0000000800   | 0000042844.70 | 000053.555875 | 02         |            | 20190829 15:31:55(411) |
+-------+------------+----------------------+--------------+---------------+---------------+------------+------------+------------------------+
10 rows in set (0.00 sec)

mysql>

mysql>

mysql> select @r:=@r+1 As rowNum, T2.* from DUMMY T1, (select substr(regtime,1,17) as t_regtime, count(1) as t_cnt from RB_OCUS_POS_TEST2 group by substr(regtime,1,17)) T2, (Select @r:=0) r limit 100;
+--------+-------------------+-------+
| rowNum | t_regtime         | t_cnt |
+--------+-------------------+-------+
|      1 | 20190829 15:31:55 | 2640 |
|      2 | 20190829 15:31:56 | 4744 |
|      3 | 20190829 15:31:57 | 5036 |
|      4 | 20190829 15:31:58 | 5270 |
|      5 | 20190829 15:31:59 | 2587 |
|      6 | 20190829 15:32:00 | 2909 |
|      7 | 20190829 15:32:01 | 3261 |
|      8 | 20190829 15:32:02 | 5019 |
|      9 | 20190829 15:32:03 | 5488 |
|     10 | 20190829 15:32:04 | 5853 |
|     11 | 20190829 15:32:05 | 4381 |
|     12 | 20190829 15:32:06 | 4307 |
|     13 | 20190829 15:32:07 | 2871 |
|     14 | 20190829 15:32:08 |   345 |
|     15 | 20190829 15:32:09 | 3368 |
|     16 | 20190829 15:32:10 | 3087 |

mysql> select @r:=@r+1 As rowNum, T2.* from DUMMY T1, (select substr(regtime,1,17) as t_regtime, count(1) as t_cnt from RB_OCUS_POS_TEST2 group by substr(regtime,1,17)) T2, (Select @r:=0) r limit 100;
+--------+-------------------+-------+
| rowNum | t_regtime         | t_cnt |
+--------+-------------------+-------+
|      1 | 20190829 15:31:55 | 2640 |
|      2 | 20190829 15:31:56 | 4744 |
|      3 | 20190829 15:31:57 | 5036 |
|      4 | 20190829 15:31:58 | 5270 |
|      5 | 20190829 15:31:59 | 2587 |
|      6 | 20190829 15:32:00 | 2909 |
|      7 | 20190829 15:32:01 | 3261 |
|      8 | 20190829 15:32:02 | 5019 |
|      9 | 20190829 15:32:03 | 5488 |
|     10 | 20190829 15:32:04 | 5853 |
|     11 | 20190829 15:32:05 | 4381 |
|     12 | 20190829 15:32:06 | 4307 |

>>아래 쿼리의 내용은 큐를 이용해서 데이타를 입력했을때에 순서적으로 입력이 안되는 상태임을 보여주는 예입니다.

>>큐가 10개라면, SERIAL하게 데이타가 입력되는것에 대한 정합성을 보장하지 않습니다.

>>저장하는 용도의 입력이면 괜찮지만, 순서적으로 입력이 보장되어야 한다면, 다른 로직을 넣어서 이를 해결해야 합니다.

mysql> select T2.rowNum, T2.t_seqno, T2.rowNum - T2.t_seqno from DUMMY T1, (select @r:=@r+1 As rowNum, T1.seqno as t_seqno from RB_OCUS_POS_TEST2 T1, (Select @r:=0) r order by regtime asc) T2 order by T2.t_seqno asc limit 100;
+--------+---------+------------------------+
| rowNum | t_seqno | T2.rowNum - T2.t_seqno |
+--------+---------+------------------------+
|      1 |       1 |                      0 |
|      2 |       2 |                      0 |
|      3 |       3 |                      0 |
|      4 |       4 |                      0 |
|      5 |       5 |                      0 |
|      6 |       6 |                      0 |
|      7 |       7 |                      0 |
|      8 |       8 |                      0 |
|      9 |       9 |                      0 |
|     10 |      10 |                      0 |
|     12 |      11 |                      1 |
|     11 |      12 |                     -1 |
|     13 |      13 |                      0 |

mysql> select T2.rowNum, T2.t_seqno, T2.rowNum - T2.t_seqno from DUMMY T1, (select @r:=@r+1 As rowNum, T1.seqno as t_seqno from RB_OCUS_POS_TEST2 T1, (Select @r:=0) r order by regtime asc) T2 where T2.rowNum - T2.t_seqno <> 0 order by T2.t_seqno asc limit 100;
+--------+---------+------------------------+
| rowNum | t_seqno | T2.rowNum - T2.t_seqno |
+--------+---------+------------------------+
|     12 |      11 |                      1 |
|     11 |      12 |                     -1 |
|     32 |      31 |                      1 |
|     33 |      32 |                      1 |
|     40 |      33 |                      7 |
|     31 |      34 |                     -3 |
|     34 |      35 |                     -1 |
|     35 |      36 |                     -1 |
|     36 |      37 |                     -1 |
|     37 |      38 |                     -1 |
|     38 |      39 |                     -1 |
|     39 |      40 |                     -1 |
|     47 |      43 |                      4 |
|     43 |      44 |                     -1 |
|     44 |      45 |                     -1 |
|     45 |      46 |                     -1 |
|     46 |      47 |                     -1 |
|     60 |      53 |                      7 |

'데이타베이스 > MySQL' 카테고리의 다른 글

#LINUX,send_msg_to_queue.c (2번째) (0)	2019.10.30
#LINUX,recv_msg_from_queue.c (두번째) (0)	2019.10.30
1달전 자료 지우는 쿼리 (0)	2019.10.29
MySQL LOCK 확인 및 해제(kill) 방법 (0)	2019.10.29
#innodb_flush_log_at_trx_commit 에 따른 입력건수 성능비교 (0)	2019.10.29

find ./ -type f -mtime -일수 -print

find ./ -type f -mtime -일수 -ls

find ./ -type f -mtime -일수 -print

find ./ -type f -mtime -일수 -ls

find ./ -type f -mtime -일수 -print

find ./ -type f -mtime -일수 -ls | grep "\.c"

'리눅스' 카테고리의 다른 글

BIOS 부트 모드(Boot Mode)에 따른 CentOS설치시 추가 파티션 설정(/boot/efi) (0)	2021.03.31
CentOS 6. 설치가이드(파티션설정) (0)	2021.03.30
Linux - du (Disk Usage) (0)	2019.10.31
LINUX,REDIS 활용 (0)	2019.10.30
리눅스 파티션 수동설치(CentOS 6.6) (0)	2019.10.29

1. GOAL

- 1.REST의 개념을 이해한다.

- 2.REST의 특징을 이해한다.

- 3.REST API의 개념을 이해한다.

- 4.REST API의 설계 규칙을 이해한다.

- 5.RESTful의 개념을 이해한다.

2. REST란

REST의 정의

“Representational State Transfer” 의 약자

자원을 이름(자원의 표현)으로 구분하여 해당 자원의 상태(정보)를 주고 받는 모든 것을 의미한다.

즉, 자원(resource)의 표현(representation) 에 의한 상태 전달

자원(resource)의 표현(representation)

자원: 해당 소프트웨어가 관리하는 모든 것

-> Ex) 문서, 그림, 데이터, 해당 소프트웨어 자체 등

자원의 표현: 그 자원을 표현하기 위한 이름

-> Ex) DB의 학생 정보가 자원일 때, ‘students’를 자원의 표현으로 정한다.

상태(정보) 전달

데이터가 요청되어지는 시점에서 자원의 상태(정보)를 전달한다.

JSON 혹은 XML를 통해 데이터를 주고 받는 것이 일반적이다.

월드 와이드 웹(www)과 같은 분산 하이퍼미디어 시스템을 위한 소프트웨어 개발 아키텍처의 한 형식

REST는 기본적으로 웹의 기존 기술과 HTTP 프로토콜을 그대로 활용하기 때문에 웹의 장점을 최대한 활용할 수 있는 아키텍처 스타일이다.

REST는 네트워크 상에서 Client와 Server 사이의 통신 방식 중 하나이다.

REST의 구체적인 개념

HTTP URI(Uniform Resource Identifier)를 통해 자원(Resource)을 명시하고, HTTP Method(POST, GET, PUT, DELETE)를 통해 해당 자원에 대한 CRUD Operation을 적용하는 것을 의미한다.

즉, REST는 자원 기반의 구조(ROA, Resource Oriented Architecture) 설계의 중심에 Resource가 있고 HTTP Method를 통해 Resource를 처리하도록 설계된 아키텍쳐를 의미한다.

웹 사이트의 이미지, 텍스트, DB 내용 등의 모든 자원에 고유한 ID인 HTTP URI를 부여한다.

CRUD Operation

Create : 생성(POST)

Read : 조회(GET)

Update : 수정(PUT)

Delete : 삭제(DELETE)

HEAD: header 정보 조회(HEAD)

3. REST의 장단점

- 장점

HTTP 프로토콜의 인프라를 그대로 사용하므로 REST API 사용을 위한 별도의 인프라를 구출할 필요가 없다.

HTTP 프로토콜의 표준을 최대한 활용하여 여러 추가적인 장점을 함께 가져갈 수 있게 해준다.

HTTP 표준 프로토콜에 따르는 모든 플랫폼에서 사용이 가능하다.

Hypermedia API의 기본을 충실히 지키면서 범용성을 보장한다.

REST API 메시지가 의도하는 바를 명확하게 나타내므로 의도하는 바를 쉽게 파악할 수 있다.

여러가지 서비스 디자인에서 생길 수 있는 문제를 최소화한다.

서버와 클라이언트의 역할을 명확하게 분리한다.

- 단점

표준이 존재하지 않는다.

사용할 수 있는 메소드가 4가지 밖에 없다.

HTTP Method 형태가 제한적이다.

브라우저를 통해 테스트할 일이 많은 서비스라면 쉽게 고칠 수 있는 URL보다 Header 값이 왠지 더 어렵게 느껴진다.

구형 브라우저가 아직 제대로 지원해주지 못하는 부분이 존재한다.

PUT, DELETE를 사용하지 못하는 점

pushState를 지원하지 않는 점

4. REST가 필요한 이유

‘애플리케이션 분리 및 통합’

‘다양한 클라이언트의 등장’

최근의 서버 프로그램은 다양한 브라우저와 안드로이폰, 아이폰과 같은 모바일 디바이스에서도 통신을 할 수 있어야 한다.

이러한 멀티 플랫폼에 대한 지원을 위해 서비스 자원에 대한 아키텍처를 세우고 이용하는 방법을 모색한 결과, REST에 관심을 가지게 되었다.

5. REST 구성 요소

자원(Resource): URI

모든 자원에 고유한 ID가 존재하고, 이 자원은 Server에 존재한다.

자원을 구별하는 ID는 ‘/groups/:group_id’와 같은 HTTP URI 다.

Client는 URI를 이용해서 자원을 지정하고 해당 자원의 상태(정보)에 대한 조작을 Server에 요청한다.

행위(Verb): HTTP Method

HTTP 프로토콜의 Method를 사용한다.

HTTP 프로토콜은 GET, POST, PUT, DELETE 와 같은 메서드를 제공한다.

표현(Representation of Resource)

Client가 자원의 상태(정보)에 대한 조작을 요청하면 Server는 이에 적절한 응답(Representation)을 보낸다.

REST에서 하나의 자원은 JSON, XML, TEXT, RSS 등 여러 형태의 Representation으로 나타내어 질 수 있다.

JSON 혹은 XML를 통해 데이터를 주고 받는 것이 일반적이다.

6. REST 특징

Server-Client(서버-클라이언트 구조)

자원이 있는 쪽이 Server, 자원을 요청하는 쪽이 Client가 된다.

REST Server: API를 제공하고 비즈니스 로직 처리 및 저장을 책임진다.

Client: 사용자 인증이나 context(세션, 로그인 정보) 등을 직접 관리하고 책임진다.

서로 간 의존성이 줄어든다.

Stateless(무상태)

HTTP 프로토콜은 Stateless Protocol이므로 REST 역시 무상태성을 갖는다.

Client의 context를 Server에 저장하지 않는다.

즉, 세션과 쿠키와 같은 context 정보를 신경쓰지 않아도 되므로 구현이 단순해진다.

Server는 각각의 요청을 완전히 별개의 것으로 인식하고 처리한다.

각 API 서버는 Client의 요청만을 단순 처리한다.

즉, 이전 요청이 다음 요청의 처리에 연관되어서는 안된다.

물론 이전 요청이 DB를 수정하여 DB에 의해 바뀌는 것은 허용한다.

Server의 처리 방식에 일관성을 부여하고 부담이 줄어들며, 서비스의 자유도가 높아진다.

Cacheable(캐시 처리 가능)

웹 표준 HTTP 프로토콜을 그대로 사용하므로 웹에서 사용하는 기존의 인프라를 그대로 활용할 수 있다.

즉, HTTP가 가진 가장 강력한 특징 중 하나인 캐싱 기능을 적용할 수 있다.

HTTP 프로토콜 표준에서 사용하는 Last-Modified 태그나 E-Tag를 이용하면 캐싱 구현이 가능하다.

대량의 요청을 효율적으로 처리하기 위해 캐시가 요구된다.

캐시 사용을 통해 응답시간이 빨라지고 REST Server 트랜잭션이 발생하지 않기 때문에 전체 응답시간, 성능, 서버의 자원 이용률을 향상시킬 수 있다.

Layered System(계층화)

Client는 REST API Server만 호출한다.

REST Server는 다중 계층으로 구성될 수 있다.

API Server는 순수 비즈니스 로직을 수행하고 그 앞단에 보안, 로드밸런싱, 암호화, 사용자 인증 등을 추가하여 구조상의 유연성을 줄 수 있다.

또한 로드밸런싱, 공유 캐시 등을 통해 확장성과 보안성을 향상시킬 수 있다.

PROXY, 게이트웨이 같은 네트워크 기반의 중간 매체를 사용할 수 있다.

Code-On-Demand(optional)

Server로부터 스크립트를 받아서 Client에서 실행한다.

반드시 충족할 필요는 없다.

Uniform Interface(인터페이스 일관성)

URI로 지정한 Resource에 대한 조작을 통일되고 한정적인 인터페이스로 수행한다.

HTTP 표준 프로토콜에 따르는 모든 플랫폼에서 사용이 가능하다.

특정 언어나 기술에 종속되지 않는다.

7. REST API란

API(Application Programming Interface)란

데이터와 기능의 집합을 제공하여 컴퓨터 프로그램간 상호작용을 촉진하며, 서로 정보를 교환가능 하도록 하는 것

REST API의 정의

REST 기반으로 서비스 API를 구현한 것

최근 OpenAPI(누구나 사용할 수 있도록 공개된 API: 구글 맵, 공공 데이터 등), 마이크로 서비스(하나의 큰 애플리케이션을 여러 개의 작은 애플리케이션으로 쪼개어 변경과 조합이 가능하도록 만든 아키텍처) 등을 제공하는 업체 대부분은 REST API를 제공한다.

8. REST API의 특징

사내 시스템들도 REST 기반으로 시스템을 분산해 확장성과 재사용성을 높여 유지보수 및 운용을 편리하게 할 수 있다.

REST는 HTTP 표준을 기반으로 구현하므로, HTTP를 지원하는 프로그램 언어로 클라이언트, 서버를 구현할 수 있다.

즉, REST API를 제작하면 델파이 클라이언트 뿐 아니라, 자바, C#, 웹 등을 이용해 클라이언트를 제작할 수 있다.

9. RESTful이란

RESTful은 일반적으로 REST라는 아키텍처를 구현하는 웹 서비스를 나타내기 위해 사용되는 용어이다.

‘REST API’를 제공하는 웹 서비스를 ‘RESTful’하다고 할 수 있다.

RESTful은 REST를 REST답게 쓰기 위한 방법으로, 누군가가 공식적으로 발표한 것이 아니다.

즉, REST 원리를 따르는 시스템은 RESTful이란 용어로 지칭된다.

RESTful의 목적

이해하기 쉽고 사용하기 쉬운 REST API를 만드는 것

RESTful한 API를 구현하는 근본적인 목적이 성능 향상에 있는 것이 아니라 일관적인 컨벤션을 통한 API의 이해도 및 호환성을 높이는 것이 주 동기이니, 성능이 중요한 상황에서는 굳이 RESTful한 API를 구현할 필요는 없다.

RESTful 하지 못한 경우

Ex1) CRUD 기능을 모두 POST로만 처리하는 API

Ex2) route에 resource, id 외의 정보가 들어가는 경우(/students/updateName)

'유용한 자료들(Tip)' 카테고리의 다른 글

Firebase : Send notification with REST API (0)	2019.10.30

/*

gcc -o w_send w_send.c -lwsock32 -Wall -DTEST_PRINTF

*/

#include <WinSock2.h>
#include <windows.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>

#define  MAXLINE 4096

DWORD WINAPI stdin_input_send_thread(LPVOID arg);

FILE *fp=NULL;
FILE *stream=NULL;
char line[MAXLINE], chatdata[MAXLINE+1];

struct sockaddr_in server_addr;
SOCKET clientsocket; //server connect socket
char *escape = "quit"; //exit command message
BOOL bisquit;           //exit falg variable

int main(int argc, char *argv[])
{
    WSADATA wsa;    //socket
    HANDLE hthread; //thread
    DWORD threadid;
    int size;

    if (argc != 4)
    {
        printf("usage : %s server_address port filename\n", argv[0]);
        return(-1);
    }
    bisquit = FALSE;

    //socket initialization
    if (WSAStartup(MAKEWORD(2,2), &wsa) != 0)
    {
        return(-2);
    }
    //socket creation
    if ((clientsocket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        printf("fail make socket\n");
        return(-3);
    }

    //memory initialization
    memset(&server_addr, 0x00, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = inet_addr(argv[1]);
    server_addr.sin_port = htons(atoi(argv[2]));

    //connection with server
    if (connect(clientsocket, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0)
    {
        printf("fail connect to server\n");
        return(-4);
    }

    if((fp = fopen(argv[3], "rt"))==NULL)
    {
        printf("fopen error(%s)\n", argv[3]);
        return(-5);
    }

if((stream = fopen("KRX_SEND.dat", "wt"))==NULL)
    {
        printf("fopen error(%s)\n", argv[3]);
        return(-5);
    }

    hthread = CreateThread(NULL, 0, stdin_input_send_thread, 0, 0, &threadid);
    if (hthread == NULL)
    {
        printf("fail make thread\n");
    }
    else
    {
        CloseHandle(hthread);
    }

    while (!bisquit)
    {
        memset(chatdata, 0x00, sizeof(chatdata));

        if ((size = recv(clientsocket, chatdata, MAXLINE, 0)) == INVALID_SOCKET)
        {
            break;
        }
        else
        {
            chatdata[size] = '\0';
            printf("(RECV)%s", chatdata);
fprintf(stream, "%s", chatdata);
        }
    }
    closesocket(clientsocket);
    WSACleanup();

    if(fp != NULL) fclose(fp);
if(stream != NULL) fclose(stream);

    return(0);
}

//user data input mechanism
DWORD WINAPI stdin_input_send_thread(LPVOID arg)
{
    char rbuf[MAXLINE];

    while(TRUE)
    {
        memset(rbuf, 0x00, sizeof(rbuf));
        if(fgets(rbuf, sizeof(rbuf), fp) == NULL)
{
bisquit = TRUE;
break;
}

        printf("(SEND)%s", rbuf);

        if (send(clientsocket, rbuf, strlen(rbuf), 0) < 0)
        {
            return(-2);
        }

        Sleep(50); //#include
    }

closesocket(clientsocket);
    return 0;
}

'통신 > SELECT(TCP)' 카테고리의 다른 글

KOSCOM DATA,SEND,SELECT MODEL CLIENT (0)	2020.08.25
KOSCOM DATA,RECV,SELECT MODEL SERVER (0)	2020.08.25
WINDOWS,SERVER,SELECT(FILE RECV),BASIC(SEND),FILE SAVE(DIFF) (0)	2019.10.29
WINDOWS,SERVER,SELECT(FILE RECV),BASIC(SEND) (0)	2019.10.29
WINDOWS,CLIENT,THREAD(FILE READ SEND),BASIC(RECV) (0)	2019.10.29

/*

gcc -o w_server w_server.c -lwsock32 -Wall -DTEST_PRINTF

*/

#include <winsock2.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#define MAXLINE 4096
#define MAX_SOCK 64

#define bzero(b,len) (memset(b,0,len))
#define bcopy(b1,b2,len) (memcpy(b1,b2,len))

char *escapechar = "exit";
char send_calc_msg[MAXLINE+1];

//EXTERN LINK VARIABLE
char input[MAXLINE+1];

int maxfd;
int g_num_chat = 0;
int client_s[MAX_SOCK];

FILE *fp=NULL;

//STATIC LINK
static int getmax(int);
static void removeclient(int);
static int getdottedipaddr(int sd, struct sockaddr_in *addr);

int main(int argc, char *argv[])
{
    char rline[MAXLINE+1];
    int ii, kk, recv_len;
    int client_fd, clilen, rc;

    fd_set read_fds;
    WSADATA wsadata;
    SOCKET hservsock;
    SOCKADDR_IN client_addr, server_addr;

    if (argc != 2) {
        printf("usage : %s port\n", argv[0]);
        return(-1);
    }

if((fp=fopen("KRX_RECV.dat", "wt"))==NULL)
{
return(-7);
}

if(WSAStartup(MAKEWORD(2,2), &wsadata) != 0)
    {
        return(-9);
    }

    hservsock=socket(PF_INET, SOCK_STREAM, 0);
    if(hservsock==INVALID_SOCKET)
    {
        return(-8);
    }

    bzero((char *)&server_addr, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    server_addr.sin_port = htons(atoi(argv[1]));

    if (bind(hservsock, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
        return(-3);
    }
    listen(hservsock, 5); /* backlog = 5 */
    maxfd = hservsock + 1;

for(;;)
    {
        FD_ZERO(&read_fds);
        FD_SET(hservsock, &read_fds);
        for (ii=0; ii < g_num_chat; ii++)
        {
            FD_SET(client_s[ii], &read_fds);
        }
        maxfd = getmax(hservsock) + 1;

        if (select(maxfd, &read_fds, (fd_set *)0, (fd_set *)0, (struct timeval *)0) < 0)
        {
            printf("server: select error.\n");
            break;
        }

        if (FD_ISSET(hservsock, &read_fds))
        {
            clilen = sizeof(client_addr);
            client_fd = accept(hservsock, (struct sockaddr *)&client_addr, &clilen);
            if (client_fd == -1)
            {
                printf("server: accept error\n");
                break;
            }
            client_s[g_num_chat] = client_fd;
            g_num_chat++;
        }

        for (ii=0; ii<g_num_chat; ii++)
        {
            if (FD_ISSET(client_s[ii], &read_fds))
            {
                if ((recv_len = recv(client_s[ii], rline, MAXLINE, 0)) <= 0)
                {
                    removeclient(ii); /* abrupt exit *//* abrupt exit *//* abrupt exit *//* abrupt exit */
                    continue;
                }
                rline[recv_len] = '\0';

                for (kk=0; kk<g_num_chat; kk++)
                {
                    send(client_s[kk], rline, recv_len, 0);
                    printf("[%.5d][%d]%s", kk, client_s[ii], rline);

if(client_s[ii] == client_s[kk])
{
fprintf(fp,"%s", rline);
fflush(fp); /*in server, very important*/
}
                }
            }
        }
    } /* while */

    rc = WSACleanup();
    if(rc == WSANOTINITIALISED)
    {
        printf(">>error::A successful WSAStartup call must occur before using this function.\n");
    }
    else if(rc == WSAENETDOWN)
    {
        printf(">>error::The network subsystem has failed.\n");
    }
    else if(rc == WSAEINPROGRESS)
    {
        printf(">>error::A blocking Windows Sockets 1.1 call is in progress, or the service provider is still processing a callback function.\n");
    }
    closesocket(hservsock);

if(fp != NULL) fclose(fp);
}

void removeclient(int indx)
{
    struct sockaddr_in client_addr;

    if (getdottedipaddr(client_s[indx], &client_addr) > -1)
    {
        printf("\nserver>>removeclient>>1 number expired!!(IP: %s).", inet_ntoa(client_addr.sin_addr));
    }
    else
    {
        printf("\nserver>>removeclient>>1 number expired!!.");
    }

    closesocket(client_s[indx]);

    if (indx != g_num_chat-1)
    {
        client_s[indx] = client_s[g_num_chat-1];
    }

    g_num_chat--;
    printf("\nserver>>removeclient>>now number = %d\n", g_num_chat);
}

int getmax(int k)
{
    int max = k;
    int r;

    for (r=0; r < g_num_chat; r++)
    {
        if (client_s[r] > max) max = client_s[r];
    }
    return max;
}

int getdottedipaddr(int sd, struct sockaddr_in *addr)
{
    struct sockaddr_in client_addr;
    int len, r;

    len = sizeof(client_addr);
    if ((r = getpeername(sd, (struct sockaddr *)&client_addr, &len)) == 0)
    {
        *addr = client_addr;
    }
    return r;
}

'통신 > SELECT(TCP)' 카테고리의 다른 글

KOSCOM DATA,RECV,SELECT MODEL SERVER (0)	2020.08.25
WINDOWS,CLIENT,THREAD(FILE READ SEND),BASIC(RECV),FILE SAVE(DIFF) (0)	2019.10.29
WINDOWS,SERVER,SELECT(FILE RECV),BASIC(SEND) (0)	2019.10.29
WINDOWS,CLIENT,THREAD(FILE READ SEND),BASIC(RECV) (0)	2019.10.29
LINUX,SERVER,SELECT(RECV),SELECT(SEND) (0)	2019.10.29

/*

WINDOWS,SERVER,SELECT(RECV),BASIC(SEND)

*/

#include <winsock2.h>
#include <stdio.h>
#include <fcntl.h>
#include <stdlib.h>
#include <string.h>

#define MAXLINE 4096
#define MAX_SOCK 64

#define bzero(b,len) (memset(b,0,len))
#define bcopy(b1,b2,len) (memcpy(b1,b2,len))

char *escapechar = "exit";
char send_calc_msg[MAXLINE+1];

//EXTERN LINK VARIABLE
char input[MAXLINE+1];

int maxfd;
int g_num_chat = 0;
int client_s[MAX_SOCK];

//STATIC LINK
static int getmax(int);
static void removeclient(int);
static int getdottedipaddr(int sd, struct sockaddr_in *addr);

int main(int argc, char *argv[])
{
    char rline[MAXLINE+1];
    int ii, kk, nn;
    int client_fd, clilen, rc;

    fd_set read_fds;
    WSADATA wsadata;
    SOCKET hservsock;
    SOCKADDR_IN client_addr, server_addr;

    if (argc != 2) {
        printf("usage : %s port\n", argv[0]);
        return(-1);
    }

if(WSAStartup(MAKEWORD(2,2), &wsadata) != 0)
    {
        return(-9);
    }

    hservsock=socket(PF_INET, SOCK_STREAM, 0);
    if(hservsock==INVALID_SOCKET)
    {
        return(-8);
    }

    bzero((char *)&server_addr, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    server_addr.sin_port = htons(atoi(argv[1]));

    if (bind(hservsock, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
        return(-3);
    }
    listen(hservsock, 5); /* backlog = 5 */
    maxfd = hservsock + 1;

for(;;)
    {
        FD_ZERO(&read_fds);
        FD_SET(hservsock, &read_fds);
        for (ii=0; ii < g_num_chat; ii++)
        {
            FD_SET(client_s[ii], &read_fds);
        }
        maxfd = getmax(hservsock) + 1;

        if (select(maxfd, &read_fds, (fd_set *)0, (fd_set *)0, (struct timeval *)0) < 0)
        {
            printf("server: select error.\n");
            break;
        }

        if (FD_ISSET(hservsock, &read_fds))
        {
            clilen = sizeof(client_addr);
            client_fd = accept(hservsock, (struct sockaddr *)&client_addr, &clilen);
            if (client_fd == -1)
            {
                printf("server: accept error\n");
                break;
            }
            client_s[g_num_chat] = client_fd;
            g_num_chat++;
        }

        for (ii=0; ii<g_num_chat; ii++)
        {
            if (FD_ISSET(client_s[ii], &read_fds))
            {
                if ((nn = recv(client_s[ii], rline, MAXLINE, 0)) <= 0)
                {
                    removeclient(ii); /* abrupt exit *//* abrupt exit *//* abrupt exit *//* abrupt exit */
                    continue;
                }
                rline[nn] = 0x00;

                for (kk=0; kk<g_num_chat; kk++)
                {
                    send(client_s[kk], rline, nn, 0);
                    printf("[%.5d][%d]%s", kk, client_s[ii], rline);
                }
            }
        }
    } /* while */

    rc = WSACleanup();
    if(rc == WSANOTINITIALISED)
    {
        printf(">>error::A successful WSAStartup call must occur before using this function.\n");
    }
    else if(rc == WSAENETDOWN)
    {
        printf(">>error::The network subsystem has failed.\n");
    }
    else if(rc == WSAEINPROGRESS)
    {
        printf(">>error::A blocking Windows Sockets 1.1 call is in progress, or the service provider is still processing a callback function.\n");
    }
    closesocket(hservsock);
}

void removeclient(int indx)
{
    struct sockaddr_in client_addr;

    if (getdottedipaddr(client_s[indx], &client_addr) > -1)
    {
        printf("\nserver>>removeclient>>1 number expired!!(IP: %s).", inet_ntoa(client_addr.sin_addr));
    }
    else
    {
        printf("\nserver>>removeclient>>1 number expired!!.");
    }

    closesocket(client_s[indx]);

    if (indx != g_num_chat-1)
    {
        client_s[indx] = client_s[g_num_chat-1];
    }

    g_num_chat--;
    printf("\nserver>>removeclient>>now number = %d\n", g_num_chat);
}

int getmax(int k)
{
    int max = k;
    int r;

    for (r=0; r < g_num_chat; r++)
    {
        if (client_s[r] > max) max = client_s[r];
    }
    return max;
}

int getdottedipaddr(int sd, struct sockaddr_in *addr)
{
    struct sockaddr_in client_addr;
    int len, r;

    len = sizeof(client_addr);
    if ((r = getpeername(sd, (struct sockaddr *)&client_addr, &len)) == 0)
    {
        *addr = client_addr;
    }
    return r;
}

'통신 > SELECT(TCP)' 카테고리의 다른 글

WINDOWS,CLIENT,THREAD(FILE READ SEND),BASIC(RECV),FILE SAVE(DIFF) (0)	2019.10.29
WINDOWS,SERVER,SELECT(FILE RECV),BASIC(SEND),FILE SAVE(DIFF) (0)	2019.10.29
WINDOWS,CLIENT,THREAD(FILE READ SEND),BASIC(RECV) (0)	2019.10.29
LINUX,SERVER,SELECT(RECV),SELECT(SEND) (0)	2019.10.29
Makefile(win_calc_server: win_calc_server.o pushcall.o common.o calc_server.o) (0)	2019.10.29

/*

WINDOWS,CLIENT,THREAD(FILE READ SEND),BASIC(RECV)

*/

#include <WinSock2.h>
#include <windows.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#define  MAXLINE 1024

DWORD WINAPI stdin_input_send_thread(LPVOID arg);

FILE *fp=NULL;
char line[MAXLINE], chatdata[MAXLINE+1];

struct sockaddr_in server_addr;
SOCKET clientsocket; //server connect socket
char *escape = "quit"; //exit command message
BOOL bisquit;           //exit falg variable

int main(int argc, char *argv[])
{
    WSADATA wsa;    //socket
    HANDLE hthread; //thread
    DWORD threadid;
    int size;

    if (argc != 4)
    {
        printf("usage : %s server_address port filename\n", argv[0]);
        return(-1);
    }
    bisquit = FALSE;

    //socket initialization
    if (WSAStartup(MAKEWORD(2,2), &wsa) != 0)
    {
        return(-2);
    }
    //socket creation
    if ((clientsocket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        printf("fail make socket\n");
        return(-3);
    }

    //memory initialization
    memset(&server_addr, 0x00, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = inet_addr(argv[1]);
    server_addr.sin_port = htons(atoi(argv[2]));

    //connection with server
    if (connect(clientsocket, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0)
    {
        printf("fail connect to server\n");
        return(-4);
    }

    if((fp = fopen(argv[3], "rt"))==NULL)
    {
        printf("fopen error(%s)\n", argv[3]);
        return(-5);
    }

    hthread = CreateThread(NULL, 0, stdin_input_send_thread, 0, 0, &threadid);
    if (hthread == NULL)
    {
        printf("fail make thread\n");
    }
    else
    {
        CloseHandle(hthread);
    }

    while (!bisquit)
    {
        memset(chatdata, 0x00, sizeof(chatdata));

        if ((size = recv(clientsocket, chatdata, MAXLINE, 0)) == INVALID_SOCKET)
        {
            break;
        }
        else
        {
            chatdata[size] = '\0';
            printf("(RECV)%s", chatdata);
        }
    }
    closesocket(clientsocket);
    WSACleanup();

    if(fp != NULL) fclose(fp);

    return(0);
}

//user data input mechanism
DWORD WINAPI stdin_input_send_thread(LPVOID arg)
{
    char rbuf[4096];

    while(TRUE)
    {
        memset(rbuf, 0x00, sizeof(rbuf));
        if(fgets(rbuf, sizeof(rbuf), fp) == NULL) break;

        printf("(SEND)%s", rbuf);

        if (send(clientsocket, rbuf, strlen(rbuf), 0) < 0)
        {
            return(-2);
        }

        Sleep(500); //#include
    }
    return 0;
}

'통신 > SELECT(TCP)' 카테고리의 다른 글

WINDOWS,SERVER,SELECT(FILE RECV),BASIC(SEND),FILE SAVE(DIFF) (0)	2019.10.29
WINDOWS,SERVER,SELECT(FILE RECV),BASIC(SEND) (0)	2019.10.29
LINUX,SERVER,SELECT(RECV),SELECT(SEND) (0)	2019.10.29
Makefile(win_calc_server: win_calc_server.o pushcall.o common.o calc_server.o) (0)	2019.10.29
Windows,client,tcp,basic(recv),thread(send) (0)	2019.10.29

/*-------------------

* static 키워드를 사용한 변수는 클래스가 메모리에 올라갈 때 자동으로 생성이 됩니다.
인스턴스 생성 없이 바로 사용이 가능한 것이죠.
이런 특성 때문에 프로그램 내에서 공통으로 사용되는 데이터들을 관리할 때 이용합니다.
자바 프로그램에서는 공통 로직이 들어가는 유틸 기능을 static 으로 작성하곤 합니다.
이런 static 은 남발해서는 안되며 공통으로 값을 유지하고 싶을 때만 사용합니다.

*/

public class StaticSample02 {
public static void main(String args[]) {

        Card c1 = new Card();
        c1.kind = "Heart";
        c1.number = 7;

System.out.println("==> 인스턴스 함수 호출");
System.out.println("totalWidth() : " + c1.totalWidth());

        System.out.println("==> static 함수 호출 ");
        System.out.println("totalWidth() : " + Card.totalWidth(10, 20));
    }
}

class Card {

    String kind;      // 카드 종류
    int number;       // 카드 숫자
    int width = 10;   // 카드 넓이
    int height = 25; // 카드 높이

    public int getNumber() {
        return number;
    }
    public int totalWidth() {
        return width * height;
    }
    public static int totalWidth(int width, int height) {
        return width * height;
    }
}

/*--------결과
==> 인스턴스 함수 호출
totalWidth() : 250
==> static 함수 호출
totalWidth() : 200

--------------------------------------*/

'java 언어 > Java' 카테고리의 다른 글

C#과 Java비교(Properties ,Variables, Array) (0)	2021.10.24
Non-Static (Instance) 변수를 활용한 AES 128 BITS ALGORITHM AES/ECB/PKCS7PADDING AND HEX ENCODING (0)	2019.10.29
카카오 신입공채 1차 코딩테스트 문제1 비밀지도(자바풀이) (0)	2019.10.29

import javax.crypto.Cipher;
import javax.crypto.spec.SecretKeySpec;

public class AES128 {

public static String key = "AAAAAAAAAAAAAAAA";

     public static void main(String[] args) {
         String message = "ABCDEFGHIJKLMNOPQRSTUABCDEFGHIJKLMNOPQRSTUABCDEFGHIJKLMNOPQRSTU";

         AES128 aes128 = new AES128();

         try
         {
            String encrypt = aes128.encrypt(message);
            System.out.println("[ORIGIN STR ]= " + message);
            System.out.println("[ENCRYPT STR ]= " + encrypt);

            String decrypt = aes128.decrypt(encrypt);
            System.out.println("[DECRYPT STR ]= " + decrypt);
         }
         catch (Exception e)
         {
            e.printStackTrace();
         }
     }
     public byte[] hexToByteArray(String hex) {
        if (hex == null || hex.length() == 0) {
            return null;
        }

        byte[] ba = new byte[hex.length() / 2];

        for (int i = 0; i < ba.length; i++) {
            ba[i] = (byte) Integer.parseInt(hex.substring(2 * i, 2 * i + 2), 16);
        }

        return ba;
     }
     public String byteArrayToHex(byte[] ba) {
        if (ba == null || ba.length == 0) {
            return null;
        }

        StringBuffer sb = new StringBuffer(ba.length * 2);
        String hexNumber;

        for (int x = 0; x < ba.length; x++) {
            hexNumber = "0" + Integer.toHexString(0xff & ba[x]);
            sb.append(hexNumber.substring(hexNumber.length() - 2));
        }

        return sb.toString();
     }
     public String encrypt(String message) throws Exception {

        AES128 aes128 = new AES128();

        SecretKeySpec skeySpec = new SecretKeySpec(key.getBytes(), "AES");

Cipher cipher = Cipher.getInstance("AES");
cipher.init(Cipher.ENCRYPT_MODE, skeySpec);

        byte[] encrypted = cipher.doFinal(message.getBytes());

        return aes128.byteArrayToHex(encrypted);
     }
     public String decrypt(String encrypted) throws Exception {

        AES128 aes128 = new AES128();

        SecretKeySpec skeySpec = new SecretKeySpec(key.getBytes(), "AES");

        Cipher cipher = Cipher.getInstance("AES");
        cipher.init(Cipher.DECRYPT_MODE, skeySpec);

        byte[] original = cipher.doFinal(aes128.hexToByteArray(encrypted));

        String originalString = new String(original);

        return originalString;
    }
}

/*결과

[ORIGIN STR ]= ABCDEFGHIJKLMNOPQRSTUABCDEFGHIJKLMNOPQRSTUABCDEFGHIJKLMNOPQRSTU
[ENCRYPT STR ]= 1eb6a5b8559de7cf7936ad108fb1bd2cd323454cfb4097b6bc53e670a51e9067
deaeebd8095ae5a76ebf9797c551bc0ab0ebca77dc7be9dd95452b34e90f845c
[DECRYPT STR ]= ABCDEFGHIJKLMNOPQRSTUABCDEFGHIJKLMNOPQRSTUABCDEFGHIJKLMNOPQRSTU

*/

'java 언어 > Java' 카테고리의 다른 글

C#과 Java비교(Properties ,Variables, Array) (0)	2021.10.24
static 함수와 인스턴스 함수의 차이 (0)	2019.10.29
카카오 신입공채 1차 코딩테스트 문제1 비밀지도(자바풀이) (0)	2019.10.29

/*

카카오 신입공채 1차 코딩테스트 문제1 비밀지도

문제설명

네오는 평소 프로도가 비상금을 숨겨놓는 장소를 알려줄 비밀지도를 손에 넣었다. 그런데 이 비밀지도는 숫자로 암호화되어 있어 위치를 확인하기 위해서는 암호를 해독해야 한다. 다행히 지도 암호를 해독할 방법을 적어놓은 메모도 함께 발견했다.

지도는 한 변의 길이가 n인 정사각형 배열 형태로, 각 칸은 “공백”(“ “) 또는 “벽”(“#”) 두 종류로 이루어져 있다.

전체 지도는 두 장의 지도를 겹쳐서 얻을 수 있다. 각각 “지도 1”과 “지도 2”라고 하자. 지도 1 또는 지도 2 중 어느 하나라도 벽인 부분은 전체 지도에서도 벽이다. 지도 1과 지도 2에서 모두 공백인 부분은 전체 지도에서도 공백이다.

“지도 1”과 “지도 2”는 각각 정수 배열로 암호화되어 있다.

암호화된 배열은 지도의 각 가로줄에서 벽 부분을 1, 공백 부분을 0으로 부호화했을 때 얻어지는 이진수에 해당하는 값의 배열이다.

이해이미지)

네오가 프로도의 비상금을 손에 넣을 수 있도록, 비밀지도의 암호를 해독하는 작업을 도와줄 프로그램을 작성하라.

입력형식

입력으로 지도의 한 변 크기 n 과 2개의 정수 배열 arr1, arr2가 들어온다.

arr1, arr2는 길이 n인 정수 배열로 주어진다.

정수 배열의 각 원소 x를 이진수로 변환했을 때의 길이는 n 이하이다. 즉, 0 ? x ? 2^n - 1을 만족한다.

출력형식

원래의 비밀지도를 해독하여 "#", 공백으로 구성된 문자열 배열로 출력하라.

문제해설

이 문제는 비트 연산Bitwise Operation을 묻는 문제입니다. 이미 문제 예시에 2진수로 처리하는 힌트가 포함되어 있고, 둘 중 하나가 1일 경우에 벽 #이 생기기 때문에 OR로 처리하면 간단히 풀 수 있습니다. 아주 쉬운 문제였던 만큼 if else로 풀이한 분들도 많이 발견되었는데요. 정답으로는 간주되지만 이 문제는 비트 연산을 잘 다룰 수 있는지를 묻고자 하는 의도였던 만큼 앞으로 이런 유형의 문제를 풀 때는 비트 연산을 꼭 기억하시기 바랍니다.

이 문제의 정답률은 81.78%입니다. 첫 번째 문제이고 가장 쉬운 문제였던 만큼 많은 분들이 잘 풀어주셨습니다.

*/

public class SecretMap {

public static void main(String[] args) {

int[] arr1;

int[] arr2;

arr1 = new int[]{9, 20, 28, 18, 11};

arr2 = new int[]{30, 1, 21, 17, 28};

printArr(decodeSecretMap(5, arr1, arr2));

arr1 = new int[]{46, 33, 33 ,22, 31, 50};

arr2 = new int[]{27 ,56, 19, 14, 14, 10};

printArr(decodeSecretMap(6, arr1, arr2));

}

/**

* 입력받은 arr1, arr2의 각 int를 or연산 처리

* -> toBinaryString으로 변환 -> 출력형태에 맞게 문자열 replace

* @param n

* @param arr1

* @param arr2

* @return

*/

public static String[] decodeSecretMap(int n, int[] arr1, int[] arr2) {

String[] retArr = new String[n];

for(int i = 0; i < n; i++) {

retArr[i] = Integer.toBinaryString(arr1[i]|arr2[i]).replace("0", " ").replace("1", "#").replace("2", "$").replace("3", "%");

}

return retArr;

}

/**

* 배열을 입력받아 println

* @param arr

*/

public static void printArr(String[] arr) {

StringBuilder sb = new StringBuilder();

for(String str: arr) {

sb.append(", \""+str+"\"");

}

System.out.println(sb.toString().replaceFirst(", ", ""));

}

/*결과

bash-3.1$

bash-3.1$ java SecretMap

"#####", "# # #", "### #", "# ##", "#####"

"######", "### #", "## ##", "#### ", "#####", "### # "

bash-3.1$

*/

'java 언어 > Java' 카테고리의 다른 글

C#과 Java비교(Properties ,Variables, Array) (0)	2021.10.24
static 함수와 인스턴스 함수의 차이 (0)	2019.10.29
Non-Static (Instance) 변수를 활용한 AES 128 BITS ALGORITHM AES/ECB/PKCS7PADDING AND HEX ENCODING (0)	2019.10.29

//IPC QUEUE 데이타를 읽어 KAFKA에 전송하는경우

//FILE의 데이타를 읽어서 KAFKA에 전송하는경우(아래소스는 여기에 해당)

/*

* librdkafka - Apache Kafka C library

*

* Redistribution and use in source and binary forms, with or without

* modification, are permitted provided that the following conditions are met:

*

* 1. Redistributions of source code must retain the above copyright notice,

* this list of conditions and the following disclaimer.

* 2. Redistributions in binary form must reproduce the above copyright notice,

* this list of conditions and the following disclaimer in the documentation

* and/or other materials provided with the distribution.

*

* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"

* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE

* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE

* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE

* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR

* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF

* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS

* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN

* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)

* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

* POSSIBILITY OF SUCH DAMAGE.

*/

/**

* Simple Apache Kafka producer

* using the Kafka driver from librdkafka

* (https://github.com/edenhill/librdkafka)

*/

#include <stdio.h>

#include <signal.h>

#include <string.h>

/* Typical include path would be <librdkafka/rdkafka.h>, but this program

* is builtin from within the librdkafka source tree and thus differs. */

#include "rdkafka.h"

static int run = 1;

/**

* @brief Signal termination of program

*/

static void stop (int sig) {

run = 0;

fclose(stdin); /* abort fgets() */

}

/**

* @brief Message delivery report callback.

*

* This callback is called exactly once per message, indicating if

* the message was succesfully delivered

* (rkmessage->err == RD_KAFKA_RESP_ERR_NO_ERROR) or permanently

* failed delivery (rkmessage->err != RD_KAFKA_RESP_ERR_NO_ERROR).

*

* The callback is triggered from rd_kafka_poll() and executes on

* the application's thread.

*/

static void dr_msg_cb (rd_kafka_t *rk, const rd_kafka_message_t *rkmessage, void *opaque) {

if (rkmessage->err)

fprintf(stderr, "%% Message delivery failed: %s\n",

rd_kafka_err2str(rkmessage->err));

else

fprintf(stderr,"%% Message delivered (%zd bytes, ""partition %"PRId32")\n",rkmessage->len, rkmessage->partition);

/* The rkmessage is destroyed automatically by librdkafka */

}

int main (int argc, char **argv) {

rd_kafka_t *rk; /* Producer instance handle */

rd_kafka_topic_t *rkt; /* Topic object */

rd_kafka_conf_t *conf; /* Temporary configuration object */

char errstr[512]; /* librdkafka API error reporting buffer */

char buf[512]; /* Message value temporary buffer */

const char *brokers; /* Argument: broker list */

const char *topic; /* Argument: topic to produce to */

FILE *fp=NULL;

/*

* Argument validation

*/

if (argc != 4) {

fprintf(stderr, "%% Usage: %s <broker> <topic> <filename>\n", argv[0]);

return -1;

}

brokers = argv[1]; //127.0.0.1:9092

//1.1 기본적인 topic 생성예제(topic의 이름은 test)

//>bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

//1.2 일자별로 topic생성(아래예제는 20180401 ~ 20180431, 4월 날짜별로 topic생성)

//>for ii in `seq 20180401 20180431`; do bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic $ii; done

//3. Step 3: Create a topic

//3.1 Let's create a topic named "test" with a single partition and only one replica:

// for ii in `seq 20180411 20180431`; do bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic $ii; done

//> cd /home1/irteamsu/kafka2/kafka_2.11-1.1.0

//> bin/kafka-server-start.sh config/server.properties

//3.2 TOPIC리스트 확인

//> bin/kafka-topics.sh --list --zookeeper localhost:2181

topic = argv[2]; //YYYYMMDD

if((fp=fopen(argv[3], "rt"))==NULL) return(-1);

/*

* Create Kafka client configuration place-holder

*/

conf = rd_kafka_conf_new();

/* Set bootstrap broker(s) as a comma-separated list of

* host or host:port (default port 9092).

* librdkafka will use the bootstrap brokers to acquire the full

* set of brokers from the cluster. */

if (rd_kafka_conf_set(conf, "bootstrap.servers", brokers,errstr, sizeof(errstr)) != RD_KAFKA_CONF_OK)

{

fprintf(stderr, "%s\n", errstr);

return -1;

}

/* Set the delivery report callback.

* This callback will be called once per message to inform

* the application if delivery succeeded or failed.

* See dr_msg_cb() above. */

rd_kafka_conf_set_dr_msg_cb(conf, dr_msg_cb);

/*

* Create producer instance.

*

* NOTE: rd_kafka_new() takes ownership of the conf object

* and the application must not reference it again after

* this call.

*/

rk = rd_kafka_new(RD_KAFKA_PRODUCER, conf, errstr, sizeof(errstr));

if (!rk) {

fprintf(stderr,

"%% Failed to create new producer: %s\n", errstr);

return -1;

}

/* Create topic object that will be reused for each message

* produced.

*

* Both the producer instance (rd_kafka_t) and topic objects (topic_t)

* are long-lived objects that should be reused as much as possible.

*/

rkt = rd_kafka_topic_new(rk, topic, NULL);

if (!rkt) {

fprintf(stderr, "%% Failed to create topic object: %s\n",

rd_kafka_err2str(rd_kafka_last_error()));

rd_kafka_destroy(rk);

return -1;

}

/* Signal handler for clean shutdown */

signal(SIGINT, stop);

fprintf(stderr,

"%% Type some text and hit enter to produce message\n"

"%% Or just hit enter to only serve delivery reports\n"

"%% Press Ctrl-C or Ctrl-D to exit\n");

while (run)

{

memset(buf, 0x00, sizeof(buf));

if(fgets(buf, sizeof(buf), fp)==NULL) break;

size_t len = strlen(buf);

if (buf[len-1] == '\n') /* Remove newline */

buf[--len] = '\0';

if (len == 0) {

/* Empty line: only serve delivery reports */

rd_kafka_poll(rk, 0/*non-blocking */);

continue;

}

/*

* Send/Produce message.

* This is an asynchronous call, on success it will only

* enqueue the message on the internal producer queue.

* The actual delivery attempts to the broker are handled

* by background threads.

* The previously registered delivery report callback

* (dr_msg_cb) is used to signal back to the application

* when the message has been delivered (or failed).

*/

retry:

if (rd_kafka_produce(

/* Topic object */

rkt,

/* Use builtin partitioner to select partition*/

RD_KAFKA_PARTITION_UA,

/* Make a copy of the payload. */

RD_KAFKA_MSG_F_COPY,

/* Message payload (value) and length */

buf, len,

/* Optional key and its length */

NULL, 0,

/* Message opaque, provided in

* delivery report callback as

* msg_opaque. */

NULL) == -1)

{

/**

* Failed to *enqueue* message for producing.

*/

fprintf(stderr,

"%% Failed to produce to topic %s: %s\n",

rd_kafka_topic_name(rkt),

rd_kafka_err2str(rd_kafka_last_error()));

/* Poll to handle delivery reports */

if (rd_kafka_last_error() ==

RD_KAFKA_RESP_ERR__QUEUE_FULL) {

/* If the internal queue is full, wait for

* messages to be delivered and then retry.

* The internal queue represents both

* messages to be sent and messages that have

* been sent or failed, awaiting their

* delivery report callback to be called.

*

* The internal queue is limited by the

* configuration property

* queue.buffering.max.messages */

rd_kafka_poll(rk, 1000/*block for max 1000ms*/);

goto retry;

}

else

{

fprintf(stderr, "%% Enqueued message (%zd bytes) "

"for topic %s\n",

len, rd_kafka_topic_name(rkt));

}

/* A producer application should continually serve

* the delivery report queue by calling rd_kafka_poll()

* at frequent intervals.

* Either put the poll call in your main loop, or in a

* dedicated thread, or call it after every

* rd_kafka_produce() call.

* Just make sure that rd_kafka_poll() is still called

* during periods where you are not producing any messages

* to make sure previously produced messages have their

* delivery report callback served (and any other callbacks

* you register). */

rd_kafka_poll(rk, 0/*non-blocking*/);

}

/* Wait for final messages to be delivered or fail.

* rd_kafka_flush() is an abstraction over rd_kafka_poll() which

* waits for all messages to be delivered.

*/

fprintf(stderr, "%% Flushing final messages..\n");

rd_kafka_flush(rk, 10*1000 /* wait for max 10 seconds */);

/* Destroy topic object */

rd_kafka_topic_destroy(rkt);

/* Destroy the producer instance */

rd_kafka_destroy(rk);

return 0;

}

'통신 > THREAD(TCP)' 카테고리의 다른 글

RcvManualData.c (0)	2021.03.17

//ORDR_DT = YYYYMMDD

DELETE FROM OPS_ORDER WHERE ORDR_DT <= date_format(date_add(now(), INTERVAL -1 MONTH), '%Y%m%d');

'데이타베이스 > MySQL' 카테고리의 다른 글

#LINUX,send_msg_to_queue.c (2번째) (0)	2019.10.30
#LINUX,recv_msg_from_queue.c (두번째) (0)	2019.10.30
#Queue를 이용한 MySQL입력 성능향상에 관한 글(1) (0)	2019.10.30
MySQL LOCK 확인 및 해제(kill) 방법 (0)	2019.10.29
#innodb_flush_log_at_trx_commit 에 따른 입력건수 성능비교 (0)	2019.10.29

MySQL LOCK 확인 및 해제(kill) 방법

MySQL 사용 시 관리자의 의도 혹은 그렇지 않은 이유들로 인해 Lock 상태가 발생한다.

이럴 경우 어느 쿼리가 Lock을 걸렸는지 확인 후 해당 쿼리를 해제(kill) 해야 할 상황이 있다.

Lock의 종류

Table Lock, User Lock, Global Lock, Name Lock이 있다. 트랜잭션 기반의 멀티 쓰레드를 사용하려면 Lock의 개념을 충분히 알아두어야 한다. 하지만 그렇지 못한 몇몇 프로그래머로 인해 다른 사용자들이 쿼리 대기상태(Lock으로 인한 리소스 접근 대기상태)로 서비스에 지장을 초래할 수 있다.

흔히들 알고있는 Read Lock, Write Lock은 Table, Global Lock 등에 포함된 내용이므로 이를 혼동해서 사용하지 않도록 하자.

이 포스팅은 Lock에 대한 개념을 다루지 않으므로, 보다 자세한 사항은 다른 포스팅을 참조하여 공부하고, Lock이 걸려있는 프로세스의 확인 및 해제를 다뤄보자.

Lock 확인 및 해제

아래 쿼리를 통해 현재 프로세스를 확인할 수 있다.

1. SHOW PROCESSLIST;

cs

(위 쿼리는 100개까지 list를 노출하며, 모두 노출 하려면 SHOW FULL PROCESSLIST;로 하면 된다.)

State컬럼을 보면 Waiting for table metadata lock 으로 인해 해당 쿼리가 진행되지 않음을 확인 할 수 있다.

그러면 이 프로세스를 해제(kill)해보자.

2. KILL 255;

cs

위 쿼리를 통해 lock을 해제할 수 있다.

원인

해당 테이블이 DDL을 통해 open상태일 경우.

선행 트랜잭션이 종료가 되지 않았을 경우 종료를 위한 DDL 구문 실행 대기.

보통 metadata lock info라는 별도의 플로그인을 통해 확인 할 수 있으나 불가능한 경우도 있다.

(트랜잭션 중 autocommit이 false일 때, commit을 수행하지 않고 DDL을 실행할 경우)

마무리

개발 중 문제에 봉착했을 때, 해결법에 대한 포스팅만 보고 해결하지 말고

원인을 분석하고 공부하다보면 내것으로 만들 수 있다는 생각으로 시간을 가지고 투자하면서

배움의 자세를 가지도록 노력하자.

'데이타베이스 > MySQL' 카테고리의 다른 글

#LINUX,send_msg_to_queue.c (2번째) (0)	2019.10.30
#LINUX,recv_msg_from_queue.c (두번째) (0)	2019.10.30
#Queue를 이용한 MySQL입력 성능향상에 관한 글(1) (0)	2019.10.30
1달전 자료 지우는 쿼리 (0)	2019.10.29
#innodb_flush_log_at_trx_commit 에 따른 입력건수 성능비교 (0)	2019.10.29

#innodb_flush_log_at_trx_commit 에 따른 입력건수 성능비교
#innodb_flush_log_at_trx_commit 에 따른 입력건수 성능비교
#innodb_flush_log_at_trx_commit 에 따른 입력건수 성능비교
#innodb_flush_log_at_trx_commit 에 따른 입력건수 성능비교
#innodb_flush_log_at_trx_commit 에 따른 입력건수 성능비교

#QUEUE사용안함
#QUEUE사용안함

#QUEUE사용안함

#SERIAL형식의 입력
#SERIAL형식의 입력
#SERIAL형식의 입력
#SERIAL형식의 입력

mysql> select sum(T2.t_cnt) from DUMMY T1, (select substr(regtime,1,17) as t_regtime, count(1) as t_cnt from RB_OCUS_POS_TEST2 group by substr(regtime,1,17)) T2;
+---------------+
| sum(T2.t_cnt) |
+---------------+
| 161297 |
+---------------+
1 row in set (0.26 sec)

mysql>

1SEC > 647.7791164658635 입력

>>begin[20190829 07:23:04(988)],end[20190829 07:23:23(968)]

1SEC > 8489.315789473684 입력

>>begin[20190829 07:25:41(568)],end[20190829 07:26:05(191)]

1SEC > 6451.88 입력

'데이타베이스 > MySQL' 카테고리의 다른 글

#LINUX,send_msg_to_queue.c (2번째) (0)	2019.10.30
#LINUX,recv_msg_from_queue.c (두번째) (0)	2019.10.30
#Queue를 이용한 MySQL입력 성능향상에 관한 글(1) (0)	2019.10.30
1달전 자료 지우는 쿼리 (0)	2019.10.29
MySQL LOCK 확인 및 해제(kill) 방법 (0)	2019.10.29

'리눅스' 카테고리의 다른 글

BIOS 부트 모드(Boot Mode)에 따른 CentOS설치시 추가 파티션 설정(/boot/efi) (0)	2021.03.31
CentOS 6. 설치가이드(파티션설정) (0)	2021.03.30
Linux - du (Disk Usage) (0)	2019.10.31
LINUX,REDIS 활용 (0)	2019.10.30
#find ./ -type f -mtime -일수 -ls (0)	2019.10.30

//pointer memory use instead of structure stack memory

#include <stdio.h>

#include <string.h>

#include <stdlib.h>

#define MAX_ADDRESS_CNT 200

struct st_basic_trade

{

char dataclass[2];

char infoclass[2];

char marketclass[1];

char stockcode[12];

char serialno[8];

char abbrstockcode[9];

char abbrstocknamekor[40];

char abbrstocknameeng[40];

char senddate[8];

char infodivisiongroupno[5];

char stockgroupid[2];

char isunittrade[1];

char exclasscode[2];

char facevaluechangeclasscode[2];

char isopenpricebasedstandardprice[1];

char isrevaluationstockreason[2];

char isstandardpricechangestock[1];

char israndomendpossibillty[1];

char ismarketalarmdangernotice[1];

char marketalarmclasscode[2];

char iscorporategovernancefine[1];

char ismanagementstock[1];

char isinsinceritypublicnewsappoint[1];

char isbackdoorlisting[1];

char istradestop[1];

char indexbusinesstypelarge[3];

char indexbusinesstypemedium[3];

char indexbusinesstypesmall[3];

char standardindustrycode[10];

char businesstypekospi200[1];

char listpricesizecode[1];

char ismanufactureindustry[1];

char iskrx100stock[1];

char isdividendindexstock[1];

char iscorporategovernanceindexstock[1];

char investorganclasscode[2];

char iskospi[1];

char iskospi100[1];

char iskospi50[1];

char iskrxsectorindexcar[1];

char iskrxsectorindexsemiconductor[1];

char iskrxsectorindexbio[1];

char iskrxsectorindexfinance[1];

char iskrxsectorindexit[1];

char iskrxsectorindexenergychemical[1];

char iskrxsectorindexsteel[1];

char iskrxsectorindexnecessary[1];

char iskrxsectorindexmediacomm[1];

char iskrxsectorindexconstruction[1];

char iskrxsectorindexfinanceservice[1];

char iskrxsectorindexstock[1];

char iskrxsectorindexship[1];

char standardprice[9];

char ydayclosepriceclasscode[1];

char ydaycloseprice[9];

char ydayaccmvolume[12];

char ydayaccmamount[18];

char uplimitprice[9];

char downlimitprice[9];

char substituteprice[9];

char facevalue[12];

};

int main(int argc, char *argv[])

{

struct st_basic_trade st_basic_trade[MAX_ADDRESS_CNT];

struct st_basic_trade *address_byte_trade1;

struct st_basic_trade *address_byte_trade2;

struct st_basic_trade *address_byte_trade_tmp;

char *address_byte[MAX_ADDRESS_CNT];//st_basic_trade structure address saving pointer array

char *address_byte_tmp;//st_basic_trade structure address saving pointer

FILE *fp=NULL;//file pointer

char rbuf[4096];//file read buffer

char tmp1[200];

char tmp2[200];

int ii,kk,continue_tmp;

int st_basic_trade_cnt;

if((fp=fopen("BATCH_A0011.dat", "rt"))==NULL)

{

return(-1);

}

//DATA MEMORY INIT

for(kk=0; kk<MAX_ADDRESS_CNT; kk++)

{

memset(&st_basic_trade[kk],0x00,sizeof(st_basic_trade[kk]));

}

//DATA LOAD FROM FILE

kk=0;

while(1)

{

memset(rbuf,0x00,sizeof(rbuf));

if(fgets(rbuf,sizeof(rbuf),fp)==NULL) break;

memcpy(&st_basic_trade[kk], rbuf, (int)sizeof(st_basic_trade[kk]));

continue_tmp=-1;

if(memcmp(st_basic_trade[kk].stockgroupid,"ST",2)==0) continue_tmp=100;

if(memcmp(st_basic_trade[kk].stockgroupid,"EF",2)==0) continue_tmp=100;

if(memcmp(st_basic_trade[kk].stockgroupid,"RT",2)==0) continue_tmp=100;

if(memcmp(st_basic_trade[kk].stockgroupid,"MF",2)==0) continue_tmp=100;

if(memcmp(st_basic_trade[kk].stockgroupid,"SC",2)==0) continue_tmp=100;

if(memcmp(st_basic_trade[kk].stockgroupid,"IF",2)==0) continue_tmp=100;

if(memcmp(st_basic_trade[kk].stockgroupid,"DR",2)==0) continue_tmp=100;

if(memcmp(st_basic_trade[kk].stockgroupid,"FS",2)==0) continue_tmp=100;

if(memcmp(st_basic_trade[kk].stockgroupid,"EN",2)==0) continue_tmp=100;

if(continue_tmp<0) continue;

kk++;

if(kk==MAX_ADDRESS_CNT) break;

}

st_basic_trade_cnt=kk;

if(fp != NULL) fclose(fp);

//POINTER MEMORY USE INSTEAD OF STRUCTURE STACK MEMORY

for(kk=0; kk<st_basic_trade_cnt; kk++)

{

address_byte[kk] = (char *)&st_basic_trade[kk];

}

//DESCENDING BY POINTER MEMORY

for(kk=0; kk<st_basic_trade_cnt; kk++)

{

for(ii=kk+1; ii<st_basic_trade_cnt; ii++)

{

address_byte_trade1 = (struct st_basic_trade *)address_byte[kk];

address_byte_trade2 = (struct st_basic_trade *)address_byte[ii];

memset(tmp1,0x00,sizeof(tmp1));

memset(tmp2,0x00,sizeof(tmp2));

sprintf(tmp1, "%.*s", (int)sizeof(address_byte_trade1->standardprice), address_byte_trade1->standardprice);

sprintf(tmp2, "%.*s", (int)sizeof(address_byte_trade2->standardprice), address_byte_trade2->standardprice);

if(atoi(tmp1) > atoi(tmp2))

{

address_byte_tmp=address_byte[kk];

address_byte[kk]=address_byte[ii];

address_byte[ii]=address_byte_tmp;

}

//RESULT DISPLAY

for(kk=0; kk<st_basic_trade_cnt; kk++)

{

address_byte_trade_tmp = (struct st_basic_trade *)address_byte[kk];

printf(

"[%.4d]:"

"(%.*s)"

"\n",

kk+1,

(int)sizeof(address_byte_trade_tmp->iskospi),address_byte_trade_tmp->iskospi,

(int)sizeof(address_byte_trade_tmp->dataclass),address_byte_trade_tmp->dataclass,

(int)sizeof(address_byte_trade_tmp->infoclass),address_byte_trade_tmp->infoclass,

(int)sizeof(address_byte_trade_tmp->serialno),address_byte_trade_tmp->serialno,

(int)sizeof(address_byte_trade_tmp->stockgroupid),address_byte_trade_tmp->stockgroupid,

(int)sizeof(address_byte_trade_tmp->abbrstockcode),address_byte_trade_tmp->abbrstockcode,

(int)sizeof(address_byte_trade_tmp->standardprice),address_byte_trade_tmp->standardprice,

(int)sizeof(address_byte_trade_tmp->ydayaccmvolume),address_byte_trade_tmp->ydayaccmvolume,

(int)sizeof(address_byte_trade_tmp->ydayaccmamount),address_byte_trade_tmp->ydayaccmamount,

(int)sizeof(address_byte_trade_tmp->uplimitprice),address_byte_trade_tmp->uplimitprice,

(int)sizeof(address_byte_trade_tmp->downlimitprice),address_byte_trade_tmp->downlimitprice,

(int)sizeof(address_byte_trade_tmp->abbrstocknameeng),address_byte_trade_tmp->abbrstocknameeng);

}

return(0);

}

/*RESULT

[0140]:(Y)(A0)(01)(00000068)(ST)(A000860 )(000035500)(000000012109)(000000000427932950)(000046150)(000024850)(KANGNAM JEVISCO )

[0141]:(Y)(A0)(01)(00000069)(ST)(A000880 )(000035550)(000000250112)(000000008841239150)(000046200)(000024900)(Hanwha )

[0142]:(Y)(A0)(01)(00000161)(ST)(A002390 )(000035800)(000000175128)(000000006200375550)(000046500)(000025100)(HANDOK )

[0143]:(Y)(A0)(01)(00000062)(ST)(A000720 )(000036000)(000000935395)(000000033665525250)(000046800)(000025200)(HyundaiEng&Const )

[0144]:(Y)(A0)(01)(00000168)(ST)(A002620 )(000037150)(000000043866)(000000001645729300)(000048250)(000026050)(JeilPharm )

[0145]:(Y)(A0)(01)(00000031)(ST)(A000180 )(000038150)(000000051172)(000000001962002000)(000049550)(000026750)(SCEHoldings )

[0146]:(Y)(A0)(01)(00000080)(ST)(A001060 )(000040300)(000000157559)(000000006374627600)(000052300)(000028250)(JWPHARMA )

[0147]:(Y)(A0)(01)(00000082)(ST)(A001067 )(000042550)(000000000536)(000000000022519300)(000055300)(000029800)(JWPHARMA(2PB) )

[0148]:(Y)(A0)(01)(00000063)(ST)(A000725 )(000043150)(000000000564)(000000000024648550)(000056000)(000030250)(HyundaiEng&Con(1P) )

[0149]:(Y)(A0)(01)(00000039)(ST)(A000270 )(000043550)(000001342543)(000000058170323500)(000056600)(000030500)(KiaMtr )

[0150]:(Y)(A0)(01)(00000147)(ST)(A002170 )(000044500)(000000010952)(000000000488631300)(000057800)(000031150)(SamyangTongsang )

[0151]:(Y)(A0)(01)(00000163)(ST)(A002420 )(000045400)(000000001276)(000000000057439100)(000059000)(000031800)(Century )

[0152]:(Y)(A0)(01)(00000126)(ST)(A001745 )(000045750)(000000001253)(000000000058412550)(000059400)(000032050)(SKNetworks(1P) )

[0153]:(Y)(A0)(01)(00000124)(ST)(A001725 )(000046950)(000000000551)(000000000025664750)(000061000)(000032900)(ShinyoungSecu(1P) )

[0154]:(Y)(A0)(01)(00000123)(ST)(A001720 )(000049550)(000000002054)(000000000101791900)(000064400)(000034700)(ShinyoungSecu )

[0155]:(Y)(A0)(01)(00000030)(ST)(A000157 )(000050500)(000000000118)(000000000005902400)(000065600)(000035400)(DOOSAN(2PB) )

[0156]:(Y)(A0)(01)(00000067)(ST)(A000850 )(000050800)(000000001558)(000000000079929400)(000066000)(000035600)(HMT )

[0157]:(Y)(A0)(01)(00000029)(ST)(A000155 )(000051000)(000000001053)(000000000053774400)(000066300)(000035700)(DOOSAN(1P) )

[0158]:(Y)(A0)(01)(00000192)(ST)(A003030 )(000051800)(000000009657)(000000000494291400)(000067300)(000036300)(SeAhStl )

[0159]:(Y)(A0)(01)(00000073)(ST)(A000950 )(000053000)(000000001352)(000000000072137200)(000068900)(000037100)(Chonbang )

[0160]:(Y)(A0)(01)(00000156)(ST)(A002320 )(000053200)(000000053672)(000000002833688300)(000069100)(000037300)(HanjinTrnspt )

[0161]:(Y)(A0)(01)(00000196)(ST)(A003080 )(000055200)(000000000851)(000000000046476300)(000071700)(000038700)(SungboChem )

[0162]:(Y)(A0)(01)(00000083)(ST)(A001070 )(000056400)(000000001586)(000000000088415000)(000073300)(000039500)(TaihanTextl )

[0163]:(Y)(A0)(01)(00000137)(ST)(A001940 )(000058300)(000000002805)(000000000163564100)(000075700)(000040900)(KISCO Holdings )

[0164]:(Y)(A0)(01)(00000114)(ST)(A001530 )(000059200)(000000001443)(000000000085351600)(000076900)(000041500)(Dongil )

[0165]:(Y)(A0)(01)(00000197)(ST)(A003090 )(000063200)(000000007172)(000000000457728500)(000082100)(000044300)(Daewoong )

[0166]:(Y)(A0)(01)(00000057)(ST)(A000650 )(000063600)(000000000824)(000000000053056100)(000082600)(000044600)(ChunilExp )

[0167]:(Y)(A0)(01)(00000140)(ST)(A002020 )(000070600)(000000044170)(000000003133398600)(000091700)(000049500)(KOLON CORP )

[0168]:(Y)(A0)(01)(00000028)(ST)(A000150 )(000072400)(000000117697)(000000008567840400)(000094100)(000050700)(DOOSAN )

[0169]:(Y)(A0)(01)(00000055)(ST)(A000590 )(000072600)(000000001684)(000000000122223400)(000094300)(000050900)(CSHOLDINGS )

[0170]:(Y)(A0)(01)(00000032)(ST)(A000210 )(000077600)(000000148934)(000000011570941400)(000100500)(000054400)(DaelimInd )

[0171]:(Y)(A0)(01)(00000020)(ST)(A000075 )(000077800)(000000000177)(000000000013515400)(000101000)(000054500)(SAMYANGHOLDINGS(1P) )

[0172]:(Y)(A0)(01)(00000048)(ST)(A000480 )(000080600)(000000000412)(000000000033291100)(000104500)(000056500)(ChosunRefrctr )

[0173]:(Y)(A0)(01)(00000179)(ST)(A002795 )(000087500)(000000052984)(000000004654231400)(000113500)(000061300)(AmoreG(1P) )

[0174]:(Y)(A0)(01)(00000205)(ST)(A003300 )(000094800)(000000020468)(000000001954590400)(000123000)(000066400)(HanilCement )

[0175]:(Y)(A0)(01)(00000142)(ST)(A002030 )(000098300)(000000000761)(000000000074790600)(000127500)(000068900)(ASIA HOLDINGS )

[0176]:(Y)(A0)(01)(00000198)(ST)(A003120 )(000107500)(000000000483)(000000000051978500)(000139500)(000075500)(IlsungPharm )

[0177]:(Y)(A0)(01)(00000119)(ST)(A001630 )(000120000)(000000020708)(000000002442273500)(000156000)(000084000)(CHONGKUNDANG HOLDINGS )

[0178]:(Y)(A0)(01)(00000079)(ST)(A001045 )(000135000)(000000002881)(000000000387653500)(000175500)(000094500)(CJ(1P) )

[0179]:(Y)(A0)(01)(00000200)(ST)(A003200 )(000148000)(000000001833)(000000000268996500)(000192000)(000104000)(IlshinSpng )

[0180]:(Y)(A0)(01)(00000178)(ST)(A002790 )(000161000)(000000715462)(000000113395522000)(000209000)(000113000)(AmoreG )

[0181]:(Y)(A0)(01)(00000167)(ST)(A002600 )(000161000)(000000000169)(000000000027542500)(000209000)(000113000)(CHOHEUNG )

[0182]:(Y)(A0)(01)(00000019)(ST)(A000070 )(000177000)(000000028579)(000000005043584000)(000230000)(000124000)(SAMYANGHOLDINGS )

[0183]:(Y)(A0)(01)(00000182)(ST)(A002840 )(000179000)(000000000063)(000000000011328500)(000232500)(000125500)(MiwonComcl )

[0184]:(Y)(A0)(01)(00000086)(ST)(A001130 )(000184000)(000000000647)(000000000119095000)(000239000)(000129000)(DaehanFlrMill )

[0185]:(Y)(A0)(01)(00000024)(ST)(A000105 )(000190000)(000000000029)(000000000005484500)(000247000)(000133000)(Yuhan(1P) )

[0186]:(Y)(A0)(01)(00000066)(ST)(A000815 )(000195000)(000000003175)(000000000613795000)(000253500)(000136500)(SamsungF&MIns(1P) )

[0187]:(Y)(A0)(01)(00000105)(ST)(A001465 )(000198500)(000000000076)(000000000015081500)(000258000)(000139000)(BYC(1P) )

[0188]:(Y)(A0)(01)(00000017)(ST)(A000050 )(000203000)(000000001581)(000000000318739000)(000263500)(000142500)(Kyungbang )

[0189]:(Y)(A0)(01)(00000056)(ST)(A000640 )(000214000)(000000013643)(000000002898145500)(000278000)(000150000)(Donga Socio Holdings )

[0190]:(Y)(A0)(01)(00000025)(ST)(A000120 )(000216000)(000000029404)(000000006392050500)(000280500)(000151500)(CJ korea express )

[0191]:(Y)(A0)(01)(00000078)(ST)(A001040 )(000281500)(000000039434)(000000011175365500)(000365500)(000197500)(CJ )

[0192]:(Y)(A0)(01)(00000065)(ST)(A000810 )(000303500)(000000038064)(000000011500917820)(000394500)(000212500)(SamsungF&MIns )

[0193]:(Y)(A0)(01)(00000023)(ST)(A000100 )(000330000)(000000030710)(000000010129506500)(000429000)(000231000)(Yuhan )

[0194]:(Y)(A0)(01)(00000160)(ST)(A002380 )(000432000)(000000014528)(000000006278496500)(000561000)(000302500)(KCC )

[0195]:(Y)(A0)(01)(00000187)(ST)(A002960 )(000485000)(000000000772)(000000000378426000)(000630000)(000339500)(HankookShellOil )

[0196]:(Y)(A0)(01)(00000104)(ST)(A001460 )(000532000)(000000000326)(000000000172720000)(000691000)(000373000)(BYC )

[0197]:(Y)(A0)(01)(00000059)(ST)(A000670 )(000931000)(000000001930)(000000001790511000)(001210000)(000652000)(Youngpoong )

[0198]:(Y)(A0)(01)(00000153)(ST)(A002270 )(000943000)(000000003189)(000000002984664000)(001225000)(000661000)(LotteFood )

[0199]:(Y)(A0)(01)(00000203)(ST)(A003240 )(000986000)(000000000664)(000000000656189000)(001281000)(000691000)(TaekwangInd )

[0200]:(Y)(A0)(01)(00000134)(ST)(A001800 )(001028000)(000000010402)(000000010702212000)(001336000)(000720000)(ORION )

bash-3.1$

*/

'c 언어 > 중급과정' 카테고리의 다른 글

[카카오 코딩테스트] 자연수 자릿수의 합 구하기 (0)	2019.10.30
[카카오 코딩테스트] 다트 게임 (0)	2019.10.30
OS Common, strstr로 해결이 안되는 부분에서는 strchr로 (0)	2019.10.30
gcc -o sample sample.o -lm 시에 m의 의미는? (0)	2019.10.29
[Tip] semop() 세마포어 값을 변경 (0)	2019.10.29

#include <stdio.h>

#include <string.h>

typedef struct ____HM

{

int hh;

int mm;

}HM;

//시간(HH:MM)10:00에서 unit(MINUTE)만큼 뺄때에 구해지는 HH:MM을 계산

void ____get_hour_min(HM *sihm, int unit)

{

int divide_hh, divide_mm, share;

divide_hh = (int)(unit / 60);

divide_mm = unit - (int)(unit / 60) * 60;

if(divide_mm > 0) share = 1;

else share = 0;

sihm->hh = 10 - divide_hh - share;

if(share==1) sihm->mm = 60 - divide_mm;

else sihm->mm = divide_mm;

}

int main(int argc, char *argv[])

{

HM sihm;

int kk;

//10:00에서 61분에서 300분까지를 빼서 나오는결과를 출력

for(kk=61; kk<300; kk++)

{

____get_hour_min( &sihm, kk);

printf("MINUTE(%.6d),sihm.hh(%d),sihm.mm(%d)=HH:MM(%02d:%02d)\n", kk, sihm.hh, sihm.mm, sihm.hh, sihm.mm);

}

return(0);

}

/*

bash-3.1$ gcc -c 61.c

bash-3.1$

bash-3.1$ gcc -o 61 61.o

bash-3.1$

bash-3.1$ 61

MINUTE(000061),sihm.hh(08),sihm.mm(59)=HH:MM(08:59)

MINUTE(000062),sihm.hh(08),sihm.mm(58)=HH:MM(08:58)

MINUTE(000063),sihm.hh(08),sihm.mm(57)=HH:MM(08:57)

MINUTE(000064),sihm.hh(08),sihm.mm(56)=HH:MM(08:56)

MINUTE(000065),sihm.hh(08),sihm.mm(55)=HH:MM(08:55)

MINUTE(000066),sihm.hh(08),sihm.mm(54)=HH:MM(08:54)

MINUTE(000067),sihm.hh(08),sihm.mm(53)=HH:MM(08:53)

MINUTE(000068),sihm.hh(08),sihm.mm(52)=HH:MM(08:52)

MINUTE(000069),sihm.hh(08),sihm.mm(51)=HH:MM(08:51)

MINUTE(000070),sihm.hh(08),sihm.mm(50)=HH:MM(08:50)

MINUTE(000071),sihm.hh(08),sihm.mm(49)=HH:MM(08:49)

MINUTE(000072),sihm.hh(08),sihm.mm(48)=HH:MM(08:48)

MINUTE(000073),sihm.hh(08),sihm.mm(47)=HH:MM(08:47)

MINUTE(000074),sihm.hh(08),sihm.mm(46)=HH:MM(08:46)

MINUTE(000075),sihm.hh(08),sihm.mm(45)=HH:MM(08:45)

MINUTE(000076),sihm.hh(08),sihm.mm(44)=HH:MM(08:44)

MINUTE(000077),sihm.hh(08),sihm.mm(43)=HH:MM(08:43)

MINUTE(000078),sihm.hh(08),sihm.mm(42)=HH:MM(08:42)

MINUTE(000079),sihm.hh(08),sihm.mm(41)=HH:MM(08:41)

MINUTE(000080),sihm.hh(08),sihm.mm(40)=HH:MM(08:40)

MINUTE(000081),sihm.hh(08),sihm.mm(39)=HH:MM(08:39)

MINUTE(000082),sihm.hh(08),sihm.mm(38)=HH:MM(08:38)

MINUTE(000083),sihm.hh(08),sihm.mm(37)=HH:MM(08:37)

MINUTE(000084),sihm.hh(08),sihm.mm(36)=HH:MM(08:36)

MINUTE(000085),sihm.hh(08),sihm.mm(35)=HH:MM(08:35)

MINUTE(000086),sihm.hh(08),sihm.mm(34)=HH:MM(08:34)

MINUTE(000087),sihm.hh(08),sihm.mm(33)=HH:MM(08:33)

MINUTE(000088),sihm.hh(08),sihm.mm(32)=HH:MM(08:32)

MINUTE(000089),sihm.hh(08),sihm.mm(31)=HH:MM(08:31)

MINUTE(000090),sihm.hh(08),sihm.mm(30)=HH:MM(08:30)

MINUTE(000091),sihm.hh(08),sihm.mm(29)=HH:MM(08:29)

MINUTE(000092),sihm.hh(08),sihm.mm(28)=HH:MM(08:28)

MINUTE(000093),sihm.hh(08),sihm.mm(27)=HH:MM(08:27)

MINUTE(000094),sihm.hh(08),sihm.mm(26)=HH:MM(08:26)

MINUTE(000095),sihm.hh(08),sihm.mm(25)=HH:MM(08:25)

MINUTE(000096),sihm.hh(08),sihm.mm(24)=HH:MM(08:24)

MINUTE(000097),sihm.hh(08),sihm.mm(23)=HH:MM(08:23)

MINUTE(000098),sihm.hh(08),sihm.mm(22)=HH:MM(08:22)

MINUTE(000099),sihm.hh(08),sihm.mm(21)=HH:MM(08:21)

MINUTE(000100),sihm.hh(08),sihm.mm(20)=HH:MM(08:20)

MINUTE(000101),sihm.hh(08),sihm.mm(19)=HH:MM(08:19)

MINUTE(000102),sihm.hh(08),sihm.mm(18)=HH:MM(08:18)

MINUTE(000103),sihm.hh(08),sihm.mm(17)=HH:MM(08:17)

MINUTE(000104),sihm.hh(08),sihm.mm(16)=HH:MM(08:16)

MINUTE(000105),sihm.hh(08),sihm.mm(15)=HH:MM(08:15)

MINUTE(000106),sihm.hh(08),sihm.mm(14)=HH:MM(08:14)

MINUTE(000107),sihm.hh(08),sihm.mm(13)=HH:MM(08:13)

MINUTE(000108),sihm.hh(08),sihm.mm(12)=HH:MM(08:12)

MINUTE(000109),sihm.hh(08),sihm.mm(11)=HH:MM(08:11)

MINUTE(000110),sihm.hh(08),sihm.mm(10)=HH:MM(08:10)

MINUTE(000111),sihm.hh(08),sihm.mm(09)=HH:MM(08:09)

MINUTE(000112),sihm.hh(08),sihm.mm(08)=HH:MM(08:08)

MINUTE(000113),sihm.hh(08),sihm.mm(07)=HH:MM(08:07)

MINUTE(000114),sihm.hh(08),sihm.mm(06)=HH:MM(08:06)

MINUTE(000115),sihm.hh(08),sihm.mm(05)=HH:MM(08:05)

MINUTE(000116),sihm.hh(08),sihm.mm(04)=HH:MM(08:04)

MINUTE(000117),sihm.hh(08),sihm.mm(03)=HH:MM(08:03)

MINUTE(000118),sihm.hh(08),sihm.mm(02)=HH:MM(08:02)

MINUTE(000119),sihm.hh(08),sihm.mm(01)=HH:MM(08:01)

MINUTE(000120),sihm.hh(08),sihm.mm(00)=HH:MM(08:00)

MINUTE(000121),sihm.hh(07),sihm.mm(59)=HH:MM(07:59)

MINUTE(000122),sihm.hh(07),sihm.mm(58)=HH:MM(07:58)

MINUTE(000123),sihm.hh(07),sihm.mm(57)=HH:MM(07:57)

MINUTE(000124),sihm.hh(07),sihm.mm(56)=HH:MM(07:56)

MINUTE(000125),sihm.hh(07),sihm.mm(55)=HH:MM(07:55)

MINUTE(000126),sihm.hh(07),sihm.mm(54)=HH:MM(07:54)

MINUTE(000127),sihm.hh(07),sihm.mm(53)=HH:MM(07:53)

MINUTE(000128),sihm.hh(07),sihm.mm(52)=HH:MM(07:52)

MINUTE(000129),sihm.hh(07),sihm.mm(51)=HH:MM(07:51)

MINUTE(000130),sihm.hh(07),sihm.mm(50)=HH:MM(07:50)

MINUTE(000131),sihm.hh(07),sihm.mm(49)=HH:MM(07:49)

MINUTE(000132),sihm.hh(07),sihm.mm(48)=HH:MM(07:48)

MINUTE(000133),sihm.hh(07),sihm.mm(47)=HH:MM(07:47)

MINUTE(000134),sihm.hh(07),sihm.mm(46)=HH:MM(07:46)

MINUTE(000135),sihm.hh(07),sihm.mm(45)=HH:MM(07:45)

MINUTE(000136),sihm.hh(07),sihm.mm(44)=HH:MM(07:44)

MINUTE(000137),sihm.hh(07),sihm.mm(43)=HH:MM(07:43)

MINUTE(000138),sihm.hh(07),sihm.mm(42)=HH:MM(07:42)

MINUTE(000139),sihm.hh(07),sihm.mm(41)=HH:MM(07:41)

MINUTE(000140),sihm.hh(07),sihm.mm(40)=HH:MM(07:40)

MINUTE(000141),sihm.hh(07),sihm.mm(39)=HH:MM(07:39)

MINUTE(000142),sihm.hh(07),sihm.mm(38)=HH:MM(07:38)

MINUTE(000143),sihm.hh(07),sihm.mm(37)=HH:MM(07:37)

MINUTE(000144),sihm.hh(07),sihm.mm(36)=HH:MM(07:36)

MINUTE(000145),sihm.hh(07),sihm.mm(35)=HH:MM(07:35)

MINUTE(000146),sihm.hh(07),sihm.mm(34)=HH:MM(07:34)

MINUTE(000147),sihm.hh(07),sihm.mm(33)=HH:MM(07:33)

MINUTE(000148),sihm.hh(07),sihm.mm(32)=HH:MM(07:32)

MINUTE(000149),sihm.hh(07),sihm.mm(31)=HH:MM(07:31)

MINUTE(000150),sihm.hh(07),sihm.mm(30)=HH:MM(07:30)

MINUTE(000151),sihm.hh(07),sihm.mm(29)=HH:MM(07:29)

MINUTE(000152),sihm.hh(07),sihm.mm(28)=HH:MM(07:28)

MINUTE(000153),sihm.hh(07),sihm.mm(27)=HH:MM(07:27)

MINUTE(000154),sihm.hh(07),sihm.mm(26)=HH:MM(07:26)

MINUTE(000155),sihm.hh(07),sihm.mm(25)=HH:MM(07:25)

MINUTE(000156),sihm.hh(07),sihm.mm(24)=HH:MM(07:24)

MINUTE(000157),sihm.hh(07),sihm.mm(23)=HH:MM(07:23)

MINUTE(000158),sihm.hh(07),sihm.mm(22)=HH:MM(07:22)

MINUTE(000159),sihm.hh(07),sihm.mm(21)=HH:MM(07:21)

MINUTE(000160),sihm.hh(07),sihm.mm(20)=HH:MM(07:20)

MINUTE(000161),sihm.hh(07),sihm.mm(19)=HH:MM(07:19)

MINUTE(000162),sihm.hh(07),sihm.mm(18)=HH:MM(07:18)

MINUTE(000163),sihm.hh(07),sihm.mm(17)=HH:MM(07:17)

MINUTE(000164),sihm.hh(07),sihm.mm(16)=HH:MM(07:16)

MINUTE(000165),sihm.hh(07),sihm.mm(15)=HH:MM(07:15)

MINUTE(000166),sihm.hh(07),sihm.mm(14)=HH:MM(07:14)

MINUTE(000167),sihm.hh(07),sihm.mm(13)=HH:MM(07:13)

MINUTE(000168),sihm.hh(07),sihm.mm(12)=HH:MM(07:12)

MINUTE(000169),sihm.hh(07),sihm.mm(11)=HH:MM(07:11)

MINUTE(000170),sihm.hh(07),sihm.mm(10)=HH:MM(07:10)

MINUTE(000171),sihm.hh(07),sihm.mm(09)=HH:MM(07:09)

MINUTE(000172),sihm.hh(07),sihm.mm(08)=HH:MM(07:08)

MINUTE(000173),sihm.hh(07),sihm.mm(07)=HH:MM(07:07)

MINUTE(000174),sihm.hh(07),sihm.mm(06)=HH:MM(07:06)

MINUTE(000175),sihm.hh(07),sihm.mm(05)=HH:MM(07:05)

MINUTE(000176),sihm.hh(07),sihm.mm(04)=HH:MM(07:04)

MINUTE(000177),sihm.hh(07),sihm.mm(03)=HH:MM(07:03)

MINUTE(000178),sihm.hh(07),sihm.mm(02)=HH:MM(07:02)

MINUTE(000179),sihm.hh(07),sihm.mm(01)=HH:MM(07:01)

MINUTE(000180),sihm.hh(07),sihm.mm(00)=HH:MM(07:00)

MINUTE(000181),sihm.hh(06),sihm.mm(59)=HH:MM(06:59)

MINUTE(000182),sihm.hh(06),sihm.mm(58)=HH:MM(06:58)

MINUTE(000183),sihm.hh(06),sihm.mm(57)=HH:MM(06:57)

MINUTE(000184),sihm.hh(06),sihm.mm(56)=HH:MM(06:56)

MINUTE(000185),sihm.hh(06),sihm.mm(55)=HH:MM(06:55)

MINUTE(000186),sihm.hh(06),sihm.mm(54)=HH:MM(06:54)

MINUTE(000187),sihm.hh(06),sihm.mm(53)=HH:MM(06:53)

MINUTE(000188),sihm.hh(06),sihm.mm(52)=HH:MM(06:52)

MINUTE(000189),sihm.hh(06),sihm.mm(51)=HH:MM(06:51)

MINUTE(000190),sihm.hh(06),sihm.mm(50)=HH:MM(06:50)

MINUTE(000191),sihm.hh(06),sihm.mm(49)=HH:MM(06:49)

MINUTE(000192),sihm.hh(06),sihm.mm(48)=HH:MM(06:48)

MINUTE(000193),sihm.hh(06),sihm.mm(47)=HH:MM(06:47)

MINUTE(000194),sihm.hh(06),sihm.mm(46)=HH:MM(06:46)

MINUTE(000195),sihm.hh(06),sihm.mm(45)=HH:MM(06:45)

MINUTE(000196),sihm.hh(06),sihm.mm(44)=HH:MM(06:44)

MINUTE(000197),sihm.hh(06),sihm.mm(43)=HH:MM(06:43)

MINUTE(000198),sihm.hh(06),sihm.mm(42)=HH:MM(06:42)

MINUTE(000199),sihm.hh(06),sihm.mm(41)=HH:MM(06:41)

MINUTE(000200),sihm.hh(06),sihm.mm(40)=HH:MM(06:40)

MINUTE(000201),sihm.hh(06),sihm.mm(39)=HH:MM(06:39)

MINUTE(000202),sihm.hh(06),sihm.mm(38)=HH:MM(06:38)

MINUTE(000203),sihm.hh(06),sihm.mm(37)=HH:MM(06:37)

MINUTE(000204),sihm.hh(06),sihm.mm(36)=HH:MM(06:36)

MINUTE(000205),sihm.hh(06),sihm.mm(35)=HH:MM(06:35)

MINUTE(000206),sihm.hh(06),sihm.mm(34)=HH:MM(06:34)

MINUTE(000207),sihm.hh(06),sihm.mm(33)=HH:MM(06:33)

MINUTE(000208),sihm.hh(06),sihm.mm(32)=HH:MM(06:32)

MINUTE(000209),sihm.hh(06),sihm.mm(31)=HH:MM(06:31)

MINUTE(000210),sihm.hh(06),sihm.mm(30)=HH:MM(06:30)

MINUTE(000211),sihm.hh(06),sihm.mm(29)=HH:MM(06:29)

MINUTE(000212),sihm.hh(06),sihm.mm(28)=HH:MM(06:28)

MINUTE(000213),sihm.hh(06),sihm.mm(27)=HH:MM(06:27)

MINUTE(000214),sihm.hh(06),sihm.mm(26)=HH:MM(06:26)

MINUTE(000215),sihm.hh(06),sihm.mm(25)=HH:MM(06:25)

MINUTE(000216),sihm.hh(06),sihm.mm(24)=HH:MM(06:24)

MINUTE(000217),sihm.hh(06),sihm.mm(23)=HH:MM(06:23)

MINUTE(000218),sihm.hh(06),sihm.mm(22)=HH:MM(06:22)

MINUTE(000219),sihm.hh(06),sihm.mm(21)=HH:MM(06:21)

MINUTE(000220),sihm.hh(06),sihm.mm(20)=HH:MM(06:20)

MINUTE(000221),sihm.hh(06),sihm.mm(19)=HH:MM(06:19)

MINUTE(000222),sihm.hh(06),sihm.mm(18)=HH:MM(06:18)

MINUTE(000223),sihm.hh(06),sihm.mm(17)=HH:MM(06:17)

MINUTE(000224),sihm.hh(06),sihm.mm(16)=HH:MM(06:16)

MINUTE(000225),sihm.hh(06),sihm.mm(15)=HH:MM(06:15)

MINUTE(000226),sihm.hh(06),sihm.mm(14)=HH:MM(06:14)

MINUTE(000227),sihm.hh(06),sihm.mm(13)=HH:MM(06:13)

MINUTE(000228),sihm.hh(06),sihm.mm(12)=HH:MM(06:12)

MINUTE(000229),sihm.hh(06),sihm.mm(11)=HH:MM(06:11)

MINUTE(000230),sihm.hh(06),sihm.mm(10)=HH:MM(06:10)

MINUTE(000231),sihm.hh(06),sihm.mm(09)=HH:MM(06:09)

MINUTE(000232),sihm.hh(06),sihm.mm(08)=HH:MM(06:08)

MINUTE(000233),sihm.hh(06),sihm.mm(07)=HH:MM(06:07)

MINUTE(000234),sihm.hh(06),sihm.mm(06)=HH:MM(06:06)

MINUTE(000235),sihm.hh(06),sihm.mm(05)=HH:MM(06:05)

MINUTE(000236),sihm.hh(06),sihm.mm(04)=HH:MM(06:04)

MINUTE(000237),sihm.hh(06),sihm.mm(03)=HH:MM(06:03)

MINUTE(000238),sihm.hh(06),sihm.mm(02)=HH:MM(06:02)

MINUTE(000239),sihm.hh(06),sihm.mm(01)=HH:MM(06:01)

MINUTE(000240),sihm.hh(06),sihm.mm(00)=HH:MM(06:00)

MINUTE(000241),sihm.hh(05),sihm.mm(59)=HH:MM(05:59)

MINUTE(000242),sihm.hh(05),sihm.mm(58)=HH:MM(05:58)

MINUTE(000243),sihm.hh(05),sihm.mm(57)=HH:MM(05:57)

MINUTE(000244),sihm.hh(05),sihm.mm(56)=HH:MM(05:56)

MINUTE(000245),sihm.hh(05),sihm.mm(55)=HH:MM(05:55)

MINUTE(000246),sihm.hh(05),sihm.mm(54)=HH:MM(05:54)

MINUTE(000247),sihm.hh(05),sihm.mm(53)=HH:MM(05:53)

MINUTE(000248),sihm.hh(05),sihm.mm(52)=HH:MM(05:52)

MINUTE(000249),sihm.hh(05),sihm.mm(51)=HH:MM(05:51)

MINUTE(000250),sihm.hh(05),sihm.mm(50)=HH:MM(05:50)

MINUTE(000251),sihm.hh(05),sihm.mm(49)=HH:MM(05:49)

MINUTE(000252),sihm.hh(05),sihm.mm(48)=HH:MM(05:48)

MINUTE(000253),sihm.hh(05),sihm.mm(47)=HH:MM(05:47)

MINUTE(000254),sihm.hh(05),sihm.mm(46)=HH:MM(05:46)

MINUTE(000255),sihm.hh(05),sihm.mm(45)=HH:MM(05:45)

MINUTE(000256),sihm.hh(05),sihm.mm(44)=HH:MM(05:44)

MINUTE(000257),sihm.hh(05),sihm.mm(43)=HH:MM(05:43)

MINUTE(000258),sihm.hh(05),sihm.mm(42)=HH:MM(05:42)

MINUTE(000259),sihm.hh(05),sihm.mm(41)=HH:MM(05:41)

MINUTE(000260),sihm.hh(05),sihm.mm(40)=HH:MM(05:40)

MINUTE(000261),sihm.hh(05),sihm.mm(39)=HH:MM(05:39)

MINUTE(000262),sihm.hh(05),sihm.mm(38)=HH:MM(05:38)

MINUTE(000263),sihm.hh(05),sihm.mm(37)=HH:MM(05:37)

MINUTE(000264),sihm.hh(05),sihm.mm(36)=HH:MM(05:36)

MINUTE(000265),sihm.hh(05),sihm.mm(35)=HH:MM(05:35)

MINUTE(000266),sihm.hh(05),sihm.mm(34)=HH:MM(05:34)

MINUTE(000267),sihm.hh(05),sihm.mm(33)=HH:MM(05:33)

MINUTE(000268),sihm.hh(05),sihm.mm(32)=HH:MM(05:32)

MINUTE(000269),sihm.hh(05),sihm.mm(31)=HH:MM(05:31)

MINUTE(000270),sihm.hh(05),sihm.mm(30)=HH:MM(05:30)

MINUTE(000271),sihm.hh(05),sihm.mm(29)=HH:MM(05:29)

MINUTE(000272),sihm.hh(05),sihm.mm(28)=HH:MM(05:28)

MINUTE(000273),sihm.hh(05),sihm.mm(27)=HH:MM(05:27)

MINUTE(000274),sihm.hh(05),sihm.mm(26)=HH:MM(05:26)

MINUTE(000275),sihm.hh(05),sihm.mm(25)=HH:MM(05:25)

MINUTE(000276),sihm.hh(05),sihm.mm(24)=HH:MM(05:24)

MINUTE(000277),sihm.hh(05),sihm.mm(23)=HH:MM(05:23)

MINUTE(000278),sihm.hh(05),sihm.mm(22)=HH:MM(05:22)

MINUTE(000279),sihm.hh(05),sihm.mm(21)=HH:MM(05:21)

MINUTE(000280),sihm.hh(05),sihm.mm(20)=HH:MM(05:20)

MINUTE(000281),sihm.hh(05),sihm.mm(19)=HH:MM(05:19)

MINUTE(000282),sihm.hh(05),sihm.mm(18)=HH:MM(05:18)

MINUTE(000283),sihm.hh(05),sihm.mm(17)=HH:MM(05:17)

MINUTE(000284),sihm.hh(05),sihm.mm(16)=HH:MM(05:16)

MINUTE(000285),sihm.hh(05),sihm.mm(15)=HH:MM(05:15)

MINUTE(000286),sihm.hh(05),sihm.mm(14)=HH:MM(05:14)

MINUTE(000287),sihm.hh(05),sihm.mm(13)=HH:MM(05:13)

MINUTE(000288),sihm.hh(05),sihm.mm(12)=HH:MM(05:12)

MINUTE(000289),sihm.hh(05),sihm.mm(11)=HH:MM(05:11)

MINUTE(000290),sihm.hh(05),sihm.mm(10)=HH:MM(05:10)

MINUTE(000291),sihm.hh(05),sihm.mm(09)=HH:MM(05:09)

MINUTE(000292),sihm.hh(05),sihm.mm(08)=HH:MM(05:08)

MINUTE(000293),sihm.hh(05),sihm.mm(07)=HH:MM(05:07)

MINUTE(000294),sihm.hh(05),sihm.mm(06)=HH:MM(05:06)

MINUTE(000295),sihm.hh(05),sihm.mm(05)=HH:MM(05:05)

MINUTE(000296),sihm.hh(05),sihm.mm(04)=HH:MM(05:04)

MINUTE(000297),sihm.hh(05),sihm.mm(03)=HH:MM(05:03)

MINUTE(000298),sihm.hh(05),sihm.mm(02)=HH:MM(05:02)

MINUTE(000299),sihm.hh(05),sihm.mm(01)=HH:MM(05:01)

bash-3.1$

*/

'c 언어 > 초급과정' 카테고리의 다른 글

printf () 함수 활용 (0)	2019.10.31
소수점 2째자리에서 반올림 (0)	2019.10.31
[C언어] Header File 한번만 포함하기. (0)	2019.10.31
WINDOWS, 키보드 주므르기(102) (0)	2019.10.31
WINDOWS, 키보드 주므르기(101) (0)	2019.10.31

gcc -o sample sample.o -lm 시에 m의 의미는?

라이브러리파일을 찾기위한 하나의 INDEX 문자열이다.

#include <math.h> 는 헤더이고, 오브젝트는 libm.a입니다.

여기에서, lib와 .a사이에 문자열스트링을 가지고 LINK시에 파일을 참조해서 LINK합니다.

예를 들어 다음과 같은 함수의 프로토타입은 math.h에 선언되어져 있어서 compile시에 성공적으로 수행되지만,

실제 LINK에는 라이브러리 파일의 오브젝트를 참조하기때문에 헤더와 라이브러리 오브젝트는 분리되어 있습니다.

ㅡㅡㅡㅡㅡㅡㅡㅡsin함수의 프로토타입(math.h에 선언되어져 있습니다.)ㅡㅡㅡㅡㅡㅡ

double sin(double x); sine 계산

float sinf(float x); sine 계산

long double sinl(long double x); sine 계산

입력 매개 변수 리스트 : x radian

반환 값 : sine 값

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

sin함수의 구현은 libm.a에 바이너리형태로 구현되어 있습니다.

(오브젝트파일 -> 아카이브파일로 묶여있음)

bash-3.1$

bash-3.1$ find ./ -name libm.*

find: `./Documents and Settings': Permission denied

./MinGW/lib/libm.a (반드시 LINK할 디렉토리는 Makefile PATH에 설정되어 있어야 합니다.

find: `./Program Files/Windows NT/\272\270\301\266\307\301\267\316\261\327\267\245': Permission denied

find: File system loop detected; `./ProgramData/Application Data' is part of the same file system loop as `./ProgramData'.

find: `./ProgramData/Desktop': Permission denied

find: `./ProgramData/Documents': Permission denied

find: `./ProgramData/Favorites': Permission denied

find: `./ProgramData/Microsoft/Diagnosis/SoftLanding': Permission denied

find: `./ProgramData/Microsoft/Diagnosis/SoftLandingStage': Permission denied

find: `./ProgramData/Microsoft/Windows/Start Menu/\307\301\267\316\261\327\267\245': Permission denied

find: `./ProgramData/Start Menu': Permission denied

find: `./ProgramData/Templates': Permission denied

find: `./ProgramData/\271\331\305\301 \310\255\270\351': Permission denied

find: `./ProgramData/\275\303\300\333 \270\336\264\272': Permission denied

find: `./System Volume Information': Permission denied

find: File system loop detected; `./Users/All Users/Application Data' is part of the same file system loop as `./Users/All Users'.

find: `./Users/All Users/Desktop': Permission denied

find: `./Users/All Users/Documents': Permission denied

find: `./Users/All Users/Favorites': Permission denied

find: `./Users/All Users/Microsoft/Diagnosis/SoftLanding': Permission denied

find: `./Users/All Users/Microsoft/Diagnosis/SoftLandingStage': Permission denied

find: `./Users/All Users/Microsoft/Windows/Start Menu/\307\301\267\316\261\327\267\245': Permission denied

find: `./Users/All Users/Start Menu': Permission denied

find: `./Users/All Users/Templates': Permission denied

find: `./Users/All Users/\271\331\305\301 \310\255\270\351': Permission denied

find: `./Users/All Users/\275\303\300\333 \270\336\264\272': Permission denied

find: File system loop detected; `./Users/Default/AppData/Local/Application Data' is part of the same file system loop as `./Users/Default/AppData/Local'.

find: `./Users/Default/AppData/Local/History': Permission denied

find: `./Users/Default/AppData/Local/Temporary Internet Files': Permission denied

find: `./Users/Default/AppData/Roaming/Microsoft/Windows/Start Menu/\307\301\267\316\261\327\267\245': Permission denied

find: `./Users/Default/Application Data': Permission denied

find: `./Users/Default/Cookies': Permission denied

find: `./Users/Default/Documents/My Music': Permission denied

find: `./Users/Default/Documents/My Pictures': Permission denied

find: `./Users/Default/Documents/My Videos': Permission denied

find: `./Users/Default/Local Settings': Permission denied

find: `./Users/Default/My Documents': Permission denied

find: `./Users/Default/NetHood': Permission denied

find: `./Users/Default/PrintHood': Permission denied

find: `./Users/Default/Recent': Permission denied

find: `./Users/Default/SendTo': Permission denied

find: `./Users/Default/Start Menu': Permission denied

find: `./Users/Default/Templates': Permission denied

find: `./Users/Default/\275\303\300\333 \270\336\264\272': Permission denied

find: `./Users/Default User': Permission denied

find: `./Users/Public/Documents/My Music': Permission denied

find: `./Users/Public/Documents/My Pictures': Permission denied

find: `./Users/Public/Documents/My Videos': Permission denied

find: `./Windows/CSC/v2.0.6': Permission denied

'c 언어 > 중급과정' 카테고리의 다른 글

[카카오 코딩테스트] 자연수 자릿수의 합 구하기 (0)	2019.10.30
[카카오 코딩테스트] 다트 게임 (0)	2019.10.30
OS Common, strstr로 해결이 안되는 부분에서는 strchr로 (0)	2019.10.30
pointer memory use instead of structure stack memory (0)	2019.10.29
[Tip] semop() 세마포어 값을 변경 (0)	2019.10.29

/*

LINUX,SERVER,SELECT(RECV),SELECT(SEND)

*/

#include <stdio.h>

#include <fcntl.h>

#include <stdlib.h>

#include <signal.h>

#include <sys/socket.h>

#include <sys/file.h>

#include <netinet/in.h>

#include <string.h>

#define MAXLINE 512

#define MAX_SOCK 64

char *escapechar = "exit";

int maxfdp1;

int g_num_chat = 0;

int s;

int client_s[MAX_SOCK];

static int getmax(int);

static void removeclient(int);

static int getdottedipaddr(int sd, struct sockaddr_in *addr);

static void my_signal(int signo);

int main(int argc, char *argv[])

{

char rline[MAXLINE+1];

char *start = "Connected to chat-server\n";

int i, j, n;

int client_fd, clilen;

fd_set read_fds;

struct sockaddr_in client_addr, server_addr;

if (argc != 2) {

printf("usage : %s port\n", argv[0]);

return(-1);

}

if ((s = socket(PF_INET, SOCK_STREAM, 0)) < 0) {

printf("can't open stream socket.");

return(-2);

}

bzero((char *)&server_addr, sizeof(server_addr));

server_addr.sin_family = AF_INET;

server_addr.sin_addr.s_addr = htonl(INADDR_ANY);

server_addr.sin_port = htons(atoi(argv[1]));

if (bind(s, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {

printf("Server: Can't bind local address.\n");

return(-3);

}

if (signal(SIGINT, my_signal) == SIG_ERR) { /* Ctrl+C */

printf("Server: signal(SIGINT) error\n");

return(-4);

}

if (signal(SIGTERM, my_signal) == SIG_ERR) { /* software termination */

printf("Server: signal(SIGTERM) error\n");

return(-5);

}

if (signal(SIGQUIT, my_signal) == SIG_ERR) { /* Ctrl+\ */

printf("Server: signal(SIGQUIT) error\n");

return(-6);

}

listen(s, 5); /* backlog = 5 */

maxfdp1 = s + 1;

while (1)

{

FD_ZERO(&read_fds);

FD_SET(s, &read_fds);

for (ii=0; ii < g_num_chat; ii++)

{

FD_SET(client_s[ii], &read_fds);

}

maxfdp1 = getmax(s) + 1; /* maxfdp1 재 계산 */

/*wait & response*/

if (select(maxfdp1, &read_fds, (fd_set *)0, (fd_set *)0, (struct timeval *)0) < 0)

{

printf("select error.\n");

break;

}

if (FD_ISSET(s, &read_fds))

{

clilen = sizeof(client_addr);

client_fd = accept(s, (struct sockaddr *)&client_addr, &clilen);

if (client_fd == -1)

{

printf("server: accept error\n");

break;

}

client_s[g_num_chat] = client_fd;

g_num_chat++;

/*welcome message*/

send(client_fd, start, strlen(start), 0);

if (getdottedipaddr(client_fd, &client_addr) > -1)

printf("%d number additional(IP: %s)\n", g_num_chat, inet_ntoa(client_addr.sin_addr));

else

printf("%d number additional\n", g_num_chat);

}

for (ii=0; ii<g_num_chat; ii++)

{

if (FD_ISSET(client_s[ii], &read_fds))

{

if ((n = recv(client_s[ii], rline, MAXLINE, 0)) <= 0)

{

removeclient(ii); /* abrupt exit *//* abrupt exit *//* abrupt exit *//* abrupt exit */

continue;

}

rline[n] = '\0';

if (strstr(rline, escapechar) != NULL)

{

removeclient(ii); /* abrupt exit *//* abrupt exit *//* abrupt exit *//* abrupt exit *//* abrupt exit */

continue;

}

for (kk=0; kk<g_num_chat; kk++)

{

send(client_s[kk], rline, n, 0);

}

if (getdottedipaddr(client_fd, &client_addr) > -1)

printf("IP: %s -> %s", inet_ntoa(client_addr.sin_addr), rline);

else

printf("%s", rline);

}

} /* while */

my_signal(SIGIO);

}

void removeclient(int indx)

{

struct sockaddr_in client_addr;

if (getdottedipaddr(client_s[indx], &client_addr) > -1)

printf("1 number expired!!(IP: %s).", inet_ntoa(client_addr.sin_addr));

else

printf("1 number expired!!.");

close(client_s[indx]);

if (indx != g_num_chat-1) client_s[indx] = client_s[g_num_chat-1];

g_num_chat--;

printf("now number = %d\n", g_num_chat);

}

int getmax(int k) {

int max = k;

int r;

for (r=0; r < g_num_chat; r++)

{

if (client_s[r] > max) max = client_s[r];

}

return max;

}

/* 소켓에 연결된 상대방 주소를 알아낸다 */

int getdottedipaddr(int sd, struct sockaddr_in *addr) {

struct sockaddr_in client_addr;

int len, r;

len = sizeof(client_addr);

if ((r = getpeername(sd, (struct sockaddr *)&client_addr, &len)) == 0)

{

*addr = client_addr;

}

return r;

}

/* 시그널 처리 함수 정의 */

void my_signal(int signo)

{

int ii;

/* 대부분의 시그널(SIGILL과 SIGTRAP 은 제외)에 대한 처리 함수는 시그널이 포작된 후

즉시 재지정된다. 이것은 프로세스가 시그널의 처리 함수를 잊어버리고, 다음에 시그널이

도착하면 묵시적 처리함수인 SIG_DFL 을 수행하는 것을 의미한다.

이것은 특히 사용자가 인터럽트키를 여러번 누를 수도 있는 대화명 프로그램에서 문제가 된다

그러므로 시그널 함수가 호출되자 마자 SIGINT 시그널을 무시한다 */

signal(SIGINT, SIG_IGN);

signal(SIGTERM, SIG_IGN);

signal(SIGQUIT, SIG_IGN);

close(s);

for (ii=0; ii < g_num_chat; ii++)

{

close(client_s[ii]);

}

exit(0);

}

/*----------------------------------------------------------------------------------------------------

socket function : accept

1. 소켓에 연결을 받아들인다.

#include <sys/types.h>

#include <sys/socket.h>

int accept(int s, struct sockaddr *addr, socklen_t *addrlen);

2. 설명

accept() 함수는 연결지향 소켓 타입 (SOCK_STREAM, SOCK_SEQPACKET, SOCK_RDM)에 사용된다.

이것은 아직 처리되지 않은 연결들이 대기하고 있는 큐에서 제일 처음 연결된 연결을 가져와서 새로운 연결된 소켓을 만든다.

그리고 소켓을 가르키는 파일 지정자를 할당하고 이것을 리턴한다.

인자 s 는 socket() 로 만들어진 end-point(듣기 소켓)을 위한 파일지정자이다.

인자 addr 는 sockaddr 구조체에 대한 포인터이다.

연결이 성공되면 이 구조체를 채워서 되돌려 주게 되고,

우리는 이구조체의 정보를 이용해서 연결된 클라이언트의 인터넷 정보를 알아낼수 있다. addrlen 인자는 addr의 크기 이다.

만약 미결인 연결이 큐에 존재하지 않고, 소켓이 비봉쇄가 아니라면 accept 는 연결이 존재할때까지 해당영역에서 봉쇄된다.

비봉쇄 소켓일경우에는 errno 로 EAGAIN 을 설정하고 바로 리턴한다.

3. 반환값

에러시 -1이 반환된다. 성공한다면 받아들인 소켓을 위한 파일지정번호 (0보다 큰)을 반환한다.

---------------------------------*/

'통신 > SELECT(TCP)' 카테고리의 다른 글

WINDOWS,SERVER,SELECT(FILE RECV),BASIC(SEND) (0)	2019.10.29
WINDOWS,CLIENT,THREAD(FILE READ SEND),BASIC(RECV) (0)	2019.10.29
Makefile(win_calc_server: win_calc_server.o pushcall.o common.o calc_server.o) (0)	2019.10.29
Windows,client,tcp,basic(recv),thread(send) (0)	2019.10.29
Windows,server,tcp,select(recv),select(send),multi-client (0)	2019.10.29

/*

LINUX,MULTICAST,UDP SERVER

*/

#include <stdio.h>

#include <string.h>

#include <stdlib.h>

#include <time.h>

#include <errno.h>

#include <fcntl.h>

#include <signal.h>

#include <setjmp.h>

#include <unistd.h>

#include <ctype.h>

#include <sys/ipc.h>

#include <sys/msg.h>

#include <sys/stat.h>

#include <sys/types.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#include <netdb.h>

#include <sys/shm.h>

/*------------------------------------------------------------------------------------

TR_CODE DESC FRAME_ID MULTICAST_GROUP REAL_PORT

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19711

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19712

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19713

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19714

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19715

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19716

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19717

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19718

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19719

A3012 체결 FID_KOSDAQCHEGYUL 233.37.54.51 19720

------------------------------------------------------------------------------------*/

/*USAGE------------------------------------------------------------------------------------

rcvmulticastdata 233.37.54.51 19711

rcvmulticastdata 233.37.54.51 19712

rcvmulticastdata 233.37.54.51 19713

rcvmulticastdata 233.37.54.51 19714

rcvmulticastdata 233.37.54.51 19715

rcvmulticastdata 233.37.54.51 19716

rcvmulticastdata 233.37.54.51 19717

..

------------------------------------------------------------------------------------*/

int main(int argc, char *argv[])

{

int send_s, recv_s;

unsigned int yes=1, ttl=32;

struct sockaddr_in mcast_group;

struct ip_mreq mreq;

struct sockaddr_in from;

int rlen, len, rtn;

if (argc != 3) {

printf("usage : %s multicastaddr port &\n", argv[0]);

exit(0);

}

for (;;)

{

//socket for multicast receive

memset((char *)&mcast_group, 0, sizeof(mcast_group));

mcast_group.sin_family = AF_INET;

mcast_group.sin_port = htons(atoi(argv[2]));

mcast_group.sin_addr.s_addr = inet_addr(argv[1]);

if ((recv_s = socket(AF_INET, SOCK_DGRAM, 0)) < 0)

{

printf("error: can't create receive socket\n");

exit(0);

}

//multicast group register, and multicast network is defind by root user

mreq.imr_multiaddr = mcast_group.sin_addr;

//mreq.imr_interface.s_addr = htonl(INADDR_ANY);

//"192.178.33.142" is multicast network interface

mreq.imr_interface.s_addr = inet_addr("192.178.33.142");

if (setsockopt(recv_s, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) < 0)

{

printf("error: add membership\n");

exit(0);

}

//socket re-use option set

if (setsockopt(recv_s, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes)) < 0)

{

printf("error: so_reuseaddr setsockopt\n");

exit(0);

}

//socket bind

if (bind(recv_s, (struct sockaddr*)&mcast_group, sizeof(mcast_group)) < 0) {

printf("error: bind receive socket\n");

exit(0);

}

for (;;)

{

len = sizeof(from);

if ((rlen = recvfrom(recv_s, rbuf, SZ_MAX, 0, (struct sockaddr *)&from, &len)) < 0)

{

printf("error: recvfrom\n");

exit(0);

}

rbuf[rlen] = '\0';

printf("%s\n", rbuf);

}

close(recv_s);

usleep(1000);

}

return(0);

}

전체 글

'데이타베이스 > MySQL' 카테고리의 다른 글

'리눅스' 카테고리의 다른 글

'유용한 자료들(Tip)' 카테고리의 다른 글

'통신 > SELECT(TCP)' 카테고리의 다른 글

'통신 > SELECT(TCP)' 카테고리의 다른 글

'통신 > SELECT(TCP)' 카테고리의 다른 글

'통신 > SELECT(TCP)' 카테고리의 다른 글

'java 언어 > Java' 카테고리의 다른 글

'java 언어 > Java' 카테고리의 다른 글

'java 언어 > Java' 카테고리의 다른 글

'통신 > THREAD(TCP)' 카테고리의 다른 글

'데이타베이스 > MySQL' 카테고리의 다른 글

'데이타베이스 > MySQL' 카테고리의 다른 글

'데이타베이스 > MySQL' 카테고리의 다른 글

'리눅스' 카테고리의 다른 글

'c 언어 > 중급과정' 카테고리의 다른 글

'c 언어 > 초급과정' 카테고리의 다른 글

'c 언어 > 중급과정' 카테고리의 다른 글

'통신 > SELECT(TCP)' 카테고리의 다른 글

티스토리툴바