WEB API Archives - icodebroker

[JAVASCRIPT/WEB API] 웹 SQL 데이터베이스에서 데이터베이스 버전 업그레이드하기

■ 웹 SQL 데이터베이스에서 데이터베이스 버전을 업그레이드하는 방법을 보여준다. ▶ test.html


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <script language="javascript">
            var db;

            var sqlArray =
            [
                'create table phonebook (id integer primary key autoincrement, name varchar(32), phone varchar(32))', // 버전 1
                'alter table phonebook add column gender char',                                                       // 버전 2
                'alter table phonebook add column company varchar(64)'                                                // 버전 3
            ];

            function onLoad()
            {
                try
                {
                    this.db = openDatabase('html5', '1', '전화번호부', 1024 * 1024);
                }
                catch(e)
                {
                    document.getElementById('output').innerHTML = '데이터베이스를 여는 중 에러가 발생했습니다 : ' + e;

                    return;
                }

                document.getElementById('output').innerHTML = '데이터베이스를 열었습니다.';
            }

            function showVersion()
            {
                document.getElementById('output').innerHTML = "현재 데이터베이스 버전 : " + this.db.version;
            }

            function upgradeVersion()
            {
                var message = '';
                var version = eval('0' + this.db.version);

                if(version < this.sqlArray.length)
                {
                    this.db.changeVersion
                    (
                        this.db.version,
                        String(this.sqlArray.length),
                        function(tx)
                        {
                            for(var i = version; i < this.sqlArray.length; i++)
                            {
                                tx.executeSql(this.sqlArray[i]);

                                message += 'version ' + (i + 1) + '로 업그레이드하였습니다.<br />';
                            }

                            document.getElementById('output').innerHTML = message;
                        }
                    );
                }
                else
                {
                    document.getElementById('output').innerHTML = '현재 버전(' + version + ')이 최종 버전입니다.';
                }
            }

            function resetVersion()
            {
                this.db.changeVersion
                (
                    this.db.version,
                    '',
                    function(tx)
                    {
                        tx.executeSql('drop table phonebook');
                    }
                );

                document.getElementById('output').innerHTML = '데이터베이스를 초기 상태로 설정했습니다.';
            }
        </script>
    </head>
    <body onload="onLoad();">
        <div id="output">데이터베이스 테스트입니다.</div>
        <p />
        <input type="button" value="현재 버전 조회"  onclick="showVersion();"    />
        <input type="button" value="버전 업그레이드" onclick="upgradeVersion();" />
        <input type="button" value="버전 초기화"     onclick="resetVersion();"   />
    </body>
</html>

<!DOCTYPE html>

<html>

<head>

var db;

var sqlArray =

[

'create table phonebook (id integer primary key autoincrement, name varchar(32), phone varchar(32))', // 버전 1

'alter table phonebook add column gender char', // 버전 2

'alter table phonebook add column company varchar(64)' // 버전 3

];

function onLoad()

{

try

{

this.db = openDatabase('html5', '1', '전화번호부', 1024 * 1024);

}

catch(e)

{

document.getElementById('output').innerHTML = '데이터베이스를 여는 중 에러가 발생했습니다 : ' + e;

return;

}

document.getElementById('output').innerHTML = '데이터베이스를 열었습니다.';

}

function showVersion()

{

document.getElementById('output').innerHTML = "현재 데이터베이스 버전 : " + this.db.version;

}

function upgradeVersion()

{

var message = '';

var version = eval('0' + this.db.version);

if(version < this.sqlArray.length)

{

this.db.changeVersion

(

this.db.version,

String(this.sqlArray.length),

function(tx)

{

for(var i = version; i < this.sqlArray.length; i++)

{

tx.executeSql(this.sqlArray[i]);

message += 'version ' + (i + 1) + '로 업그레이드하였습니다.<br />';

}

document.getElementById('output').innerHTML = message;

}

);

}

else

{

document.getElementById('output').innerHTML = '현재 버전(' + version + ')이 최종 버전입니다.';

}

function resetVersion()

{

this.db.changeVersion

(

this.db.version,

'',

function(tx)

{

tx.executeSql('drop table phonebook');

}

);

document.getElementById('output').innerHTML = '데이터베이스를 초기 상태로 설정했습니다.';

}

</script>

</head>

<div id="output">데이터베이스 테스트입니다.</div>

<p />

</body>

</html>

[JAVASCRIPT/WEB API] 웹 SQL 데이터베이스에서 테이블 데이터 추가/삭제/조회하기

■ 웹 SQL 데이터베이스에서 테이블 데이터를 추가/삭제/조회하는 방법을 보여준다. ▶ test.html


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <script language="javascript">
            var db;

            function onLoad()
            {
                try
                {
                    this.db = openDatabase('html5', '1', '전화번호부', 1024 * 1024);
                }
                catch(e)
                {
                    document.getElementById('output').innerHTML = '데이터베이스를 여는 중 에러가 발생했습니다 : ' + e;

                    return;
                }

                document.getElementById('output').innerHTML = '데이터베이스를 열었습니다.';
            }

            function createCallback(tx)
            {
                tx.executeSql('create table phonebook (id integer primary key autoincrement, name varchar(32), phone varchar(32))');
            }

            function errorCallback(tx)
            {
                document.getElementById('output').innerHTML = '테이블 생성시 에러가 발생했습니다.';
            }

            function successCallback(tx)
            {
                document.getElementById('output').innerHTML = '테이블을 생성했습니다.';
            }

            function createTable()
            {
                this.db.transaction(createCallback, errorCallback, successCallback);
            }

            function dropTable()
            {
                this.db.transaction
                (
                    function(tx)
                    {
                        tx.executeSql('drop table phonebook');

                        document.getElementById('output').innerHTML = '테이블을 삭제했습니다.';
                    }
                );
            }

            function insertData()
            {
                var name  = document.getElementById('name' ).value;
                var phone = document.getElementById('phone').value;

                this.db.transaction
                (
                    function(tx)
                    {
                        tx.executeSql('insert into phonebook (name, phone) values (?, ?)', [name, phone]);
                    }
                );

                document.getElementById('output').innerHTML = '데이터를 추가했습니다.';

                document.getElementById('name' ).value = '';
                document.getElementById('phone').value = '';
            }

            function removeData(id)
            {
                this.db.transaction
                (
                    function(tx)
                    {
                        tx.executeSql('delete from phonebook where id = ?', [id]);
                    }
                );

                document.getElementById('output').innerHTML = '데이터를 삭제했습니다.';
            }

            function showData()
            {
                var message = '';

                this.db.transaction
                (
                    function(tx)
                    {
                        tx.executeSql
                        (
                            'select * from phonebook',
                            [],
                            function(tx, rs)
                            {
                                for(var i = 0; i < rs.rows.length; i++)
                                {
                                    var row = rs.rows.item(i);

                                    message = message + row['name'] + ', ' + row['phone'] + ', ' + '<a href="javascript:removeData(' + row['id'] + ');">삭제</a><br />';
                                }

                                document.getElementById('output').innerHTML = message;
                            }
                        );
                    }
                );
            }
        </script>
    </head>
    <body onload="onLoad();">
        <div id="output">데이터베이스 테스트입니다.</div>
        <p />
        <input type="button" value="테이블 생성" onclick="createTable();" />
        <input type="button" value="테이블 삭제" onclick="dropTable();"   />
        <p />
        이름 : <input type="text" id="name"  size="10" />
        전화 : <input type="text" id="phone" size="10" />
        <input type="button" value="데이터 추가" onclick="insertData();" />
        <input type="button" value="데이터 조회" onclick="showData();"   />
    </body>
</html>

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

<!DOCTYPE html>

<html>

<head>

var db;

function onLoad()

{

try

{

this.db = openDatabase('html5', '1', '전화번호부', 1024 * 1024);

}

catch(e)

{

document.getElementById('output').innerHTML = '데이터베이스를 여는 중 에러가 발생했습니다 : ' + e;

return;

}

document.getElementById('output').innerHTML = '데이터베이스를 열었습니다.';

}

function createCallback(tx)

{

tx.executeSql('create table phonebook (id integer primary key autoincrement, name varchar(32), phone varchar(32))');

}

function errorCallback(tx)

{

document.getElementById('output').innerHTML = '테이블 생성시 에러가 발생했습니다.';

}

function successCallback(tx)

{

document.getElementById('output').innerHTML = '테이블을 생성했습니다.';

}

function createTable()

{

this.db.transaction(createCallback, errorCallback, successCallback);

}

function dropTable()

{

this.db.transaction

(

function(tx)

{

tx.executeSql('drop table phonebook');

document.getElementById('output').innerHTML = '테이블을 삭제했습니다.';

}

);

}

function insertData()

{

var name = document.getElementById('name' ).value;

var phone = document.getElementById('phone').value;

this.db.transaction

(

function(tx)

{

tx.executeSql('insert into phonebook (name, phone) values (?, ?)', [name, phone]);

}

);

document.getElementById('output').innerHTML = '데이터를 추가했습니다.';

document.getElementById('name' ).value = '';

document.getElementById('phone').value = '';

}

function removeData(id)

{

this.db.transaction

(

function(tx)

{

tx.executeSql('delete from phonebook where id = ?', [id]);

}

);

document.getElementById('output').innerHTML = '데이터를 삭제했습니다.';

}

function showData()

{

var message = '';

this.db.transaction

(

function(tx)

{

tx.executeSql

(

'select * from phonebook',

[],

function(tx, rs)

{

for(var i = 0; i < rs.rows.length; i++)

{

var row = rs.rows.item(i);

message = message + row['name'] + ', ' + row['phone'] + ', ' + '<a href="javascript:removeData(' + row['id'] + ');">삭제</a><br />';

}

document.getElementById('output').innerHTML = message;

}

);

}

);

}

</script>

</head>

<div id="output">데이터베이스 테스트입니다.</div>

<p />

<p />

이름 : <input type="text" id="name" size="10" />

전화 : <input type="text" id="phone" size="10" />

</body>

</html>

[JAVASCRIPT/WEB API] 웹 SQL 데이터베이스에서 테이블 생성/삭제하기

■ 웹 SQL 데이터베이스에서 테이블을 생성하고 삭제하는 방법을 보여준다. ▶ test.html


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <script language="javascript">
            var db;

            function onLoad()
            {
                try
                {
                    this.db = openDatabase('html5', '1', '전화번호부', 1024 * 1024);
                }
                catch(e)
                {
                    document.getElementById('output').innerHTML = '데이터베이스를 여는 중 에러가 발생했습니다 : ' + e;

                    return;
                }

                document.getElementById('output').innerHTML = '데이터베이스를 열었습니다.';
            }

            function createCallback(tx)
            {
                tx.executeSql('create table phonebook (id integer primary key autoincrement, name varchar(32), phone varchar(32))');
            }

            function errorCallback(tx)
            {
                document.getElementById('output').innerHTML = '테이블 생성시 에러가 발생했습니다.';
            }

            function successCallback(tx)
            {
                document.getElementById('output').innerHTML = '테이블을 생성했습니다.';
            }

            function createTable()
            {
                this.db.transaction(createCallback, errorCallback, successCallback);
            }

            function dropTable()
            {
                this.db.transaction
                (
                    function(tx)
                    {
                        tx.executeSql('drop table phonebook');

                        document.getElementById('output').innerHTML = '테이블을 삭제했습니다.';
                    }
                );
            }
</script>
    </head>
    <body onload="onLoad();">
        <div id="output">데이터베이스 테스트입니다.</div>
        <p />
        <input type="button" value="테이블 생성" onclick="createTable();" />
        <input type="button" value="테이블 삭제" onclick="dropTable();"   />
    </body>
</html>

<!DOCTYPE html>

<html>

<head>

var db;

function onLoad()

{

try

{

this.db = openDatabase('html5', '1', '전화번호부', 1024 * 1024);

}

catch(e)

{

document.getElementById('output').innerHTML = '데이터베이스를 여는 중 에러가 발생했습니다 : ' + e;

return;

}

document.getElementById('output').innerHTML = '데이터베이스를 열었습니다.';

}

function createCallback(tx)

{

tx.executeSql('create table phonebook (id integer primary key autoincrement, name varchar(32), phone varchar(32))');

}

function errorCallback(tx)

{

document.getElementById('output').innerHTML = '테이블 생성시 에러가 발생했습니다.';

}

function successCallback(tx)

{

document.getElementById('output').innerHTML = '테이블을 생성했습니다.';

}

function createTable()

{

this.db.transaction(createCallback, errorCallback, successCallback);

}

function dropTable()

{

this.db.transaction

(

function(tx)

{

tx.executeSql('drop table phonebook');

document.getElementById('output').innerHTML = '테이블을 삭제했습니다.';

}

);

}

</script>

</head>

<div id="output">데이터베이스 테스트입니다.</div>

<p />

</body>

</html>

[JAVASCRIPT/WEB API] Storage 인터페이스 : 세션 저장소 데이터 처리하기

■ Storage 인터페이스를 사용해 세션 저장소 데이터를 처리하는 방법을 보여준다. ▶ test1.html


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <script language="javascript">
            var data;

            function saveData()
            {
                data                = 'html5';
                sessionStorage.data = 'html5';
                localStorage.data   = 'html5';

                document.getElementById('output').innerHTML = '데이터를 저장했습니다.';
            }

            function loadData()
            {
                message =           '자바 스크립트 변수 : ' + data                           + '<br />';
                message = message + '세션 저장소 변수 : '   + sessionStorage.getItem('data') + '<br />';
                message = message + '로컬 저장소 변수 : '   + localStorage.getItem('data');

                document.getElementById('output').innerHTML = message;
            }

            function goToNextPage()
            {
                location.href = 'test2.html';
            }

            function clearData()
            {
                data = '';

                sessionStorage.clear();
                localStorage.clear();

                document.getElementById('output').innerHTML = '데이터를 삭제했습니다.';
            }
        </script>
    </head>
    <body>
        <div id="output">세션 저장소 테스트입니다.</div>
        <p />
        <input type="button" value="데이터 저장" onclick="saveData();"     />
        <input type="button" value="데이터 로드" onclick="loadData();"     />
        <input type="button" value="페이지 이동" onclick="goToNextPage();" />
        <input type="button" value="데이터 삭제" onclick="clearData();"    />
    </body>
</html>

<!DOCTYPE html>

<html>

<head>

var data;

function saveData()

{

data = 'html5';

sessionStorage.data = 'html5';

localStorage.data = 'html5';

document.getElementById('output').innerHTML = '데이터를 저장했습니다.';

}

function loadData()

{

message = '자바 스크립트 변수 : ' + data + '<br />';

message = message + '세션 저장소 변수 : ' + sessionStorage.getItem('data') + '<br />';

message = message + '로컬 저장소 변수 : ' + localStorage.getItem('data');

document.getElementById('output').innerHTML = message;

}

function goToNextPage()

{

location.href = 'test2.html';

}

function clearData()

{

data = '';

sessionStorage.clear();

localStorage.clear();

document.getElementById('output').innerHTML = '데이터를 삭제했습니다.';

}

</script>

</head>

<body>

<div id="output">세션 저장소 테스트입니다.</div>

<p />

</body>

</html>

▶ test2.html


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
    </head>
    <body>
        <a href="test1.html">이전 페이지로 이동</a>
    </body>
</html>

<!DOCTYPE html>

<html>

<head>

</head>

<body>

</body>

</html>

[JAVASCRIPT/WEB API] Storage 인터페이스 : 로컬 저장소에서 JSON 데이터 처리하기

■ Storage 인터페이스를 사용해 로컬 저장소에서 JSON 데이터를 처리하는 방법을 보여준다. ▶ test.html


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <script language="javascript">
            function onLoad()
            {
                var array = JSON.parse(localStorage.getItem('phonebook'));

                if(array == null)
                {
                    localStorage.setItem('phonebook', JSON.stringify(new Array));
                }

                showData();
            }

            function showData()
            {
                var message = '';

                var array = JSON.parse(localStorage.getItem('phonebook'));

                for(var i = 0; i < array.length; i++)
                {
                    message = message + array[i].name + ', ' + array[i].phone + ', ' + '<a href="javascript:removeData(' + i + ');">삭제</a><br />';
                }

                document.getElementById('output').innerHTML = message;
            }

            function AddData()
            {
                var value1;
                var value2;
                var array = JSON.parse(localStorage.getItem('phonebook'));

                value1 = document.getElementById('name').value;
                value2 = document.getElementById('phone').value;

                array[array.length] = { name : value1, phone : value2 };

                localStorage.setItem('phonebook', JSON.stringify(array));

                showData();

                document.getElementById('name').value  = '';
                document.getElementById('phone').value = '';
            }

            function removeData(i)
            {
                var array = JSON.parse(localStorage.getItem('phonebook'));

                array.splice(i, 1);

                localStorage.setItem('phonebook', JSON.stringify(array));

                showData();
            }

            function clearData()
            {
                localStorage.removeItem('phonebook');

                localStorage.setItem('phonebook', JSON.stringify(new Array));

                showData();
            }
        </script>
    </head>
    <body onload="onLoad();">
        <div id="output">로컬 저장소 JSON 데이터 테스트입니다.</div>
        <p />
        <input id="name" type="text" size="8" />
        <input id="phone" type="text" size="12" />
        <p />
        <input type="button" value="데이터 추가" onclick="AddData();"   />
        <input type="button" value="데이터 삭제" onclick="clearData();" />
    </body>
</html>

<!DOCTYPE html>

<html>

<head>

function onLoad()

{

var array = JSON.parse(localStorage.getItem('phonebook'));

if(array == null)

{

localStorage.setItem('phonebook', JSON.stringify(new Array));

}

showData();

}

function showData()

{

var message = '';

var array = JSON.parse(localStorage.getItem('phonebook'));

for(var i = 0; i < array.length; i++)

{

message = message + array[i].name + ', ' + array[i].phone + ', ' + '<a href="javascript:removeData(' + i + ');">삭제</a><br />';

}

document.getElementById('output').innerHTML = message;

}

function AddData()

{

var value1;

var value2;

var array = JSON.parse(localStorage.getItem('phonebook'));

value1 = document.getElementById('name').value;

value2 = document.getElementById('phone').value;

array[array.length] = { name : value1, phone : value2 };

localStorage.setItem('phonebook', JSON.stringify(array));

showData();

document.getElementById('name').value = '';

document.getElementById('phone').value = '';

}

function removeData(i)

{

var array = JSON.parse(localStorage.getItem('phonebook'));

array.splice(i, 1);

localStorage.setItem('phonebook', JSON.stringify(array));

showData();

}

function clearData()

{

localStorage.removeItem('phonebook');

localStorage.setItem('phonebook', JSON.stringify(new Array));

showData();

}

</script>

</head>

<div id="output">로컬 저장소 JSON 데이터 테스트입니다.</div>

<p />

<p />

</body>

</html>

[JAVASCRIPT/WEB API] Storage 인터페이스 : 로컬 저장소 데이터 처리하기

■ Storage 인터페이스를 사용해 로컬 저장소의 데이터를 처리하는 방법을 보여준다. ▶ test.html


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <script language="javascript">
            function saveData()
            {
                localStorage.name = 'html5';
                localStorage['phone'] = '012-3456-7890';
                localStorage.setItem('email', 'someone@html5.com');

                document.getElementById('output').innerHTML = '로컬 저장소에 데이터가 저장되었습니다.';
            }

            function loadData()
            {
                message = '이름 : ' + localStorage['name'] + '<br />';
                message = message + '전화 : ' + localStorage.getItem('phone') + '<br />';
                message = message + '이메일 : ' + localStorage.email;

                document.getElementById('output').innerHTML = message;
            }

            function clearData()
            {
                localStorage.clear();

                document.getElementById('output').innerHTML = '로컬 저장소의 데이터가 모두 제거되었습니다.';
            }
        </script>
    </head>
    <body>
        <div id="output">로컬 저장소 테스트입니다.</div>
        <p />
        <input type="button" value="저장하기" onclick="saveData();"  />
        <input type="button" value="로드하기" onclick="loadData();"  />
        <input type="button" value="지우기"   onclick="clearData();" />
    </body>
</html>

<!DOCTYPE html>

<html>

<head>

function saveData()

{

localStorage.name = 'html5';

localStorage['phone'] = '012-3456-7890';

localStorage.setItem('email', 'someone@html5.com');

document.getElementById('output').innerHTML = '로컬 저장소에 데이터가 저장되었습니다.';

}

function loadData()

{

message = '이름 : ' + localStorage['name'] + '<br />';

message = message + '전화 : ' + localStorage.getItem('phone') + '<br />';

message = message + '이메일 : ' + localStorage.email;

document.getElementById('output').innerHTML = message;

}

function clearData()

{

localStorage.clear();

document.getElementById('output').innerHTML = '로컬 저장소의 데이터가 모두 제거되었습니다.';

}

</script>

</head>

<body>

<div id="output">로컬 저장소 테스트입니다.</div>

<p />

</body>

</html>

[JAVASCRIPT/WEB API] HTMLCanvasElement 인터페이스 : getContext 메소드를 사용해 컨텍스트 구하기

■ HTMLCanvasElement 인터페이스의 getContext 메소드를 사용해 컨텍스트를 구하는 방법을 보여준다. ▶ 예제 코드 (HTML)


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <script language="javascript">
            function onLoad()
            {
                var canvas  = document.getElementById('canvas');
                var context = canvas.getContext('2d');

                context.strokeStyle = 'red';

                context.strokeRect(20, 20, 100, 100);

                context.fillStyle = 'rgb(0, 0, 255)';

                context.fillRect(120, 120, 200, 200);

                context.clearRect(140, 140, 160, 160);
            }
        </script>
    </head>
    <body onload="onLoad();">
        <canvas id="canvas" width="400" height="400" />
    </body>
</html>

<!DOCTYPE html>

<html>

<head>

function onLoad()

{

var canvas = document.getElementById('canvas');

var context = canvas.getContext('2d');

context.strokeStyle = 'red';

context.strokeRect(20, 20, 100, 100);

context.fillStyle = 'rgb(0, 0, 255)';

context.fillRect(120, 120, 200, 200);

context.clearRect(140, 140, 160, 160);

}

</script>

</head>

</body>

</html>

[JAVASCRIPT/WEB API] Document 인터페이스 : getElementById 메소드를 사용해 ID로 엘리먼트 구하기

■ Document 인터페이스의 getElementById 메소드를 사용해 ID로 엘리먼트를 구하는 방법을 보여준다. ▶ 예제 코드 (HTML)


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <script language="javascript">
            function onLoad()
            {
                var canvas  = document.getElementById('canvas');
                var context = canvas.getContext('2d');

                context.strokeStyle = 'red';

                context.strokeRect(20, 20, 100, 100);

                context.fillStyle = 'rgb(0, 0, 255)';

                context.fillRect(120, 120, 200, 200);

                context.clearRect(140, 140, 160, 160);
            }
        </script>
    </head>
    <body onload="onLoad();">
        <canvas id="canvas" width="400" height="400" />
    </body>
</html>

<!DOCTYPE html>

<html>

<head>

function onLoad()

{

var canvas = document.getElementById('canvas');

var context = canvas.getContext('2d');

context.strokeStyle = 'red';

context.strokeRect(20, 20, 100, 100);

context.fillStyle = 'rgb(0, 0, 255)';

context.fillRect(120, 120, 200, 200);

context.clearRect(140, 140, 160, 160);

}

</script>

</head>

</body>

</html>

[JAVASCRIPT/WEB API] 드래그 & 드롭 사용하기

■ 드래그 & 드롭을 사용하는 방법을 보여준다. ▶ test.html


<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
    </head>
    <style>
        #board
        {
            position     : absolute;
            width        : 400px;
            height       : 400px;
            border-style : solid;
        }
    </style>
    <script language="javascript">
        var minimumX = 0;
        var minimumY = 0;
        var baseX    = 0;
        var baseY    = 0;

        function onDragStart(event)
        {
            var targetElement;

            if(typeof event.target != 'undefined')
            {
                targetElement = event.target;
            }
            else
            {
                targetElement = event.srcElement;
            }

            if(targetElement.tagName.toLowerCase() == 'img')
            {
                event.dataTransfer.setData('text', targetElement.id);
            }
        }

        function onDragEnter(event)
        {
            if(event.dataTransfer.dropEffect == 'copy')
            {
                event.preventDefault ? event.preventDefault() : event.returnValue = false;
            }
        }

        function onDragOver(event)
        {
            event.dataTransfer.dropEffect = 'copy';

            event.preventDefault ? event.preventDefault() : event.returnValue = false;
        }

        function onDrop(event)
        {
            var id          = event.dataTransfer.getData('text');
            var dropElement = document.getElementById(id);

            var targetElement;

            if(typeof event.currentTarget != 'undefined')
            {
                targetElement = event.currentTarget;
            }
            else
            {
                targetElement = event.srcElement;
            }

            if(dropElement && dropElement.parentNode != targetElement)
            {
                var cloneElement = dropElement.cloneNode();

                targetElement.appendChild(cloneElement);

                var scrollX = window.scrollX ? window.scrollX : document.body.scrollLeft;
                var scrollY = window.scrollY ? window.scrollY : document.body.scrollTop;

                var x = window.event.clientX + scrollX;
                var y = window.event.clientY + scrollY;

                setPosition(x, y);

                cloneElement.style.position = 'absolute';
                cloneElement.style.left     = (this.minimumX - cloneElement.width  / 2 - this.baseX) + 'px';
                cloneElement.style.top      = (this.minimumY - cloneElement.height / 2 - this.baseY) + 'px';
            }

            event.stopPropagation ? event.stopPropagation() : event.returnValue = false;
        }

        function setPosition(sourceX, sourceY)
        {
            var minimumDistance = 100000;

            for(var i = 1; i <= 4; i++)
            {
                for(var j = 1; j <= 4; j++)
                {
                    var x = 80 * i + baseX;
                    var y = 80 * j + baseY;

                    var distance = Math.sqrt((sourceX - x) * (sourceX - x) + (sourceY - y) * (sourceY - y));

                    if(distance < minimumDistance)
                    {
                        minimumDistance = distance;

                        this.minimumX = x;
                        this.minimumY = y;
                    }
                }
            }
        }

        function onLoad()
        {
            var canvas = document.getElementById('canvas');

            if(canvas.getContext)
            {
                var context = canvas.getContext('2d');

                context.lineWidth   = 2;
                context.lineJoin    = 'miter';
                context.lineCap     = 'butt';
                context.strokeStyle = 'gray';

                for(i = 1; i <= 5; i++)
                {
                    context.beginPath();
                    context.moveTo(0, 80 * i);
                    context.lineTo(400, 80 * i);

                    context.moveTo(80 * i, 0);
                    context.lineTo(80 * i, 400);
                    context.stroke();
                }
            }

            var board = document.getElementById('board');

            var x = board.style.left.replace('px', '');
            var y = board.style.top.replace('px', '');

            var scrollX = window.scrollX ? window.scrollX : document.body.scrollLeft;
            var scrollY = window.scrollY ? window.scrollY : document.body.scrollTop;

            this.baseX = parseInt(x) + parseInt(scrollX);
            this.baseY = parseInt(y) + parseInt(scrollY);
        }
    </script>
    <body onload="onLoad();">
        <div onDragStart="onDragStart(event)" draggable="true">
            <img id="image1" src="ball_blue.png" />
            <img id="image2" src="ball_red.png"  />
        </div>
        <div id="board" style="left:10px;top:100px;"
            ondragEnter="onDragEnter(event)"
            onDragOver="onDragOver(event)"
            onDrop="onDrop(event)">
            <canvas id="canvas" width="400" height="400" />
        </div>
    </body>
</html>

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

<!DOCTYPE html>

<html>

<head>

</head>

<style>

#board

{

position : absolute;

width : 400px;

height : 400px;

border-style : solid;

}

</style>

var minimumX = 0;

var minimumY = 0;

var baseX = 0;

var baseY = 0;

function onDragStart(event)

{

var targetElement;

if(typeof event.target != 'undefined')

{

targetElement = event.target;

}

else

{

targetElement = event.srcElement;

}

if(targetElement.tagName.toLowerCase() == 'img')

{

event.dataTransfer.setData('text', targetElement.id);

}

function onDragEnter(event)

{

if(event.dataTransfer.dropEffect == 'copy')

{

event.preventDefault ? event.preventDefault() : event.returnValue = false;

}

function onDragOver(event)

{

event.dataTransfer.dropEffect = 'copy';

event.preventDefault ? event.preventDefault() : event.returnValue = false;

}

function onDrop(event)

{

var id = event.dataTransfer.getData('text');

var dropElement = document.getElementById(id);

var targetElement;

if(typeof event.currentTarget != 'undefined')

{

targetElement = event.currentTarget;

}

else

{

targetElement = event.srcElement;

}

if(dropElement && dropElement.parentNode != targetElement)

{

var cloneElement = dropElement.cloneNode();

targetElement.appendChild(cloneElement);

var scrollX = window.scrollX ? window.scrollX : document.body.scrollLeft;

var scrollY = window.scrollY ? window.scrollY : document.body.scrollTop;

var x = window.event.clientX + scrollX;

var y = window.event.clientY + scrollY;

setPosition(x, y);

cloneElement.style.position = 'absolute';

cloneElement.style.left = (this.minimumX - cloneElement.width / 2 - this.baseX) + 'px';

cloneElement.style.top = (this.minimumY - cloneElement.height / 2 - this.baseY) + 'px';

}

event.stopPropagation ? event.stopPropagation() : event.returnValue = false;

}

function setPosition(sourceX, sourceY)

{

var minimumDistance = 100000;

for(var i = 1; i <= 4; i++)

{

for(var j = 1; j <= 4; j++)

{

var x = 80 * i + baseX;

var y = 80 * j + baseY;

var distance = Math.sqrt((sourceX - x) * (sourceX - x) + (sourceY - y) * (sourceY - y));

if(distance < minimumDistance)

{

minimumDistance = distance;

this.minimumX = x;

this.minimumY = y;

}

function onLoad()

{

var canvas = document.getElementById('canvas');

if(canvas.getContext)

{

var context = canvas.getContext('2d');

context.lineWidth = 2;

context.lineJoin = 'miter';

context.lineCap = 'butt';

context.strokeStyle = 'gray';

for(i = 1; i <= 5; i++)

{

context.beginPath();

context.moveTo(0, 80 * i);

context.lineTo(400, 80 * i);

context.moveTo(80 * i, 0);

context.lineTo(80 * i, 400);

context.stroke();

}

var board = document.getElementById('board');

var x = board.style.left.replace('px', '');

var y = board.style.top.replace('px', '');

var scrollX = window.scrollX ? window.scrollX : document.body.scrollLeft;

var scrollY = window.scrollY ? window.scrollY : document.body.scrollTop;

this.baseX = parseInt(x) + parseInt(scrollX);

this.baseY = parseInt(y) + parseInt(scrollY);

}

</script>

</div>

<div id="board" style="left:10px;top:100px;"

ondragEnter="onDragEnter(event)"

onDragOver="onDragOver(event)"

onDrop="onDrop(event)">

</div>

</body>

</html>

[C#/MAUI/.NET6] REST WEB API 서비스 사용하기 (ANDROID) (UWP)

■ REST WEB API 서비스를 사용하는 방법을 보여준다. (ANDROID) (UWP) [TestServer 프로젝트] ▶ Properties/launchSettings.json


{
    "$schema"    : "https://json.schemastore.org/launchsettings.json",
    "iisSettings":
    {
        "windowsAuthentication"   : false,
        "anonymousAuthentication" : true,
        "iisExpress"              :
        {
            "applicationUrl" : "http://localhost:46375",
            "sslPort"        : 44369
        }
    },
    "profiles":
    {
        "PartServer" :
        {
            "commandName"          : "Project",
            "dotnetRunMessages"    : true,
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "applicationUrl"       : "https://localhost:7210;http://localhost:5210",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        },
        "IIS Express" :
        {
            "commandName"          : "IISExpress",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        }
    }
}

{

"$schema" : "https://json.schemastore.org/launchsettings.json",

"iisSettings":

{

"windowsAuthentication" : false,

"anonymousAuthentication" : true,

"iisExpress" :

{

"applicationUrl" : "http://localhost:46375",

"sslPort" : 44369

}

"profiles":

{

"PartServer" :

{

"commandName" : "Project",

"dotnetRunMessages" : true,

"launchBrowser" : true,

"launchUrl" : "swagger",

"applicationUrl" : "https://localhost:7210;http://localhost:5210",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

"IIS Express" :

{

"commandName" : "IISExpress",

"launchBrowser" : true,

"launchUrl" : "swagger",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

▶ Models/Part.cs


namespace TestServer.Models
{
    /// <summary>
    /// 부품
    /// </summary>
    public class Part
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 부품 ID - PartID

        /// <summary>
        /// 부품 ID
        /// </summary>
        public string PartID { get; set; }

        #endregion
        #region 부품명 - PartName

        /// <summary>
        /// 부품명
        /// </summary>
        public string PartName { get; set; }

        #endregion
        #region 공급자 리스트 - SupplierList

        /// <summary>
        /// 공급자 리스트
        /// </summary>
        public List<string> SupplierList { get; set; }

        #endregion
        #region 부품 이용 가능일 - PartAvailableDate

        /// <summary>
        /// 부품 이용 가능일
        /// </summary>
        public DateTime PartAvailableDate { get; set; }

        #endregion
        #region 부품 타입 - PartType

        /// <summary>
        /// 부품 타입
        /// </summary>
        public string PartType { get; set; }

        #endregion
    }
}

namespace TestServer.Models

{

/// <summary>

/// 부품

/// </summary>

public class Part

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 부품 ID - PartID

/// <summary>

/// 부품 ID

/// </summary>

public string PartID { get; set; }

#endregion

#region 부품명 - PartName

/// <summary>

/// 부품명

/// </summary>

public string PartName { get; set; }

#endregion

#region 공급자 리스트 - SupplierList

/// <summary>

/// 공급자 리스트

/// </summary>

public List<string> SupplierList { get; set; }

#endregion

#region 부품 이용 가능일 - PartAvailableDate

/// <summary>

/// 부품 이용 가능일

/// </summary>

public DateTime PartAvailableDate { get; set; }

#endregion

#region 부품 타입 - PartType

/// <summary>

/// 부품 타입

/// </summary>

public string PartType { get; set; }

#endregion

}

▶ Models/PartFactory.cs


namespace TestServer.Models
{
    /// <summary>
    /// 부품 팩토리
    /// </summary>
    public static class PartFactory
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Public

        #region Field

        /// <summary>
        /// 부품 딕셔너리
        /// </summary>
        public static Dictionary<string, Tuple<DateTime, List<Part>>> PartDictionary = new Dictionary<string, Tuple<DateTime, List<Part>>>();

        #endregion

        //////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 잠금자
        /// </summary>
        private static object _locker = new object();

        /// <summary>
        /// 난수 발생기
        /// </summary>
        private static readonly Random _random = new Random();

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 디폴트 부품 열거 가능형 - DefaultPartEnumerable

        /// <summary>
        /// 디폴트 부품 열거 가능형
        /// </summary>
        private static IEnumerable<Part> DefaultPartEnumerable
        {
            get
            {
                yield return new Part
                {
                    PartID            = "0545685192",
                    PartName          = "Large motherboard",
                    SupplierList      = new List<string> { "A. Datum Corporation", "Allure Bays Corp", "Awesome Computers" },
                    PartAvailableDate = new DateTime(2019, 10, 1),
                    PartType          = "Circuit Board",
                };

                yield return new Part
                {
                    PartID            = "0553801473",
                    PartName          = "RISC processor",
                    SupplierList      = new List<string> { "Allure Bays Corp", "Contoso Ltd", "Parnell Aerospace" },
                    PartAvailableDate = new DateTime(2021, 07, 12),
                    PartType          = "CPU",
                };

                yield return new Part
                {
                    PartID            = "0544272994",
                    PartName          = "CISC processor",
                    SupplierList      = new List<string> { "Fabrikam, Inc", "A. Datum Corporation", "Parnell Aerospace" },
                    PartAvailableDate = new DateTime(2020, 9, 4),
                    PartType          = "CPU",
                };

                yield return new Part
                {
                    PartID            = "141971189X",
                    PartName          = "High resolution card",
                    SupplierList      = new List<string> { "Awesome Computers" },
                    PartAvailableDate = new DateTime(2019, 11, 10),
                    PartType          = "Graphics Card",
                };

                yield return new Part
                {
                    PartID            = "1256324778",
                    PartName          = "240V/110V switchable",
                    SupplierList      = new List<string> { "Reskit" },
                    PartAvailableDate = new DateTime(2021, 10, 21),
                    PartType          = "PSU",
                };
            }
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Public

        #region 초기화하기 - Initialize(authorizationToken)

        /// <summary>
        /// 초기화하기
        /// </summary>
        /// <param name="authorizationToken">권한 토큰</param>
        public static void Initialize(string authorizationToken)
        {
            lock(_locker)
            {
                PartDictionary.Add(authorizationToken, Tuple.Create(DateTime.UtcNow.AddHours(1), DefaultPartEnumerable.ToList()));
            }
        }

        #endregion
        #region 오래된 데이터 지우기 - ClearStaleData()

        /// <summary>
        /// 오래된 데이터 지우기
        /// </summary>
        public static void ClearStaleData()
        {
            lock(_locker)
            {
                List<string> keyList = PartDictionary.Keys.ToList();

                foreach(string key in keyList)
                {
                    if(PartDictionary.TryGetValue(key, out Tuple<DateTime, List<Part>> result) && result.Item1 < DateTime.UtcNow)
                    {
                        PartDictionary.Remove(key);
                    }
                }
            }
        }

        #endregion
        #region 부품 ID 생성하기 - CreatePartID()

        /// <summary>
        /// 부품 ID 생성하기
        /// </summary>
        /// <returns>부품 ID</returns>
        public static string CreatePartID()
        {
            char[] characterArray = new char[10];

            for(int i = 0; i < 10; i++)
            {
                characterArray[i] = (char)('0' + _random.Next(0, 9));
            }

            return new string(characterArray);
        }

        #endregion
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

namespace TestServer.Models

{

/// <summary>

/// 부품 팩토리

/// </summary>

public static class PartFactory

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region Field

/// <summary>

/// 부품 딕셔너리

/// </summary>

public static Dictionary<string, Tuple<DateTime, List<Part>>> PartDictionary = new Dictionary<string, Tuple<DateTime, List<Part>>>();

#endregion

//////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// 잠금자

/// </summary>

private static object _locker = new object();

/// <summary>

/// 난수 발생기

/// </summary>

private static readonly Random _random = new Random();

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 디폴트 부품 열거 가능형 - DefaultPartEnumerable

/// <summary>

/// 디폴트 부품 열거 가능형

/// </summary>

private static IEnumerable<Part> DefaultPartEnumerable

{

get

{

yield return new Part

{

PartID = "0545685192",

PartName = "Large motherboard",

SupplierList = new List<string> { "A. Datum Corporation", "Allure Bays Corp", "Awesome Computers" },

PartAvailableDate = new DateTime(2019, 10, 1),

PartType = "Circuit Board",

};

yield return new Part

{

PartID = "0553801473",

PartName = "RISC processor",

SupplierList = new List<string> { "Allure Bays Corp", "Contoso Ltd", "Parnell Aerospace" },

PartAvailableDate = new DateTime(2021, 07, 12),

PartType = "CPU",

};

yield return new Part

{

PartID = "0544272994",

PartName = "CISC processor",

SupplierList = new List<string> { "Fabrikam, Inc", "A. Datum Corporation", "Parnell Aerospace" },

PartAvailableDate = new DateTime(2020, 9, 4),

PartType = "CPU",

};

yield return new Part

{

PartID = "141971189X",

PartName = "High resolution card",

SupplierList = new List<string> { "Awesome Computers" },

PartAvailableDate = new DateTime(2019, 11, 10),

PartType = "Graphics Card",

};

yield return new Part

{

PartID = "1256324778",

PartName = "240V/110V switchable",

SupplierList = new List<string> { "Reskit" },

PartAvailableDate = new DateTime(2021, 10, 21),

PartType = "PSU",

};

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region 초기화하기 - Initialize(authorizationToken)

/// <summary>

/// 초기화하기

/// </summary>

/// <param name="authorizationToken">권한 토큰</param>

public static void Initialize(string authorizationToken)

{

lock(_locker)

{

PartDictionary.Add(authorizationToken, Tuple.Create(DateTime.UtcNow.AddHours(1), DefaultPartEnumerable.ToList()));

}

#endregion

#region 오래된 데이터 지우기 - ClearStaleData()

/// <summary>

/// 오래된 데이터 지우기

/// </summary>

public static void ClearStaleData()

{

lock(_locker)

{

List<string> keyList = PartDictionary.Keys.ToList();

foreach(string key in keyList)

{

if(PartDictionary.TryGetValue(key, out Tuple<DateTime, List<Part>> result) && result.Item1 < DateTime.UtcNow)

{

PartDictionary.Remove(key);

}

#endregion

#region 부품 ID 생성하기 - CreatePartID()

/// <summary>

/// 부품 ID 생성하기

/// </summary>

/// <returns>부품 ID</returns>

public static string CreatePartID()

{

char[] characterArray = new char[10];

for(int i = 0; i < 10; i++)

{

characterArray[i] = (char)('0' + _random.Next(0, 9));

}

return new string(characterArray);

}

#endregion

}

▶

[C#/WEB API] Microsoft.AspNet.WebApi.SelfHost 누겟 설치하기

■ Microsoft.AspNet.WebApi.SelfHost 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.

[C#/WEB API/.NET5] JWT 토큰 생성하기

■ JWT 토큰을 생성하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.Collections.Generic;
using System.IdentityModel.Tokens.Jwt;
using System.Security.Claims;
using System.Text;

using Microsoft.IdentityModel.Tokens;

#region JWT 토큰 생성하기 - GenerateJWTToken(claimEnumerable, secretKey, issuer, audience)

/// <summary>
/// JWT 토큰 생성하기
/// </summary>
/// <param name="claimEnumerable">클레임 열거 가능형</param>
/// <param name="secretKey">비밀 키</param>
/// <param name="issuer">발행자</param>
/// <param name="audience">청취자</param>
/// <returns>JWT 토큰</returns>
public string GenerateJWTToken(IEnumerable<Claim> claimEnumerable, string secretKey, string issuer, string audience)
{
    byte[] keyByteArray = Encoding.UTF8.GetBytes(secretKey);

    SymmetricSecurityKey symmetricSecurityKey = new(keyByteArray);

    SigningCredentials credentials = new(symmetricSecurityKey, SecurityAlgorithms.HmacSha256);

    JwtSecurityToken token = new
    (
        issuer             : issuer,
        audience           : audience,
        claims             : claimEnumerable,
        expires            : DateTime.Now.AddHours(1),
        signingCredentials : credentials
    );

    string tokenString = new JwtSecurityTokenHandler().WriteToken(token);

    return tokenString;
}

#endregion

using System;

using System.Collections.Generic;

using System.IdentityModel.Tokens.Jwt;

using System.Security.Claims;

using System.Text;

using Microsoft.IdentityModel.Tokens;

#region JWT 토큰 생성하기 - GenerateJWTToken(claimEnumerable, secretKey, issuer, audience)

/// <summary>

/// JWT 토큰 생성하기

/// </summary>

/// <param name="claimEnumerable">클레임 열거 가능형</param>

/// <param name="secretKey">비밀 키</param>

/// <param name="issuer">발행자</param>

/// <param name="audience">청취자</param>

/// <returns>JWT 토큰</returns>

public string GenerateJWTToken(IEnumerable<Claim> claimEnumerable, string secretKey, string issuer, string audience)

{

byte[] keyByteArray = Encoding.UTF8.GetBytes(secretKey);

SymmetricSecurityKey symmetricSecurityKey = new(keyByteArray);

SigningCredentials credentials = new(symmetricSecurityKey, SecurityAlgorithms.HmacSha256);

JwtSecurityToken token = new

(

issuer : issuer,

audience : audience,

claims : claimEnumerable,

expires : DateTime.Now.AddHours(1),

signingCredentials : credentials

);

string tokenString = new JwtSecurityTokenHandler().WriteToken(token);

return tokenString;

}

#endregion

[C#/WEB API/.NET5] JWT 토큰에서 클레임 주체 구하기

■ JWT 토큰에서 클레임 주체를 구하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.IdentityModel.Tokens.Jwt;
using System.Security.Claims;
using System.Text;

using Microsoft.IdentityModel.Tokens;

#region 클레임 주체 구하기 - GetClaimsPrincipal(token, secretKey)

/// <summary>
/// 클레임 주체 구하기
/// </summary>
/// <param name="token">토큰</param>
/// <param name="secretKey">비밀 키</param>
/// <returns>클레임 주체</returns>
public ClaimsPrincipal GetClaimsPrincipal(string token, string secretKey)
{
    TokenValidationParameters parameters = new()
    {
        ValidateIssuer           = false,
        ValidateAudience         = false,
        ValidateLifetime         = false,
        ValidateIssuerSigningKey = true,
        IssuerSigningKey         = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(secretKey)),
    };

    JwtSecurityTokenHandler tokenHandler = new();

    ClaimsPrincipal principal = tokenHandler.ValidateToken(token, parameters, out SecurityToken securityToken);

    if
    (
        securityToken is not JwtSecurityToken jwtSecurityToken ||
        !jwtSecurityToken.Header.Alg.Equals(SecurityAlgorithms.HmacSha256, StringComparison.InvariantCultureIgnoreCase)
    )
    {
        throw new SecurityTokenException("Invalid token");
    }

    return principal;
}

#endregion

using System;

using System.IdentityModel.Tokens.Jwt;

using System.Security.Claims;

using System.Text;

using Microsoft.IdentityModel.Tokens;

#region 클레임 주체 구하기 - GetClaimsPrincipal(token, secretKey)

/// <summary>

/// 클레임 주체 구하기

/// </summary>

/// <param name="token">토큰</param>

/// <param name="secretKey">비밀 키</param>

/// <returns>클레임 주체</returns>

public ClaimsPrincipal GetClaimsPrincipal(string token, string secretKey)

{

TokenValidationParameters parameters = new()

{

ValidateIssuer = false,

ValidateAudience = false,

ValidateLifetime = false,

ValidateIssuerSigningKey = true,

IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(secretKey)),

};

JwtSecurityTokenHandler tokenHandler = new();

ClaimsPrincipal principal = tokenHandler.ValidateToken(token, parameters, out SecurityToken securityToken);

(

securityToken is not JwtSecurityToken jwtSecurityToken ||

!jwtSecurityToken.Header.Alg.Equals(SecurityAlgorithms.HmacSha256, StringComparison.InvariantCultureIgnoreCase)

)

{

throw new SecurityTokenException("Invalid token");

}

return principal;

}

#endregion

[C#/WEB API/.NET5] WEB API에서 JWT(Json Web Token) 인증 사용하기

■ WEB API에서 JWT(Json Web Token) 인증을 사용하는 방법을 보여준다. [TestLibrary 프로젝트] ▶ User.cs


namespace TestLibrary
{
    /// <summary>
    /// 사용자
    /// </summary>
    public class User
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 사용자명 - UserName

        /// <summary>
        /// 사용자명
        /// </summary>
        public string UserName { get; set; }

        #endregion
        #region 패스워드 - Password

        /// <summary>
        /// 패스워드
        /// </summary>
        public string Password { get; set; }

        #endregion
        #region 사용자 역할 - UserRole

        /// <summary>
        /// 사용자 역할
        /// </summary>
        public string UserRole { get; set; }

        #endregion
    }
}

namespace TestLibrary

{

/// <summary>

/// 사용자

/// </summary>

public class User

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 사용자명 - UserName

/// <summary>

/// 사용자명

/// </summary>

public string UserName { get; set; }

#endregion

#region 패스워드 - Password

/// <summary>

/// 패스워드

/// </summary>

public string Password { get; set; }

#endregion

#region 사용자 역할 - UserRole

/// <summary>

/// 사용자 역할

/// </summary>

public string UserRole { get; set; }

#endregion

}

▶ WeatherForecast.cs


using System;

namespace TestLibrary
{
    /// <summary>
    /// 기상 예보
    /// </summary>
    public class WeatherForecast
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 일자 - Date

        /// <summary>
        /// 일자
        /// </summary>
        public DateTime Date { get; set; }

        #endregion
        #region 섭씨 온도 - TemperatureC

        /// <summary>
        /// 섭씨 온도
        /// </summary>
        public int TemperatureC { get; set; }

        #endregion
        #region 화씨 온도 - TemperatureF

        /// <summary>
        /// 화씨 온도
        /// </summary>
        public int TemperatureF => 32 + (int)(TemperatureC / 0.5556);

        #endregion
        #region 요약 - Summary

        /// <summary>
        /// 요약
        /// </summary>
        public string Summary { get; set; }

        #endregion
    }
}

using System;

namespace TestLibrary

{

/// <summary>

/// 기상 예보

/// </summary>

public class WeatherForecast

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 일자 - Date

/// <summary>

/// 일자

/// </summary>

public DateTime Date { get; set; }

#endregion

#region 섭씨 온도 - TemperatureC

/// <summary>

/// 섭씨 온도

/// </summary>

public int TemperatureC { get; set; }

#endregion

#region 화씨 온도 - TemperatureF

/// <summary>

/// 화씨 온도

/// </summary>

public int TemperatureF => 32 + (int)(TemperatureC / 0.5556);

#endregion

#region 요약 - Summary

/// <summary>

/// 요약

/// </summary>

public string Summary { get; set; }

#endregion

}

[TestServer 프로젝트] ▶ appsettings.json

[C#/WEB API/.NET5] 스트림을 사용해 대용량 파일 업로드 하기

■ 스트림을 사용해 대용량 파일을 업로드하는 방법을 보여준다. [TestServer 프로젝트] ▶ launchSettings.json


{
    "$schema"     : "http://json.schemastore.org/launchsettings.json",
    "iisSettings" :
    {
        "windowsAuthentication"   : false,
        "anonymousAuthentication" : true,
        "iisExpress"              :
        {
            "applicationUrl" : "http://localhost:41483",
            "sslPort"        : 44362
        }
    },
    "profiles" :
    {
        "IIS Express" :
        {
            "commandName"          : "IISExpress",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        },
        "TestServer" :
        {
            "commandName"          : "Project",
            "dotnetRunMessages"    : "true",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "applicationUrl"       : "https://localhost:5001;http://localhost:5000",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        }
    }
}

{

"$schema" : "http://json.schemastore.org/launchsettings.json",

"iisSettings" :

{

"windowsAuthentication" : false,

"anonymousAuthentication" : true,

"iisExpress" :

{

"applicationUrl" : "http://localhost:41483",

"sslPort" : 44362

}

"profiles" :

{

"IIS Express" :

{

"commandName" : "IISExpress",

"launchBrowser" : true,

"launchUrl" : "swagger",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

"TestServer" :

{

"commandName" : "Project",

"dotnetRunMessages" : "true",

"launchBrowser" : true,

"launchUrl" : "swagger",

"applicationUrl" : "https://localhost:5001;http://localhost:5000",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

▶ appsettings.json


{
    "Logging" :
    {
        "LogLevel" :
        {
            "Default"                    : "Information",
            "Microsoft"                  : "Warning",
            "Microsoft.Hosting.Lifetime" : "Information"
        }
    },
    "AllowedHosts" : "*",
    "APIKey"       : "A7A54AD3-91E1-4C3A-98C6-A17E39C9EA3D"
}

{

"Logging" :

{

"LogLevel" :

{

"Default" : "Information",

"Microsoft" : "Warning",

"Microsoft.Hosting.Lifetime" : "Information"

}

"AllowedHosts" : "*",

"APIKey" : "A7A54AD3-91E1-4C3A-98C6-A17E39C9EA3D"

}

▶ web.config


<?xml version="1.0" encoding="utf-8"?>
<configuration>
    <system.webServer>
        <security>
            <requestFiltering>
                <requestLimits maxAllowedContentLength="2147483648" />
            </requestFiltering>
        </security>
    </system.webServer>
</configuration>

<?xml version="1.0" encoding="utf-8"?>

<system.webServer>

</requestFiltering>

</security>

</system.webServer>

</configuration>

※ IIS Express

[C#/WEB API/.NET5] 대용량 파일 업로드 하기 (2GB 제한)

■ 대용량 파일을 업로드하는 방법을 보여준다. (2GB 제한) [TestServer 프로젝트] ▶ launchSettings.json


{
    "$schema"     : "http://json.schemastore.org/launchsettings.json",
    "iisSettings" :
    {
        "windowsAuthentication"   : false,
        "anonymousAuthentication" : true,
        "iisExpress"              :
        {
            "applicationUrl" : "http://localhost:41483",
            "sslPort"        : 44362
        }
    },
    "profiles" :
    {
        "IIS Express" :
        {
            "commandName"          : "IISExpress",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        },
        "TestServer" :
        {
            "commandName"          : "Project",
            "dotnetRunMessages"    : "true",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "applicationUrl"       : "https://localhost:5001;http://localhost:5000",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        }
    }
}

{

"$schema" : "http://json.schemastore.org/launchsettings.json",

"iisSettings" :

{

"windowsAuthentication" : false,

"anonymousAuthentication" : true,

"iisExpress" :

{

"applicationUrl" : "http://localhost:41483",

"sslPort" : 44362

}

"profiles" :

{

"IIS Express" :

{

"commandName" : "IISExpress",

"launchBrowser" : true,

"launchUrl" : "swagger",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

"TestServer" :

{

"commandName" : "Project",

"dotnetRunMessages" : "true",

"launchBrowser" : true,

"launchUrl" : "swagger",

"applicationUrl" : "https://localhost:5001;http://localhost:5000",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

▶ appsettings.json


{
    "Logging" :
    {
        "LogLevel" :
        {
            "Default"                    : "Information",
            "Microsoft"                  : "Warning",
            "Microsoft.Hosting.Lifetime" : "Information"
        }
    },
    "AllowedHosts" : "*",
    "APIKey"       : "A7A54AD3-91E1-4C3A-98C6-A17E39C9EA3D"
}

{

"Logging" :

{

"LogLevel" :

{

"Default" : "Information",

"Microsoft" : "Warning",

"Microsoft.Hosting.Lifetime" : "Information"

}

"AllowedHosts" : "*",

"APIKey" : "A7A54AD3-91E1-4C3A-98C6-A17E39C9EA3D"

}

▶ web.config


<?xml version="1.0" encoding="utf-8"?>
<configuration>
    <system.webServer>
        <security>
            <requestFiltering>
                <requestLimits maxAllowedContentLength="2147483648" />
            </requestFiltering>
        </security>
    </system.webServer>
</configuration>

<?xml version="1.0" encoding="utf-8"?>

<system.webServer>

</requestFiltering>

</security>

</system.webServer>

</configuration>

▶ APIKeyAttribute.cs


using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Filters;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Threading.Tasks;

namespace TestServer
{
    /// <summary>
    /// API 키 어트리뷰트
    /// </summary>
    [AttributeUsage(validOn: AttributeTargets.Class)]
    public class APIKeyAttribute : Attribute, IAsyncActionFilter
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Public

        #region Field

        /// <summary>
        /// API 키명
        /// </summary>
        public static readonly string API_KEY_NAME = "APIKey";

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Public

        #region 액션 실행시 처리하기 (비동기) - OnActionExecutionAsync(context, nextAction)

        /// <summary>
        /// 액션 실행시 처리하기 (비동기)
        /// </summary>
        /// <param name="context">액션 실행 컨텍스트</param>
        /// <param name="nextAction">다음 액션 실행 대리자</param>
        /// <returns>태스크</returns>
        public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate nextAction)
        {
            if(!context.HttpContext.Request.Headers.TryGetValue(API_KEY_NAME, out var sourceAPIKey))
            {
                context.Result = new ContentResult()
                {
                    StatusCode = 401,
                    Content    = "API Key was not provided."
                };

                return;
            }

            IConfiguration configuration = context.HttpContext.RequestServices.GetRequiredService<IConfiguration>();

            string targetAPIKey = configuration.GetValue<string>(API_KEY_NAME);

            if(!targetAPIKey.Equals(sourceAPIKey))
            {
                context.Result = new ContentResult()
                {
                    StatusCode = 401,
                    Content    = "API Key is not valid."
                };

                return;
            }

            await nextAction();
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Mvc;

using Microsoft.AspNetCore.Mvc.Filters;

using Microsoft.Extensions.Configuration;

using Microsoft.Extensions.DependencyInjection;

using System;

using System.Threading.Tasks;

namespace TestServer

{

/// <summary>

/// API 키 어트리뷰트

/// </summary>

[AttributeUsage(validOn: AttributeTargets.Class)]

public class APIKeyAttribute : Attribute, IAsyncActionFilter

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region Field

/// <summary>

/// API 키명

/// </summary>

public static readonly string API_KEY_NAME = "APIKey";

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region 액션 실행시 처리하기 (비동기) - OnActionExecutionAsync(context, nextAction)

/// <summary>

/// 액션 실행시 처리하기 (비동기)

/// </summary>

/// <param name="context">액션 실행 컨텍스트</param>

/// <param name="nextAction">다음 액션 실행 대리자</param>

/// <returns>태스크</returns>

public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate nextAction)

{

if(!context.HttpContext.Request.Headers.TryGetValue(API_KEY_NAME, out var sourceAPIKey))

{

context.Result = new ContentResult()

{

StatusCode = 401,

Content = "API Key was not provided."

};

return;

}

IConfiguration configuration = context.HttpContext.RequestServices.GetRequiredService<IConfiguration>();

string targetAPIKey = configuration.GetValue<string>(API_KEY_NAME);

if(!targetAPIKey.Equals(sourceAPIKey))

{

context.Result = new ContentResult()

{

StatusCode = 401,

Content = "API Key is not valid."

};

return;

}

await nextAction();

}

#endregion

}

[C#/WEB API/.NET5] 대용량 데이터를 스트리밍 방식으로 전달받기 (PostgreSQL 연동)

■ 대용량 데이터를 스트리밍 방식으로 전달받는 방법을 보여준다. (PostgreSQL 연동) [TestClient 프로젝트] ▶ Program.cs


using System;
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;

using Newtonsoft.Json;

namespace TestClient
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        static void Main()
        {
            string url = "https://localhost:44352/api/data/inquirylist";

            DataSearchConditionModel searchCondition = new DataSearchConditionModel();

            searchCondition.MENU_ID      = "A007A6D5-35E6-46A2-A3BD-1B84843BB76C";
            searchCondition.MEMBER_GRADE = "99";
            searchCondition.LIMIT_AGE    = "99";
            searchCondition.WRITE_DATE1  = new DateTime(2021, 7 , 1 );
            searchCondition.WRITE_DATE2  = new DateTime(2021, 7 , 25);
            searchCondition.CREATE_TIME1 = new DateTime(1   , 1 , 1 );
            searchCondition.CREATE_TIME2 = new DateTime(9999, 12, 31);

            int i = 0;

            var result = GetPOSTData1<DataModel>(url, searchCondition);

            foreach(DataModel photo in result)
            {
                Console.WriteLine("{0} {1} {2}", i++, photo.ID, photo.SUBJECT);
            }
        }

        #endregion

        #region POST 스트림 구하기 - POSTGetStream(serverURL, contentType, encoding, argument, timeOut)

        /// <summary>
        /// POST 스트림 구하기
        /// </summary>
        /// <param name="serverURL">서버 URL</param>
        /// <param name="contentType">컨텐츠 타입</param>
        /// <param name="encoding">인코딩</param>
        /// <param name="argument">인자 문자열</param>
        /// <param name="timeOut">타임 아웃</param>
        /// <returns>POST 스트림</returns>
        private static Stream POSTGetStream(string serverURL, string contentType, Encoding encoding, string argument, int? timeOut = null)
        {
            byte[] argumentArray = encoding.GetBytes(argument);

            HttpWebRequest request = WebRequest.Create(serverURL) as HttpWebRequest;

            request.ProtocolVersion           = HttpVersion.Version11;
            request.AllowAutoRedirect         = true;
            request.AllowWriteStreamBuffering = true;
            request.Method                    = WebRequestMethods.Http.Post;
            request.ContentType               = contentType;
            request.ContentLength             = argumentArray.Length;

            if(timeOut.HasValue)
            {
                request.Timeout = timeOut.Value;
            }

            using(Stream requestStream = request.GetRequestStream())
            {
                requestStream.Write(argumentArray, 0, argumentArray.Length);
            }

            HttpWebResponse response = request.GetResponse() as HttpWebResponse;

            Stream responseStream = response.GetResponseStream();

            return responseStream;
        }

        #endregion

        #region POST 데이터 구하기 1 - GetPOSTData1<TResultItem>(url, source)

        /// <summary>
        /// POST 데이터 구하기 1
        /// </summary>
        /// <typeparam name="TResultItem">결과 항목 타입</typeparam>
        /// <param name="url">URL</param>
        /// <param name="source">소스 객체</param>
        /// <returns>결과 항목 타입 열거 가능형</returns>
        private static IEnumerable<TResultItem> GetPOSTData1<TResultItem>(string url, object source)
        {
            string sourceJSON = JsonConvert.SerializeObject(source);

            HttpRequestMessage requestMessage = new HttpRequestMessage(HttpMethod.Post, url);

            requestMessage.Content = new StringContent(sourceJSON, Encoding.UTF8, "application/json");

            requestMessage.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));

            HttpClient client = new HttpClient();

            HttpResponseMessage responseMessage = client.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead).Result;

            responseMessage.EnsureSuccessStatusCode();

            using(Stream stream = responseMessage.Content.ReadAsStreamAsync().Result)
            {
                using(StreamReader streamReader = new StreamReader(stream))
                {
                    JsonSerializer serializer = new JsonSerializer();

                    using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))
                    {
                        while(jsonTextReader.Read())
                        {
                            if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)
                            {
                                yield return serializer.Deserialize<TResultItem>(jsonTextReader);
                            }
                        }
                    }
                }
            }
        }

        #endregion
        #region POST 데이터 구하기 2 - GetPOSTData2<TResultItem>(url, source)

        /// <summary>
        /// POST 데이터 구하기 2
        /// </summary>
        /// <typeparam name="TResultItem">결과 항목 타입</typeparam>
        /// <param name="url">URL</param>
        /// <param name="source">소스 객체</param>
        /// <returns>결과 항목 타입 열거 가능형</returns>
        private static IEnumerable<TResultItem> GetPOSTData2<TResultItem>(string url, object source)
        {
            string sourceJSON = JsonConvert.SerializeObject(source);

            using(Stream stream = POSTGetStream(url, "application/json; charset=utf-8", Encoding.UTF8, sourceJSON))
            {
                using(StreamReader streamReader = new StreamReader(stream))
                {
                    using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))
                    {
                        JsonSerializer serializer = new JsonSerializer();

                        while(jsonTextReader.Read())
                        {
                            if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)
                            {
                                yield return serializer.Deserialize<TResultItem>(jsonTextReader);
                            }
                        }
                    }
                }
            }
        }

        #endregion
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

using System;

using System.Collections.Generic;

using System.IO;

using System.Net;

using System.Net.Http;

using System.Net.Http.Headers;

using System.Text;

using Newtonsoft.Json;

namespace TestClient

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

static void Main()

{

string url = "https://localhost:44352/api/data/inquirylist";

DataSearchConditionModel searchCondition = new DataSearchConditionModel();

searchCondition.MENU_ID = "A007A6D5-35E6-46A2-A3BD-1B84843BB76C";

searchCondition.MEMBER_GRADE = "99";

searchCondition.LIMIT_AGE = "99";

searchCondition.WRITE_DATE1 = new DateTime(2021, 7 , 1 );

searchCondition.WRITE_DATE2 = new DateTime(2021, 7 , 25);

searchCondition.CREATE_TIME1 = new DateTime(1 , 1 , 1 );

searchCondition.CREATE_TIME2 = new DateTime(9999, 12, 31);

int i = 0;

var result = GetPOSTData1<DataModel>(url, searchCondition);

foreach(DataModel photo in result)

{

Console.WriteLine("{0} {1} {2}", i++, photo.ID, photo.SUBJECT);

}

#endregion

#region POST 스트림 구하기 - POSTGetStream(serverURL, contentType, encoding, argument, timeOut)

/// <summary>

/// POST 스트림 구하기

/// </summary>

/// <param name="serverURL">서버 URL</param>

/// <param name="contentType">컨텐츠 타입</param>

/// <param name="encoding">인코딩</param>

/// <param name="argument">인자 문자열</param>

/// <param name="timeOut">타임 아웃</param>

/// <returns>POST 스트림</returns>

private static Stream POSTGetStream(string serverURL, string contentType, Encoding encoding, string argument, int? timeOut = null)

{

byte[] argumentArray = encoding.GetBytes(argument);

HttpWebRequest request = WebRequest.Create(serverURL) as HttpWebRequest;

request.ProtocolVersion = HttpVersion.Version11;

request.AllowAutoRedirect = true;

request.AllowWriteStreamBuffering = true;

request.Method = WebRequestMethods.Http.Post;

request.ContentType = contentType;

request.ContentLength = argumentArray.Length;

if(timeOut.HasValue)

{

request.Timeout = timeOut.Value;

}

using(Stream requestStream = request.GetRequestStream())

{

requestStream.Write(argumentArray, 0, argumentArray.Length);

}

HttpWebResponse response = request.GetResponse() as HttpWebResponse;

Stream responseStream = response.GetResponseStream();

return responseStream;

}

#endregion

#region POST 데이터 구하기 1 - GetPOSTData1<TResultItem>(url, source)

/// <summary>

/// POST 데이터 구하기 1

/// </summary>

/// <typeparam name="TResultItem">결과 항목 타입</typeparam>

/// <param name="url">URL</param>

/// <param name="source">소스 객체</param>

/// <returns>결과 항목 타입 열거 가능형</returns>

private static IEnumerable<TResultItem> GetPOSTData1<TResultItem>(string url, object source)

{

string sourceJSON = JsonConvert.SerializeObject(source);

HttpRequestMessage requestMessage = new HttpRequestMessage(HttpMethod.Post, url);

requestMessage.Content = new StringContent(sourceJSON, Encoding.UTF8, "application/json");

requestMessage.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));

HttpClient client = new HttpClient();

HttpResponseMessage responseMessage = client.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead).Result;

responseMessage.EnsureSuccessStatusCode();

using(Stream stream = responseMessage.Content.ReadAsStreamAsync().Result)

{

using(StreamReader streamReader = new StreamReader(stream))

{

JsonSerializer serializer = new JsonSerializer();

using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))

{

while(jsonTextReader.Read())

{

if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)

{

yield return serializer.Deserialize<TResultItem>(jsonTextReader);

}

#endregion

#region POST 데이터 구하기 2 - GetPOSTData2<TResultItem>(url, source)

/// <summary>

/// POST 데이터 구하기 2

/// </summary>

/// <typeparam name="TResultItem">결과 항목 타입</typeparam>

/// <param name="url">URL</param>

/// <param name="source">소스 객체</param>

/// <returns>결과 항목 타입 열거 가능형</returns>

private static IEnumerable<TResultItem> GetPOSTData2<TResultItem>(string url, object source)

{

string sourceJSON = JsonConvert.SerializeObject(source);

using(Stream stream = POSTGetStream(url, "application/json; charset=utf-8", Encoding.UTF8, sourceJSON))

{

using(StreamReader streamReader = new StreamReader(stream))

{

using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))

{

JsonSerializer serializer = new JsonSerializer();

while(jsonTextReader.Read())

{

if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)

{

yield return serializer.Deserialize<TResultItem>(jsonTextReader);

}

#endregion

}

[TestServer 프로젝트] ▶ launchSettings.json


{
    "$schema"     : "http://json.schemastore.org/launchsettings.json",
    "iisSettings" :
    {
        "windowsAuthentication"   : false,
        "anonymousAuthentication" : true,
        "iisExpress"              :
        {
            "applicationUrl" : "http://localhost:35043",
            "sslPort"        : 44352
        }
    },
    "profiles" :
    {
        "IIS Express" :
        {
            "commandName"          : "IISExpress",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        },
        "TestServer" :
        {
            "commandName"          : "Project",
            "dotnetRunMessages"    : "true",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "applicationUrl"       : "https://localhost:5001;http://localhost:5000",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        }
    }
}

{

"$schema" : "http://json.schemastore.org/launchsettings.json",

"iisSettings" :

{

"windowsAuthentication" : false,

"anonymousAuthentication" : true,

"iisExpress" :

{

"applicationUrl" : "http://localhost:35043",

"sslPort" : 44352

}

"profiles" :

{

"IIS Express" :

{

"commandName" : "IISExpress",

"launchBrowser" : true,

"launchUrl" : "swagger",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

"TestServer" :

{

"commandName" : "Project",

"dotnetRunMessages" : "true",

"launchBrowser" : true,

"launchUrl" : "swagger",

"applicationUrl" : "https://localhost:5001;http://localhost:5000",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

▶ appsettings.json

[C#/WEB API/.NET5] PostgreSQL 데이터베이스 사용하기

■ PostgreSQL 데이터베이스를 사용하는 방법을 보여준다. ▶ launchSettings.json


{
    "$schema"     : "http://json.schemastore.org/launchsettings.json",
    "iisSettings" :
    {
        "windowsAuthentication"   : false,
        "anonymousAuthentication" : true,
        "iisExpress"              :
        {
            "applicationUrl" : "http://localhost:35043",
            "sslPort"        : 44352
        }
    },
    "profiles" :
    {
        "IIS Express" :
        {
            "commandName"          : "IISExpress",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        },
        "TestProject" :
        {
            "commandName"          : "Project",
            "dotnetRunMessages"    : "true",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "applicationUrl"       : "https://localhost:5001;http://localhost:5000",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        }
    }
}

{

"$schema" : "http://json.schemastore.org/launchsettings.json",

"iisSettings" :

{

"windowsAuthentication" : false,

"anonymousAuthentication" : true,

"iisExpress" :

{

"applicationUrl" : "http://localhost:35043",

"sslPort" : 44352

}

"profiles" :

{

"IIS Express" :

{

"commandName" : "IISExpress",

"launchBrowser" : true,

"launchUrl" : "swagger",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

"TestProject" :

{

"commandName" : "Project",

"dotnetRunMessages" : "true",

"launchBrowser" : true,

"launchUrl" : "swagger",

"applicationUrl" : "https://localhost:5001;http://localhost:5000",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

▶ appsettings.json


{
    "Logging" :
    {
        "LogLevel" :
        {
            "Default"                    : "Information",
            "Microsoft"                  : "Warning",
            "Microsoft.Hosting.Lifetime" : "Information"
        }
    },
    "AllowedHosts"      : "*",
    "ConnectionStrings" :
    {
        "DefaultConnection" : "Server=localhost;Port=5432;Database=arca;User Id=admin;Password=1234;"
    }
}

{

"Logging" :

{

"LogLevel" :

{

"Default" : "Information",

"Microsoft" : "Warning",

"Microsoft.Hosting.Lifetime" : "Information"

}

"AllowedHosts" : "*",

"ConnectionStrings" :

{

"DefaultConnection" : "Server=localhost;Port=5432;Database=arca;User Id=admin;Password=1234;"

}

▶ Models/CodeModel.cs


namespace TestProject.Models
{
    /// <summary>
    /// 코드 모델
    /// </summary>
    public class CodeModel
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region ID - ID (NOT NULL)

        /// <summary>
        /// ID
        /// </summary>
        public string ID { get; set; }

        #endregion
        #region 그룹 ID - GROUP_ID (NOT NULL)

        /// <summary>
        /// 그룹 ID
        /// </summary>
        public string GROUP_ID { get; set; }

        #endregion
        #region 명칭 - NAME (NOT NULL)

        /// <summary>
        /// 명칭
        /// </summary>
        public string NAME { get; set; }

        #endregion
        #region 값 - VALUE (NOT NULL)

        /// <summary>
        /// 값
        /// </summary>
        public string VALUE { get; set; }

        #endregion
        #region 표시 순서 - DISPLAY_ORDER (NOT NULL)

        /// <summary>
        /// 표시 순서
        /// </summary>
        public int DISPLAY_ORDER { get; set; }

        #endregion
        #region 상태 코드 - STATUS_CODE (NOT NULL)

        /// <summary>
        /// 상태 코드
        /// </summary>
        /// <remarks>
        /// A : 활성
        /// D : 삭제
        /// </remarks>
        public string STATUS_CODE { get; set; }

        #endregion
    }
}

namespace TestProject.Models

{

/// <summary>

/// 코드 모델

/// </summary>

public class CodeModel

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID (NOT NULL)

/// <summary>

/// ID

/// </summary>

public string ID { get; set; }

#endregion

#region 그룹 ID - GROUP_ID (NOT NULL)

/// <summary>

/// 그룹 ID

/// </summary>

public string GROUP_ID { get; set; }

#endregion

#region 명칭 - NAME (NOT NULL)

/// <summary>

/// 명칭

/// </summary>

public string NAME { get; set; }

#endregion

#region 값 - VALUE (NOT NULL)

/// <summary>

/// 값

/// </summary>

public string VALUE { get; set; }

#endregion

#region 표시 순서 - DISPLAY_ORDER (NOT NULL)

/// <summary>

/// 표시 순서

/// </summary>

public int DISPLAY_ORDER { get; set; }

#endregion

#region 상태 코드 - STATUS_CODE (NOT NULL)

/// <summary>

/// 상태 코드

/// </summary>

/// <remarks>

/// A : 활성

/// D : 삭제

/// </remarks>

public string STATUS_CODE { get; set; }

#endregion

}

▶ Models/CodeKeyModel.cs


namespace TestProject.Models
{
    /// <summary>
    /// 코드 키 모델
    /// </summary>
    public class CodeKeyModel
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region ID - ID

        /// <summary>
        /// ID
        /// </summary>
        public string ID { get; set; }

        #endregion
        #region 그룹 ID - GROUP_ID

        /// <summary>
        /// 그룹 ID
        /// </summary>
        public string GROUP_ID { get; set; }

        #endregion
    }
}

namespace TestProject.Models

{

/// <summary>

/// 코드 키 모델

/// </summary>

public class CodeKeyModel

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public string ID { get; set; }

#endregion

#region 그룹 ID - GROUP_ID

/// <summary>

/// 그룹 ID

/// </summary>

public string GROUP_ID { get; set; }

#endregion

}

▶ CodeController.cs


using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using System.Collections.Generic;
using System.Data;
using System.Linq;

using Npgsql;

using Dapper;

using TestProject.Models;

namespace TestProject.Controllers
{
    [ApiController]
    [Route("[controller]")]
    public class CodeController : ControllerBase
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region INQUIRY_LIST_SQL

        /// <summary>
        /// INQUIRY_LIST_SQL
        /// </summary>
        private static string INQUIRY_LIST_SQL = @"
SELECT
    A.ID            AS ID
   ,A.GROUP_ID      AS GROUP_ID
   ,A.NAME          AS NAME
   ,A.VALUE         AS VALUE
   ,A.DISPLAY_ORDER AS DISPLAY_ORDER
   ,A.STATUS_CODE   AS STATUS_CODE
FROM     COM_CODE A
WHERE    A.GROUP_ID = @GROUP_ID
ORDER BY A.DISPLAY_ORDER ASC
";

        #endregion
        #region INQUIRY_ITEM

        /// <summary>
        /// INQUIRY_ITEM_SQL
        /// </summary>
        private static string INQUIRY_ITEM_SQL = @"
SELECT
    A.ID            AS ID
   ,A.GROUP_ID      AS GROUP_ID
   ,A.NAME          AS NAME
   ,A.VALUE         AS VALUE
   ,A.DISPLAY_ORDER AS DISPLAY_ORDER
   ,A.STATUS_CODE   AS STATUS_CODE
FROM  COM_CODE A
WHERE A.ID = @ID
";

        #endregion

        ////////////////////////////////////////////////////////////////////////////////////////// Instance
        //////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 구성
        /// </summary>
        private readonly IConfiguration configuration;

        /// <summary>
        /// 로거
        /// </summary>
        private readonly ILogger<CodeController> logger;

        /// <summary>
        /// 연결 문자열
        /// </summary>
        private readonly string connectionString;

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - CodeController(configuration, logger)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="configuration">구성</param>
        /// <param name="logger">로거</param>
        public CodeController(IConfiguration configuration, ILogger<CodeController> logger)
        {
            this.configuration    = configuration;
            this.logger           = logger;
            this.connectionString = configuration.GetConnectionString("DefaultConnection");
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 리스트 조회하기 - InquiryList(groupID)

        /// <summary>
        /// 리스트 조회하기
        /// </summary>
        /// <param name="groupID">그룹 ID</param>
        /// <returns>리스트</returns>
        [HttpGet]
        [Route("InquiryList")]
        public IEnumerable<CodeModel> InquiryList(string groupID)
        {
            using(IDbConnection connection = CreateConnection())
            {
                var result = connection.Query<CodeModel>(INQUIRY_LIST_SQL, new CodeKeyModel { GROUP_ID = groupID });

                return result;
            }
        }

        #endregion
        #region 항목 조회하기 - InquiryItem(id)

        /// <summary>
        /// 항목 조회하기
        /// </summary>
        /// <param name="id">ID</param>
        /// <returns></returns>
        [HttpGet]
        [Route("InquiryItem")]
        public CodeModel InquiryItem(string id)
        {
            using(IDbConnection connection = CreateConnection())
            {
                var result = connection.Query<CodeModel>(INQUIRY_ITEM_SQL, new CodeKeyModel { ID = id });

                return result.FirstOrDefault();
            }
        }

        #endregion

        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region 연결 생성하기 - CreateConnection()

        /// <summary>
        /// 연결 생성하기
        /// </summary>
        /// <returns>연결</returns>
        private IDbConnection CreateConnection()
        {
            return new NpgsqlConnection(this.connectionString);
        }

        #endregion
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

using Microsoft.AspNetCore.Mvc;

using Microsoft.Extensions.Configuration;

using Microsoft.Extensions.Logging;

using System.Collections.Generic;

using System.Data;

using System.Linq;

using Npgsql;

using Dapper;

using TestProject.Models;

namespace TestProject.Controllers

{

[ApiController]

[Route("[controller]")]

public class CodeController : ControllerBase

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region INQUIRY_LIST_SQL

/// <summary>

/// INQUIRY_LIST_SQL

/// </summary>

private static string INQUIRY_LIST_SQL = @"

SELECT

A.ID AS ID

,A.GROUP_ID AS GROUP_ID

,A.NAME AS NAME

,A.VALUE AS VALUE

,A.DISPLAY_ORDER AS DISPLAY_ORDER

,A.STATUS_CODE AS STATUS_CODE

FROM COM_CODE A

WHERE A.GROUP_ID = @GROUP_ID

ORDER BY A.DISPLAY_ORDER ASC

#endregion

#region INQUIRY_ITEM

/// <summary>

/// INQUIRY_ITEM_SQL

/// </summary>

private static string INQUIRY_ITEM_SQL = @"

SELECT

A.ID AS ID

,A.GROUP_ID AS GROUP_ID

,A.NAME AS NAME

,A.VALUE AS VALUE

,A.DISPLAY_ORDER AS DISPLAY_ORDER

,A.STATUS_CODE AS STATUS_CODE

FROM COM_CODE A

WHERE A.ID = @ID

#endregion

////////////////////////////////////////////////////////////////////////////////////////// Instance

//////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// 구성

/// </summary>

private readonly IConfiguration configuration;

/// <summary>

/// 로거

/// </summary>

private readonly ILogger<CodeController> logger;

/// <summary>

/// 연결 문자열

/// </summary>

private readonly string connectionString;

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - CodeController(configuration, logger)

/// <summary>

/// 생성자

/// </summary>

/// <param name="configuration">구성</param>

/// <param name="logger">로거</param>

public CodeController(IConfiguration configuration, ILogger<CodeController> logger)

{

this.configuration = configuration;

this.logger = logger;

this.connectionString = configuration.GetConnectionString("DefaultConnection");

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 리스트 조회하기 - InquiryList(groupID)

/// <summary>

/// 리스트 조회하기

/// </summary>

/// <param name="groupID">그룹 ID</param>

/// <returns>리스트</returns>

[HttpGet]

[Route("InquiryList")]

public IEnumerable<CodeModel> InquiryList(string groupID)

{

using(IDbConnection connection = CreateConnection())

{

var result = connection.Query<CodeModel>(INQUIRY_LIST_SQL, new CodeKeyModel { GROUP_ID = groupID });

return result;

}

#endregion

#region 항목 조회하기 - InquiryItem(id)

/// <summary>

/// 항목 조회하기

/// </summary>

/// <param name="id">ID</param>

/// <returns></returns>

[HttpGet]

[Route("InquiryItem")]

public CodeModel InquiryItem(string id)

{

using(IDbConnection connection = CreateConnection())

{

var result = connection.Query<CodeModel>(INQUIRY_ITEM_SQL, new CodeKeyModel { ID = id });

return result.FirstOrDefault();

}

#endregion

////////////////////////////////////////////////////////////////////////////////////////// Private

#region 연결 생성하기 - CreateConnection()

/// <summary>

/// 연결 생성하기

/// </summary>

/// <returns>연결</returns>

private IDbConnection CreateConnection()

{

return new NpgsqlConnection(this.connectionString);

}

#endregion

}

▶

[C#/WEB API/.NET5] 커스텀 미들웨어를 사용해 API 키 인증하기

■ 커스텀 미들웨어를 사용해 API 키를 인증하는 방법을 보여준다. [TestServer 프로젝트] ▶ Properteis/launchSettings.json


{
    "$schema"     : "http://json.schemastore.org/launchsettings.json",
    "iisSettings" :
    {
        "windowsAuthentication"   : false,
        "anonymousAuthentication" : true,
        "iisExpress"              :
        {
            "applicationUrl" : "http://localhost:41483",
            "sslPort"        : 44362
        }
    },
    "profiles" :
    {
        "IIS Express" :
        {
            "commandName"          : "IISExpress",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        },
        "TestServer" :
        {
            "commandName"          : "Project",
            "dotnetRunMessages"    : "true",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "applicationUrl"       : "https://localhost:5001;http://localhost:5000",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        }
    }
}

{

"$schema" : "http://json.schemastore.org/launchsettings.json",

"iisSettings" :

{

"windowsAuthentication" : false,

"anonymousAuthentication" : true,

"iisExpress" :

{

"applicationUrl" : "http://localhost:41483",

"sslPort" : 44362

}

"profiles" :

{

"IIS Express" :

{

"commandName" : "IISExpress",

"launchBrowser" : true,

"launchUrl" : "swagger",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

"TestServer" :

{

"commandName" : "Project",

"dotnetRunMessages" : "true",

"launchBrowser" : true,

"launchUrl" : "swagger",

"applicationUrl" : "https://localhost:5001;http://localhost:5000",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

▶ appsettings.json


{
    "Logging" :
    {
        "LogLevel" :
        {
            "Default"                    : "Information",
            "Microsoft"                  : "Warning",
            "Microsoft.Hosting.Lifetime" : "Information"
        }
    },
    "AllowedHosts" : "*",
    "APIKey"       : "A7A54AD3-91E1-4C3A-98C6-A17E39C9EA3D"
}

{

"Logging" :

{

"LogLevel" :

{

"Default" : "Information",

"Microsoft" : "Warning",

"Microsoft.Hosting.Lifetime" : "Information"

}

"AllowedHosts" : "*",

"APIKey" : "A7A54AD3-91E1-4C3A-98C6-A17E39C9EA3D"

}

▶ APIKeyMiddleware.cs


using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using System.Threading.Tasks;

namespace TestServer
{
    /// <summary>
    /// API 키 미들웨어
    /// </summary>
    public class APIKeyMiddleware
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// API 키명
        /// </summary>
        private static readonly string API_KEY_NAME = "APIKey";

        #endregion

        ////////////////////////////////////////////////////////////////////////////////////////// Instance
        //////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 다음 액션
        /// </summary>
        private readonly RequestDelegate nextAction;

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - APIKeyMiddleware(nextAction)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="nextAction">다음 액션</param>
        public APIKeyMiddleware(RequestDelegate nextAction)
        {
            this.nextAction = nextAction;
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 호출하기 (비동기) - InvokeAsync(context)

        /// <summary>
        /// 호출하기 (비동기)
        /// </summary>
        /// <param name="context">HTTP 컨텍스트</param>
        /// <returns>태스크</returns>
        public async Task InvokeAsync(HttpContext context)
        {
            if(!context.Request.Headers.TryGetValue(API_KEY_NAME, out var sourceAPIKey))
            {
                context.Response.StatusCode = 401;

                await context.Response.WriteAsync("API Key was not provided.");

                return;
            }

            IConfiguration configuration = context.RequestServices.GetRequiredService<IConfiguration>();

            string targetAPIKey = configuration.GetValue<string>(API_KEY_NAME);

            if(!targetAPIKey.Equals(sourceAPIKey))
            {
                context.Response.StatusCode = 401;

                await context.Response.WriteAsync("Unauthorized client.");

                return;
            }

            await nextAction(context);
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Http;

using Microsoft.Extensions.Configuration;

using Microsoft.Extensions.DependencyInjection;

using System.Threading.Tasks;

namespace TestServer

{

/// <summary>

/// API 키 미들웨어

/// </summary>

public class APIKeyMiddleware

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// API 키명

/// </summary>

private static readonly string API_KEY_NAME = "APIKey";

#endregion

////////////////////////////////////////////////////////////////////////////////////////// Instance

//////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// 다음 액션

/// </summary>

private readonly RequestDelegate nextAction;

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - APIKeyMiddleware(nextAction)

/// <summary>

/// 생성자

/// </summary>

/// <param name="nextAction">다음 액션</param>

public APIKeyMiddleware(RequestDelegate nextAction)

{

this.nextAction = nextAction;

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 호출하기 (비동기) - InvokeAsync(context)

/// <summary>

/// 호출하기 (비동기)

/// </summary>

/// <param name="context">HTTP 컨텍스트</param>

/// <returns>태스크</returns>

public async Task InvokeAsync(HttpContext context)

{

if(!context.Request.Headers.TryGetValue(API_KEY_NAME, out var sourceAPIKey))

{

context.Response.StatusCode = 401;

await context.Response.WriteAsync("API Key was not provided.");

return;

}

IConfiguration configuration = context.RequestServices.GetRequiredService<IConfiguration>();

string targetAPIKey = configuration.GetValue<string>(API_KEY_NAME);

if(!targetAPIKey.Equals(sourceAPIKey))

{

context.Response.StatusCode = 401;

await context.Response.WriteAsync("Unauthorized client.");

return;

}

await nextAction(context);

}

#endregion

}

▶ WeatherForecast.cs

[C#/WEB API/.NET5] IAsyncActionFilter 인터페이스 : API 키 인증하기

■ IAsyncActionFilter 인터페이스를 사용해 API 키를 인증하는 방법을 보여준다. [TestServer 프로젝트] ▶ Properteis/launchSettings.json


{
    "$schema"     : "http://json.schemastore.org/launchsettings.json",
    "iisSettings" :
    {
        "windowsAuthentication"   : false,
        "anonymousAuthentication" : true,
        "iisExpress"              :
        {
            "applicationUrl" : "http://localhost:41483",
            "sslPort"        : 44362
        }
    },
    "profiles" :
    {
        "IIS Express" :
        {
            "commandName"          : "IISExpress",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        },
        "TestServer" :
        {
            "commandName"          : "Project",
            "dotnetRunMessages"    : "true",
            "launchBrowser"        : true,
            "launchUrl"            : "swagger",
            "applicationUrl"       : "https://localhost:5001;http://localhost:5000",
            "environmentVariables" :
            {
                "ASPNETCORE_ENVIRONMENT" : "Development"
            }
        }
    }
}

{

"$schema" : "http://json.schemastore.org/launchsettings.json",

"iisSettings" :

{

"windowsAuthentication" : false,

"anonymousAuthentication" : true,

"iisExpress" :

{

"applicationUrl" : "http://localhost:41483",

"sslPort" : 44362

}

"profiles" :

{

"IIS Express" :

{

"commandName" : "IISExpress",

"launchBrowser" : true,

"launchUrl" : "swagger",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

"TestServer" :

{

"commandName" : "Project",

"dotnetRunMessages" : "true",

"launchBrowser" : true,

"launchUrl" : "swagger",

"applicationUrl" : "https://localhost:5001;http://localhost:5000",

"environmentVariables" :

{

"ASPNETCORE_ENVIRONMENT" : "Development"

}

▶ appsettings.json


{
    "Logging" :
    {
        "LogLevel" :
        {
            "Default"                    : "Information",
            "Microsoft"                  : "Warning",
            "Microsoft.Hosting.Lifetime" : "Information"
        }
    },
    "AllowedHosts" : "*",
    "APIKey"       : "A7A54AD3-91E1-4C3A-98C6-A17E39C9EA3D"
}

{

"Logging" :

{

"LogLevel" :

{

"Default" : "Information",

"Microsoft" : "Warning",

"Microsoft.Hosting.Lifetime" : "Information"

}

"AllowedHosts" : "*",

"APIKey" : "A7A54AD3-91E1-4C3A-98C6-A17E39C9EA3D"

}

▶ APIKeyAttribute.cs


using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Filters;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Threading.Tasks;

namespace TestServer
{
    /// <summary>
    /// API 키 어트리뷰트
    /// </summary>
    [AttributeUsage(validOn: AttributeTargets.Class)]
    public class APIKeyAttribute : Attribute, IAsyncActionFilter
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Public

        #region Field

        /// <summary>
        /// API 키명
        /// </summary>
        public static readonly string API_KEY_NAME = "APIKey";

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Public

        #region 액션 실행시 처리하기 (비동기) - OnActionExecutionAsync(context, nextAction)

        /// <summary>
        /// 액션 실행시 처리하기 (비동기)
        /// </summary>
        /// <param name="context">액션 실행 컨텍스트</param>
        /// <param name="nextAction">다음 액션 실행 대리자</param>
        /// <returns>태스크</returns>
        public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate nextAction)
        {
            if(!context.HttpContext.Request.Headers.TryGetValue(API_KEY_NAME, out var sourceAPIKey))
            {
                context.Result = new ContentResult()
                {
                    StatusCode = 401,
                    Content    = "API Key was not provided."
                };

                return;
            }

            IConfiguration configuration = context.HttpContext.RequestServices.GetRequiredService<IConfiguration>();

            string targetAPIKey = configuration.GetValue<string>(API_KEY_NAME);

            if(!targetAPIKey.Equals(sourceAPIKey))
            {
                context.Result = new ContentResult()
                {
                    StatusCode = 401,
                    Content    = "API Key is not valid."
                };

                return;
            }

            await nextAction();
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Mvc;

using Microsoft.AspNetCore.Mvc.Filters;

using Microsoft.Extensions.Configuration;

using Microsoft.Extensions.DependencyInjection;

using System;

using System.Threading.Tasks;

namespace TestServer

{

/// <summary>

/// API 키 어트리뷰트

/// </summary>

[AttributeUsage(validOn: AttributeTargets.Class)]

public class APIKeyAttribute : Attribute, IAsyncActionFilter

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region Field

/// <summary>

/// API 키명

/// </summary>

public static readonly string API_KEY_NAME = "APIKey";

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region 액션 실행시 처리하기 (비동기) - OnActionExecutionAsync(context, nextAction)

/// <summary>

/// 액션 실행시 처리하기 (비동기)

/// </summary>

/// <param name="context">액션 실행 컨텍스트</param>

/// <param name="nextAction">다음 액션 실행 대리자</param>

/// <returns>태스크</returns>

public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate nextAction)

{

if(!context.HttpContext.Request.Headers.TryGetValue(API_KEY_NAME, out var sourceAPIKey))

{

context.Result = new ContentResult()

{

StatusCode = 401,

Content = "API Key was not provided."

};

return;

}

IConfiguration configuration = context.HttpContext.RequestServices.GetRequiredService<IConfiguration>();

string targetAPIKey = configuration.GetValue<string>(API_KEY_NAME);

if(!targetAPIKey.Equals(sourceAPIKey))

{

context.Result = new ContentResult()

{

StatusCode = 401,

Content = "API Key is not valid."

};

return;

}

await nextAction();

}

#endregion

}

▶ WeatherForecast.cs

[C#/WEB API/.NETCORE] ControllerBase 클래스 : StatusCode 메소드를 사용해 검증 오류 처리하기

■ ControllerBase 클래스의 StatusCode 메소드를 사용해 검증 오류를 처리하는 방법을 보여준다. ▶ Startup.cs


using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

namespace TestProject
{
    /// <summary>
    /// 시작
    /// </summary>
    public class Startup
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 구성 - Configuration

        /// <summary>
        /// 구성
        /// </summary>
        public IConfiguration Configuration { get; }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - Startup(configuration)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="configuration">구성</param>
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 서비스 컬렉션 구성하기 - ConfigureServices(services)

        /// <summary>
        /// 서비스 컬렉션 구성하기
        /// </summary>
        /// <param name="services">서비스 컬렉션</param>
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllersWithViews();
        }

        #endregion
        #region 구성하기 - Configure(app, environment)

        /// <summary>
        /// 구성하기
        /// </summary>
        /// <param name="app">애플리케이션 빌더</param>
        /// <param name="environment">웹 호스트 환경</param>
        public void Configure(IApplicationBuilder app, IWebHostEnvironment environment)
        {
            if(environment.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }

            app.UseHttpsRedirection();

            app.UseRouting();

            app.UseAuthorization();

            app.UseEndpoints
            (
                endpoints =>
                {
                    endpoints.MapControllers();
                }
            );
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Builder;

using Microsoft.AspNetCore.Hosting;

using Microsoft.Extensions.Configuration;

using Microsoft.Extensions.DependencyInjection;

using Microsoft.Extensions.Hosting;

namespace TestProject

{

/// <summary>

/// 시작

/// </summary>

public class Startup

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 구성 - Configuration

/// <summary>

/// 구성

/// </summary>

public IConfiguration Configuration { get; }

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - Startup(configuration)

/// <summary>

/// 생성자

/// </summary>

/// <param name="configuration">구성</param>

public Startup(IConfiguration configuration)

{

Configuration = configuration;

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 서비스 컬렉션 구성하기 - ConfigureServices(services)

/// <summary>

/// 서비스 컬렉션 구성하기

/// </summary>

/// <param name="services">서비스 컬렉션</param>

public void ConfigureServices(IServiceCollection services)

{

services.AddControllersWithViews();

}

#endregion

#region 구성하기 - Configure(app, environment)

/// <summary>

/// 구성하기

/// </summary>

/// <param name="app">애플리케이션 빌더</param>

/// <param name="environment">웹 호스트 환경</param>

public void Configure(IApplicationBuilder app, IWebHostEnvironment environment)

{

if(environment.IsDevelopment())

{

app.UseDeveloperExceptionPage();

}

app.UseHttpsRedirection();

app.UseRouting();

app.UseAuthorization();

app.UseEndpoints

(

endpoints =>

{

endpoints.MapControllers();

}

);

}

#endregion

}

▶ Controllers/TestController.cs


using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Docs.Samples;

namespace TestProject.Controllers
{
    /// <summary>
    /// 테스트 컨트롤러
    /// </summary>
    [ApiController]
    [Route("api/[controller]")]
    public class TestController : ControllerBase
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        // GET /api/test/3
        #region 구하기 - Get(id)

        /// <summary>
        /// 구하기
        /// </summary>
        /// <param name="id">ID</param>
        /// <returns>액션 결과</returns>
        [HttpGet("{id}")]
        public IActionResult Get(string id)
        {
            if(id.Contains('0'))
            {
                return StatusCode(StatusCodes.Status406NotAcceptable);
            }

            return ControllerContext.MyDisplayRouteInfo(id);
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Http;

using Microsoft.AspNetCore.Mvc;

using Microsoft.Docs.Samples;

namespace TestProject.Controllers

{

/// <summary>

/// 테스트 컨트롤러

/// </summary>

[ApiController]

[Route("api/[controller]")]

public class TestController : ControllerBase

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

// GET /api/test/3

#region 구하기 - Get(id)

/// <summary>

/// 구하기

/// </summary>

/// <param name="id">ID</param>

/// <returns>액션 결과</returns>

[HttpGet("{id}")]

public IActionResult Get(string id)

{

if(id.Contains('0'))

{

return StatusCode(StatusCodes.Status406NotAcceptable);

}

return ControllerContext.MyDisplayRouteInfo(id);

}

#endregion

}

TestProject.zip

[C#/WEB API/.NETCORE] IRouteConstraint 인터페이스 : 커스텀 경로 제약 조건 설정하기

■ IRouteConstraint 인터페이스를 사용해 커스텀 경로 제약 조건을 설정하는 방법을 보여준다. ▶ CustomNameConstraint.cs


using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Routing;
using System;
using System.Globalization;
using System.Text.RegularExpressions;

namespace TestProject
{
    /// <summary>
    /// 커스텀 명칭 제약 조건
    /// </summary>
    public class CustomNameConstraint : IRouteConstraint
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 정규식
        /// </summary>
        private Regex regex;

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - CustomNameConstraint()

        /// <summary>
        /// 생성자
        /// </summary>
        public CustomNameConstraint()
        {
            this.regex = new Regex
            (
                @"^[1-9]*$",
                RegexOptions.CultureInvariant | RegexOptions.IgnoreCase,
                TimeSpan.FromMilliseconds(100)
            );
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 매칭 여부 구하기 - Match(httpContext, route, routeKey, valueDictionary, routeDirection)

        /// <summary>
        /// 매칭 여부 구하기
        /// </summary>
        /// <param name="httpContext">HTTP 컨텍스트</param>
        /// <param name="router">라우터</param>
        /// <param name="routeKey">경로 키</param>
        /// <param name="valueDictionary">경로 값 딕셔너리</param>
        /// <param name="routeDirection">경로 방향</param>
        /// <returns>매칭 여부</returns>
        public bool Match
        (
            HttpContext          httpContext,
            IRouter              router,
            string               routeKey,
            RouteValueDictionary valueDictionary,
            RouteDirection       routeDirection
        )
        {
            if(valueDictionary.TryGetValue(routeKey, out object value))
            {
                string parameterValue = Convert.ToString(value, CultureInfo.InvariantCulture);

                if(parameterValue == null)
                {
                    return false;
                }

                return regex.IsMatch(parameterValue);
            }

            return false;
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Http;

using Microsoft.AspNetCore.Routing;

using System;

using System.Globalization;

using System.Text.RegularExpressions;

namespace TestProject

{

/// <summary>

/// 커스텀 명칭 제약 조건

/// </summary>

public class CustomNameConstraint : IRouteConstraint

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// 정규식

/// </summary>

private Regex regex;

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - CustomNameConstraint()

/// <summary>

/// 생성자

/// </summary>

public CustomNameConstraint()

{

this.regex = new Regex

(

@"^[1-9]*$",

RegexOptions.CultureInvariant | RegexOptions.IgnoreCase,

TimeSpan.FromMilliseconds(100)

);

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 매칭 여부 구하기 - Match(httpContext, route, routeKey, valueDictionary, routeDirection)

/// <summary>

/// 매칭 여부 구하기

/// </summary>

/// <param name="httpContext">HTTP 컨텍스트</param>

/// <param name="router">라우터</param>

/// <param name="routeKey">경로 키</param>

/// <param name="valueDictionary">경로 값 딕셔너리</param>

/// <param name="routeDirection">경로 방향</param>

/// <returns>매칭 여부</returns>

public bool Match

(

HttpContext httpContext,

IRouter router,

string routeKey,

RouteValueDictionary valueDictionary,

RouteDirection routeDirection

)

{

if(valueDictionary.TryGetValue(routeKey, out object value))

{

string parameterValue = Convert.ToString(value, CultureInfo.InvariantCulture);

if(parameterValue == null)

{

return false;

}

return regex.IsMatch(parameterValue);

}

return false;

}

#endregion

}

▶ Startup.cs


using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

namespace TestProject
{
    /// <summary>
    /// 시작
    /// </summary>
    public class Startup
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 구성 - Configuration

        /// <summary>
        /// 구성
        /// </summary>
        public IConfiguration Configuration { get; }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - Startup(configuration)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="configuration">구성</param>
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 서비스 컬렉션 구성하기 - ConfigureServices(services)

        /// <summary>
        /// 서비스 컬렉션 구성하기
        /// </summary>
        /// <param name="services">서비스 컬렉션</param>
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllersWithViews();

            services.AddRouting
            (
                options =>
                {
                    options.ConstraintMap.Add("customName", typeof(CustomNameConstraint));
                }
            );
        }

        #endregion
        #region 구성하기 - Configure(app, environment)

        /// <summary>
        /// 구성하기
        /// </summary>
        /// <param name="app">애플리케이션 빌더</param>
        /// <param name="environment">웹 호스트 환경</param>
        public void Configure(IApplicationBuilder app, IWebHostEnvironment environment)
        {
            if(environment.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }

            app.UseHttpsRedirection();

            app.UseRouting();

            app.UseAuthorization();

            app.UseEndpoints
            (
                endpoints =>
                {
                    endpoints.MapControllers();
                }
            );
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Builder;

using Microsoft.AspNetCore.Hosting;

using Microsoft.Extensions.Configuration;

using Microsoft.Extensions.DependencyInjection;

using Microsoft.Extensions.Hosting;

namespace TestProject

{

/// <summary>

/// 시작

/// </summary>

public class Startup

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 구성 - Configuration

/// <summary>

/// 구성

/// </summary>

public IConfiguration Configuration { get; }

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - Startup(configuration)

/// <summary>

/// 생성자

/// </summary>

/// <param name="configuration">구성</param>

public Startup(IConfiguration configuration)

{

Configuration = configuration;

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 서비스 컬렉션 구성하기 - ConfigureServices(services)

/// <summary>

/// 서비스 컬렉션 구성하기

/// </summary>

/// <param name="services">서비스 컬렉션</param>

public void ConfigureServices(IServiceCollection services)

{

services.AddControllersWithViews();

services.AddRouting

(

options =>

{

options.ConstraintMap.Add("customName", typeof(CustomNameConstraint));

}

);

}

#endregion

#region 구성하기 - Configure(app, environment)

/// <summary>

/// 구성하기

/// </summary>

/// <param name="app">애플리케이션 빌더</param>

/// <param name="environment">웹 호스트 환경</param>

public void Configure(IApplicationBuilder app, IWebHostEnvironment environment)

{

if(environment.IsDevelopment())

{

app.UseDeveloperExceptionPage();

}

app.UseHttpsRedirection();

app.UseRouting();

app.UseAuthorization();

app.UseEndpoints

(

endpoints =>

{

endpoints.MapControllers();

}

);

}

#endregion

}

▶ Controllers/TestController.cs


using Microsoft.AspNetCore.Mvc;
using Microsoft.Docs.Samples;

namespace TestProject.Controllers
{
    /// <summary>
    /// 테스트 컨트롤러
    /// </summary>
    [ApiController]
    [Route("api/[controller]")]
    public class TestController : ControllerBase
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        // GET /api/test/3
        #region 구하기 - Get(id)

        /// <summary>
        /// 구하기
        /// </summary>
        /// <param name="id">ID</param>
        /// <returns>액션 결과</returns>
        [HttpGet("{id:customName}")]
        public IActionResult Get(string id)
        {
            return ControllerContext.MyDisplayRouteInfo(id);
        }

        #endregion
        // GET /api/test/my/3
        #region 구하기 -  Get(id)

        /// <summary>
        /// 구하기
        /// </summary>
        /// <param name="id">ID</param>
        /// <returns>액션 결과</returns>
        [HttpGet("my/{id:customName}")]
        public IActionResult Get(int id)
        {
            return ControllerContext.MyDisplayRouteInfo(id);
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Mvc;

using Microsoft.Docs.Samples;

namespace TestProject.Controllers

{

/// <summary>

/// 테스트 컨트롤러

/// </summary>

[ApiController]

[Route("api/[controller]")]

public class TestController : ControllerBase

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

// GET /api/test/3

#region 구하기 - Get(id)

/// <summary>

/// 구하기

/// </summary>

/// <param name="id">ID</param>

/// <returns>액션 결과</returns>

[HttpGet("{id:customName}")]

public IActionResult Get(string id)

{

return ControllerContext.MyDisplayRouteInfo(id);

}

#endregion

// GET /api/test/my/3

#region 구하기 - Get(id)

/// <summary>

/// 구하기

/// </summary>

/// <param name="id">ID</param>

/// <returns>액션 결과</returns>

[HttpGet("my/{id:customName}")]

public IActionResult Get(int id)

{

return ControllerContext.MyDisplayRouteInfo(id);

}

#endregion

}

TestProject.zip

[C#/WEB API/.NETCORE] 스캐폴딩 기능을 사용해 WEB API 앱 만들기

■ 스캐폴딩 기능을 사용해 WEB API 앱을 만드는 방법을 보여준다. ▶ Models/TodoModel.cs


namespace TestProject.Models
{
    /// <summary>
    /// 할일 모델
    /// </summary>
    public class TodoModel
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region ID - ID

        /// <summary>
        /// ID
        /// </summary>
        public long ID { get; set; }

        #endregion
        #region 제목 - Name

        /// <summary>
        /// 제목
        /// </summary>
        public string Name { get; set; }

        #endregion
        #region 완료 여부 - IsComplete

        /// <summary>
        /// 완료 여부
        /// </summary>
        public bool IsComplete { get; set; }

        #endregion
    }
}

namespace TestProject.Models

{

/// <summary>

/// 할일 모델

/// </summary>

public class TodoModel

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public long ID { get; set; }

#endregion

#region 제목 - Name

/// <summary>

/// 제목

/// </summary>

public string Name { get; set; }

#endregion

#region 완료 여부 - IsComplete

/// <summary>

/// 완료 여부

/// </summary>

public bool IsComplete { get; set; }

#endregion

}

▶ Data/DatabaseContext.cs


using Microsoft.EntityFrameworkCore;

using TestProject.Models;

namespace TestProject.Data
{
    /// <summary>
    /// 데이터베이스 컨텍스트
    /// </summary>
    public class DatabaseContext : DbContext
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 할일 - Todo

        /// <summary>
        /// 할일
        /// </summary>
        public DbSet<TodoModel> Todo { get; set; }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - DatabaseContext(options)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="options">옵션</param>
        public DatabaseContext(DbContextOptions<DatabaseContext> options) : base(options)
        {
        }

        #endregion
    }
}

using Microsoft.EntityFrameworkCore;

using TestProject.Models;

namespace TestProject.Data

{

/// <summary>

/// 데이터베이스 컨텍스트

/// </summary>

public class DatabaseContext : DbContext

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 할일 - Todo

/// <summary>

/// 할일

/// </summary>

public DbSet<TodoModel> Todo { get; set; }

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - DatabaseContext(options)

/// <summary>

/// 생성자

/// </summary>

/// <param name="options">옵션</param>

public DatabaseContext(DbContextOptions<DatabaseContext> options) : base(options)

{

}

#endregion

}

▶ Startup.cs


using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

using TestProject.Data;

namespace TestProject
{
    /// <summary>
    /// 시작
    /// </summary>
    public class Startup
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 구성 - Configuration

        /// <summary>
        /// 구성
        /// </summary>
        public IConfiguration Configuration { get; }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - Startup(configuration)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="configuration">구성</param>
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 서비스 컬렉션 구성하기 - ConfigureServices(services)

        /// <summary>
        /// 서비스 컬렉션 구성하기
        /// </summary>
        /// <param name="services">서비스 컬렉션</param>
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddDbContext<DatabaseContext>(options => options.UseInMemoryDatabase("TodoList"));

            services.AddControllers();
        }

        #endregion
        #region 구성하기 - Configure(app, environment)

        /// <summary>
        /// 구성하기
        /// </summary>
        /// <param name="app">애플리케이션 빌더</param>
        /// <param name="environment">웹 호스트 환경</param>
        public void Configure(IApplicationBuilder app, IWebHostEnvironment environment)
        {
            if(environment.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }

            app.UseHttpsRedirection();

            app.UseRouting();

            app.UseAuthorization();

            app.UseEndpoints
            (
                endpointRouterBuilder =>
                {
                    endpointRouterBuilder.MapControllers();
                }
            );
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Builder;

using Microsoft.AspNetCore.Hosting;

using Microsoft.EntityFrameworkCore;

using Microsoft.Extensions.Configuration;

using Microsoft.Extensions.DependencyInjection;

using Microsoft.Extensions.Hosting;

using TestProject.Data;

namespace TestProject

{

/// <summary>

/// 시작

/// </summary>

public class Startup

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 구성 - Configuration

/// <summary>

/// 구성

/// </summary>

public IConfiguration Configuration { get; }

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - Startup(configuration)

/// <summary>

/// 생성자

/// </summary>

/// <param name="configuration">구성</param>

public Startup(IConfiguration configuration)

{

Configuration = configuration;

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 서비스 컬렉션 구성하기 - ConfigureServices(services)

/// <summary>

/// 서비스 컬렉션 구성하기

/// </summary>

/// <param name="services">서비스 컬렉션</param>

public void ConfigureServices(IServiceCollection services)

{

services.AddDbContext<DatabaseContext>(options => options.UseInMemoryDatabase("TodoList"));

services.AddControllers();

}

#endregion

#region 구성하기 - Configure(app, environment)

/// <summary>

/// 구성하기

/// </summary>

/// <param name="app">애플리케이션 빌더</param>

/// <param name="environment">웹 호스트 환경</param>

public void Configure(IApplicationBuilder app, IWebHostEnvironment environment)

{

if(environment.IsDevelopment())

{

app.UseDeveloperExceptionPage();

}

app.UseHttpsRedirection();

app.UseRouting();

app.UseAuthorization();

app.UseEndpoints

(

endpointRouterBuilder =>

{

endpointRouterBuilder.MapControllers();

}

);

}

#endregion

}

▶ Controllers/TodoController.cs


using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

using TestProject.Data;
using TestProject.Models;

namespace TestProject.Controllers
{
    /// <summary>
    /// 할일 컨트롤러
    /// </summary>
    [ApiController]
    [Route("api/[controller]")]
    public class TodoController : ControllerBase
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 데이터베이스 컨텍스트
        /// </summary>
        private readonly DatabaseContext context;

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - TodoController(context)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="context">컨텍스트</param>
        public TodoController(DatabaseContext context)
        {
            this.context = context;
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region GET 처리하기 - Get()

        /// <summary>
        /// GET 처리하기
        /// </summary>
        /// <returns>액션 결과 태스크</returns>
        [HttpGet]
        public async Task<ActionResult<IEnumerable<TodoModel>>> Get()
        {
            return await this.context.Todo.ToListAsync();
        }

        #endregion
        #region GET 처리하기 - Get(id)

        /// <summary>
        /// GET 처리하기
        /// </summary>
        /// <param name="id">ID</param>
        /// <returns>액션 결과 태스크</returns>
        [HttpGet("{id}")]
        public async Task<ActionResult<TodoModel>> Get(long id)
        {
            TodoModel todo = await this.context.Todo.FindAsync(id);

            if(todo == null)
            {
                return NotFound();
            }

            return todo;
        }

        #endregion
        #region POST 처리하기 - Post(todo)

        /// <summary>
        /// POST 처리하기
        /// </summary>
        /// <param name="todo">할일</param>
        /// <returns>액션 결과 태스크</returns>
        [HttpPost]
        public async Task<ActionResult<TodoModel>> Post(TodoModel todo)
        {
            this.context.Todo.Add(todo);

            await this.context.SaveChangesAsync();

            return CreatedAtAction("Get", new { id = todo.ID }, todo);
        }

        #endregion
        #region PUT 처리하기 - Put(id, todo)

        /// <summary>
        /// PUT 처리하기
        /// </summary>
        /// <param name="id">ID</param>
        /// <param name="todo">할일</param>
        /// <returns>액션 결과 태스크</returns>
        [HttpPut("{id}")]
        public async Task<IActionResult> Put(long id, TodoModel todo)
        {
            if(id != todo.ID)
            {
                return BadRequest();
            }

            this.context.Entry(todo).State = EntityState.Modified;

            try
            {
                await this.context.SaveChangesAsync();
            }
            catch(DbUpdateConcurrencyException)
            {
                if(!TodoExists(id))
                {
                    return NotFound();
                }
                else
                {
                    throw;
                }
            }

            return NoContent();
        }

        #endregion
        #region DELETE 처리하기 - Delete(id)

        /// <summary>
        /// DELETE 처리하기
        /// </summary>
        /// <param name="id">ID</param>
        /// <returns>액션 결과 태스크</returns>
        [HttpDelete("{id}")]
        public async Task<ActionResult<TodoModel>> Delete(long id)
        {
            TodoModel todo = await this.context.Todo.FindAsync(id);

            if(todo == null)
            {
                return NotFound();
            }

            this.context.Todo.Remove(todo);

            await this.context.SaveChangesAsync();

            return todo;
        }

        #endregion

        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region 할일 존재 여부 구하기 - TodoExists(id)

        /// <summary>
        /// 할일 존재 여부 구하기
        /// </summary>
        /// <param name="id"></param>
        /// <returns>할일 존재 여부</returns>
        private bool TodoExists(long id)
        {
            return this.context.Todo.Any(e => e.ID == id);
        }

        #endregion
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

using Microsoft.AspNetCore.Mvc;

using Microsoft.EntityFrameworkCore;

using System.Collections.Generic;

using System.Linq;

using System.Threading.Tasks;

using TestProject.Data;

using TestProject.Models;

namespace TestProject.Controllers

{

/// <summary>

/// 할일 컨트롤러

/// </summary>

[ApiController]

[Route("api/[controller]")]

public class TodoController : ControllerBase

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// 데이터베이스 컨텍스트

/// </summary>

private readonly DatabaseContext context;

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - TodoController(context)

/// <summary>

/// 생성자

/// </summary>

/// <param name="context">컨텍스트</param>

public TodoController(DatabaseContext context)

{

this.context = context;

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region GET 처리하기 - Get()

/// <summary>

/// GET 처리하기

/// </summary>

/// <returns>액션 결과 태스크</returns>

[HttpGet]

public async Task<ActionResult<IEnumerable<TodoModel>>> Get()

{

return await this.context.Todo.ToListAsync();

}

#endregion

#region GET 처리하기 - Get(id)

/// <summary>

/// GET 처리하기

/// </summary>

/// <param name="id">ID</param>

/// <returns>액션 결과 태스크</returns>

[HttpGet("{id}")]

public async Task<ActionResult<TodoModel>> Get(long id)

{

TodoModel todo = await this.context.Todo.FindAsync(id);

if(todo == null)

{

return NotFound();

}

return todo;

}

#endregion

#region POST 처리하기 - Post(todo)

/// <summary>

/// POST 처리하기

/// </summary>

/// <param name="todo">할일</param>

/// <returns>액션 결과 태스크</returns>

[HttpPost]

public async Task<ActionResult<TodoModel>> Post(TodoModel todo)

{

this.context.Todo.Add(todo);

await this.context.SaveChangesAsync();

return CreatedAtAction("Get", new { id = todo.ID }, todo);

}

#endregion

#region PUT 처리하기 - Put(id, todo)

/// <summary>

/// PUT 처리하기

/// </summary>

/// <param name="id">ID</param>

/// <param name="todo">할일</param>

/// <returns>액션 결과 태스크</returns>

[HttpPut("{id}")]

public async Task<IActionResult> Put(long id, TodoModel todo)

{

if(id != todo.ID)

{

return BadRequest();

}

this.context.Entry(todo).State = EntityState.Modified;

try

{

await this.context.SaveChangesAsync();

}

catch(DbUpdateConcurrencyException)

{

if(!TodoExists(id))

{

return NotFound();

}

else

{

throw;

}

return NoContent();

}

#endregion

#region DELETE 처리하기 - Delete(id)

/// <summary>

/// DELETE 처리하기

/// </summary>

/// <param name="id">ID</param>

/// <returns>액션 결과 태스크</returns>

[HttpDelete("{id}")]

public async Task<ActionResult<TodoModel>> Delete(long id)

{

TodoModel todo = await this.context.Todo.FindAsync(id);

if(todo == null)

{

return NotFound();

}

this.context.Todo.Remove(todo);

await this.context.SaveChangesAsync();

return todo;

}

#endregion

////////////////////////////////////////////////////////////////////////////////////////// Private

#region 할일 존재 여부 구하기 - TodoExists(id)

/// <summary>

/// 할일 존재 여부 구하기

/// </summary>

/// <param name="id"></param>

/// <returns>할일 존재 여부</returns>

private bool TodoExists(long id)

{

return this.context.Todo.Any(e => e.ID == id);

}

#endregion

}

[C#/WEB API/.NETCORE] 대용량 데이터를 스트리밍 방식으로 전달받기

■ 대용량 데이터를 스트리밍 방식으로 전달받는 방법을 보여준다. [TestLibrary 프로젝트] ▶ ValueModel.cs


namespace TestLibrary
{
    /// <summary>
    /// 값 모델
    /// </summary>
    public class ValueModel
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region ID - ID

        /// <summary>
        /// ID
        /// </summary>
        public int ID { get; set; }

        #endregion
        #region 데이터 - Data

        /// <summary>
        /// 데이터
        /// </summary>
        public string Data { get; set; }

        #endregion
        #region 태그 - Tag

        /// <summary>
        /// 태그
        /// </summary>
        public string Tag { get; set; }

        #endregion
    }
}

namespace TestLibrary

{

/// <summary>

/// 값 모델

/// </summary>

public class ValueModel

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public int ID { get; set; }

#endregion

#region 데이터 - Data

/// <summary>

/// 데이터

/// </summary>

public string Data { get; set; }

#endregion

#region 태그 - Tag

/// <summary>

/// 태그

/// </summary>

public string Tag { get; set; }

#endregion

}

[TestClient 프로젝트] ▶ Program.cs


using System;
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;

using Newtonsoft.Json;

using TestLibrary;

namespace TestClient
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            Console.Title = "대용량 데이터를 스트리밍 방식으로 전달받기";

            Console.WriteLine("PRESS ANY KEY TO CONTINUE...");

            Console.ReadKey(true);

            //TestPOSTData1();
            //TestPOSTData2();
            TestGETData();

            Console.WriteLine("PRESS ANY KEY TO EXIT...");

            Console.ReadKey(true);
        }

        #endregion

        #region POST 데이터 구하기 1 - GetPOSTData1<TResultItem>(url, source)

        /// <summary>
        /// POST 데이터 구하기 1
        /// </summary>
        /// <typeparam name="TResultItem">결과 항목 타입</typeparam>
        /// <param name="url">URL</param>
        /// <param name="source">소스 객체</param>
        /// <returns>결과 항목 타입 열거 가능형</returns>
        private static IEnumerable<TResultItem> GetPOSTData1<TResultItem>(string url, object source)
        {
            string sourceJSON = JsonConvert.SerializeObject(source);

            HttpRequestMessage requestMessage = new HttpRequestMessage(HttpMethod.Post, url);

            requestMessage.Content = new StringContent(sourceJSON, Encoding.UTF8, "application/json");

            requestMessage.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));

            HttpClient client = new HttpClient();

            HttpResponseMessage responseMessage = client.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead).Result;

            responseMessage.EnsureSuccessStatusCode();

            using(Stream stream = responseMessage.Content.ReadAsStreamAsync().Result)
            {
                using(StreamReader streamReader = new StreamReader(stream))
                {
                    JsonSerializer serializer = new JsonSerializer();

                    using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))
                    {
                        while(jsonTextReader.Read())
                        {
                            if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)
                            {
                                yield return serializer.Deserialize<TResultItem>(jsonTextReader);
                            }
                        }
                    }
                }
            }
        }

        #endregion
        #region POST 데이터 테스트하기 1 - TestPOSTData1()

        /// <summary>
        /// POST 데이터 테스트하기 1
        /// </summary>
        private static void TestPOSTData1()
        {
            string url = "http://localhost:5569/api/test/postdata";

            ValueModel source = new ValueModel();

            source.ID   = -1;
            source.Data = "NODATA";
            source.Tag  = "POST3";

            foreach(ValueModel value in GetPOSTData1<ValueModel>(url, source))
            {
                Console.WriteLine("{0} {1} {2}", value.ID, value.Data.Length, value.Tag);
            }
        }

        #endregion

        #region POST 스트림 구하기 - POSTGetStream(serverURL, contentType, encoding, argument, timeOut)

        /// <summary>
        /// POST 스트림 구하기
        /// </summary>
        /// <param name="serverURL">서버 URL</param>
        /// <param name="contentType">컨텐츠 타입</param>
        /// <param name="encoding">인코딩</param>
        /// <param name="argument">인자 문자열</param>
        /// <param name="timeOut">타임 아웃</param>
        /// <returns>POST 스트림</returns>
        private static Stream POSTGetStream(string serverURL, string contentType, Encoding encoding, string argument, int? timeOut = null)
        {
            byte[] argumentArray = encoding.GetBytes(argument);

            HttpWebRequest request = WebRequest.Create(serverURL) as HttpWebRequest;

            request.ProtocolVersion           = HttpVersion.Version11;
            request.AllowAutoRedirect         = true;
            request.AllowWriteStreamBuffering = true;
            request.Method                    = WebRequestMethods.Http.Post;
            request.ContentType               = contentType;
            request.ContentLength             = argumentArray.Length;

            if(timeOut.HasValue)
            {
                request.Timeout = timeOut.Value;
            }

            using(Stream requestStream = request.GetRequestStream())
            {
                requestStream.Write(argumentArray, 0, argumentArray.Length);
            }

            HttpWebResponse response = request.GetResponse() as HttpWebResponse;

            Stream responseStream = response.GetResponseStream();

            return responseStream;
        }

        #endregion
        #region POST 데이터 구하기 2 - GetPOSTData2<TResultItem>(url, source)

        /// <summary>
        /// POST 데이터 구하기 2
        /// </summary>
        /// <typeparam name="TResultItem">결과 항목 타입</typeparam>
        /// <param name="url">URL</param>
        /// <param name="source">소스 객체</param>
        /// <returns>결과 항목 타입 열거 가능형</returns>
        private static IEnumerable<TResultItem> GetPOSTData2<TResultItem>(string url, object source)
        {
            string sourceJSON = JsonConvert.SerializeObject(source);

            using(Stream stream = POSTGetStream(url, "application/json; charset=utf-8", Encoding.UTF8, sourceJSON))
            {
                using(StreamReader streamReader = new StreamReader(stream))
                {
                    using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))
                    {
                        JsonSerializer serializer = new JsonSerializer();

                        while(jsonTextReader.Read())
                        {
                            if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)
                            {
                                yield return serializer.Deserialize<TResultItem>(jsonTextReader);
                            }
                        }
                    }
                }
            }
        }

        #endregion
        #region POST 데이터 테스트하기 2 - TestPOSTData2()

        /// <summary>
        /// POST 데이터 테스트하기 2
        /// </summary>
        private static void TestPOSTData2()
        {
            string url = "http://localhost:5569/api/test/postdata";

            ValueModel source = new ValueModel();

            source.ID   = -1;
            source.Data = "NODATA";
            source.Tag  = "POST3";

            foreach(ValueModel value in GetPOSTData2<ValueModel>(url, source))
            {
                Console.WriteLine("{0} {1} {2}", value.ID, value.Data.Length, value.Tag);
            }
        }

        #endregion

        #region GET 데이터 구하기 - GetGETData<TResultItem>(url)

        /// <summary>
        /// GET 데이터 구하기
        /// </summary>
        /// <typeparam name="TResultItem">결과 항목 타입</typeparam>
        /// <param name="url">URL</param>
        /// <returns>결과 항목 열거 가능형</returns>
        private static IEnumerable<TResultItem> GetGETData<TResultItem>(string url)
        {
            HttpClient client = new HttpClient();

            MediaTypeWithQualityHeaderValue headerValue = new MediaTypeWithQualityHeaderValue("application/json");

            client.DefaultRequestHeaders.Accept.Add(headerValue);

            using(Stream stream = client.GetStreamAsync(url).Result)
            {
                using(StreamReader streamReader = new StreamReader(stream))
                {
                    JsonSerializer serializer = new JsonSerializer();

                    using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))
                    {
                        while(jsonTextReader.Read())
                        {
                            if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)
                            {
                                yield return serializer.Deserialize<TResultItem>(jsonTextReader);
                            }
                        }
                    }
                }
            }
        }

        #endregion
        #region GET 데이터 테스트하기 - TestGETData()

        /// <summary>
        /// GET 데이터 테스트하기
        /// </summary>
        private static void TestGETData()
        {
            string url = "http://localhost:5569/api/test/getdata?tag=GET";

            foreach(ValueModel value in GetGETData<ValueModel>(url))
            {
                Console.WriteLine("{0} {1} {2}", value.ID, value.Data.Length, value.Tag);
            }
        }

        #endregion
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

using System;

using System.Collections.Generic;

using System.IO;

using System.Net;

using System.Net.Http;

using System.Net.Http.Headers;

using System.Text;

using Newtonsoft.Json;

using TestLibrary;

namespace TestClient

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

Console.Title = "대용량 데이터를 스트리밍 방식으로 전달받기";

Console.WriteLine("PRESS ANY KEY TO CONTINUE...");

Console.ReadKey(true);

//TestPOSTData1();

//TestPOSTData2();

TestGETData();

Console.WriteLine("PRESS ANY KEY TO EXIT...");

Console.ReadKey(true);

}

#endregion

#region POST 데이터 구하기 1 - GetPOSTData1<TResultItem>(url, source)

/// <summary>

/// POST 데이터 구하기 1

/// </summary>

/// <typeparam name="TResultItem">결과 항목 타입</typeparam>

/// <param name="url">URL</param>

/// <param name="source">소스 객체</param>

/// <returns>결과 항목 타입 열거 가능형</returns>

private static IEnumerable<TResultItem> GetPOSTData1<TResultItem>(string url, object source)

{

string sourceJSON = JsonConvert.SerializeObject(source);

HttpRequestMessage requestMessage = new HttpRequestMessage(HttpMethod.Post, url);

requestMessage.Content = new StringContent(sourceJSON, Encoding.UTF8, "application/json");

requestMessage.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));

HttpClient client = new HttpClient();

HttpResponseMessage responseMessage = client.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead).Result;

responseMessage.EnsureSuccessStatusCode();

using(Stream stream = responseMessage.Content.ReadAsStreamAsync().Result)

{

using(StreamReader streamReader = new StreamReader(stream))

{

JsonSerializer serializer = new JsonSerializer();

using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))

{

while(jsonTextReader.Read())

{

if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)

{

yield return serializer.Deserialize<TResultItem>(jsonTextReader);

}

#endregion

#region POST 데이터 테스트하기 1 - TestPOSTData1()

/// <summary>

/// POST 데이터 테스트하기 1

/// </summary>

private static void TestPOSTData1()

{

string url = "http://localhost:5569/api/test/postdata";

ValueModel source = new ValueModel();

source.ID = -1;

source.Data = "NODATA";

source.Tag = "POST3";

foreach(ValueModel value in GetPOSTData1<ValueModel>(url, source))

{

Console.WriteLine("{0} {1} {2}", value.ID, value.Data.Length, value.Tag);

}

#endregion

#region POST 스트림 구하기 - POSTGetStream(serverURL, contentType, encoding, argument, timeOut)

/// <summary>

/// POST 스트림 구하기

/// </summary>

/// <param name="serverURL">서버 URL</param>

/// <param name="contentType">컨텐츠 타입</param>

/// <param name="encoding">인코딩</param>

/// <param name="argument">인자 문자열</param>

/// <param name="timeOut">타임 아웃</param>

/// <returns>POST 스트림</returns>

private static Stream POSTGetStream(string serverURL, string contentType, Encoding encoding, string argument, int? timeOut = null)

{

byte[] argumentArray = encoding.GetBytes(argument);

HttpWebRequest request = WebRequest.Create(serverURL) as HttpWebRequest;

request.ProtocolVersion = HttpVersion.Version11;

request.AllowAutoRedirect = true;

request.AllowWriteStreamBuffering = true;

request.Method = WebRequestMethods.Http.Post;

request.ContentType = contentType;

request.ContentLength = argumentArray.Length;

if(timeOut.HasValue)

{

request.Timeout = timeOut.Value;

}

using(Stream requestStream = request.GetRequestStream())

{

requestStream.Write(argumentArray, 0, argumentArray.Length);

}

HttpWebResponse response = request.GetResponse() as HttpWebResponse;

Stream responseStream = response.GetResponseStream();

return responseStream;

}

#endregion

#region POST 데이터 구하기 2 - GetPOSTData2<TResultItem>(url, source)

/// <summary>

/// POST 데이터 구하기 2

/// </summary>

/// <typeparam name="TResultItem">결과 항목 타입</typeparam>

/// <param name="url">URL</param>

/// <param name="source">소스 객체</param>

/// <returns>결과 항목 타입 열거 가능형</returns>

private static IEnumerable<TResultItem> GetPOSTData2<TResultItem>(string url, object source)

{

string sourceJSON = JsonConvert.SerializeObject(source);

using(Stream stream = POSTGetStream(url, "application/json; charset=utf-8", Encoding.UTF8, sourceJSON))

{

using(StreamReader streamReader = new StreamReader(stream))

{

using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))

{

JsonSerializer serializer = new JsonSerializer();

while(jsonTextReader.Read())

{

if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)

{

yield return serializer.Deserialize<TResultItem>(jsonTextReader);

}

#endregion

#region POST 데이터 테스트하기 2 - TestPOSTData2()

/// <summary>

/// POST 데이터 테스트하기 2

/// </summary>

private static void TestPOSTData2()

{

string url = "http://localhost:5569/api/test/postdata";

ValueModel source = new ValueModel();

source.ID = -1;

source.Data = "NODATA";

source.Tag = "POST3";

foreach(ValueModel value in GetPOSTData2<ValueModel>(url, source))

{

Console.WriteLine("{0} {1} {2}", value.ID, value.Data.Length, value.Tag);

}

#endregion

#region GET 데이터 구하기 - GetGETData<TResultItem>(url)

/// <summary>

/// GET 데이터 구하기

/// </summary>

/// <typeparam name="TResultItem">결과 항목 타입</typeparam>

/// <param name="url">URL</param>

/// <returns>결과 항목 열거 가능형</returns>

private static IEnumerable<TResultItem> GetGETData<TResultItem>(string url)

{

HttpClient client = new HttpClient();

MediaTypeWithQualityHeaderValue headerValue = new MediaTypeWithQualityHeaderValue("application/json");

client.DefaultRequestHeaders.Accept.Add(headerValue);

using(Stream stream = client.GetStreamAsync(url).Result)

{

using(StreamReader streamReader = new StreamReader(stream))

{

JsonSerializer serializer = new JsonSerializer();

using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))

{

while(jsonTextReader.Read())

{

if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)

{

yield return serializer.Deserialize<TResultItem>(jsonTextReader);

}

#endregion

#region GET 데이터 테스트하기 - TestGETData()

/// <summary>

/// GET 데이터 테스트하기

/// </summary>

private static void TestGETData()

{

string url = "http://localhost:5569/api/test/getdata?tag=GET";

foreach(ValueModel value in GetGETData<ValueModel>(url))

{

Console.WriteLine("{0} {1} {2}", value.ID, value.Data.Length, value.Tag);

}

#endregion

}

[TestServer 프로젝트] ▶ Controllers/TestController.cs

[C#/WEB API] 대용량 데이터를 스트리밍 방식으로 전달받기

■ 대용량 데이터를 스트리밍 방식으로 전달받는 방법을 보여준다. [TestClient 프로젝트] ▶ Program.cs


using System;
using System.Collections.Generic;
using System.IO;
using System.Net.Http;
using System.Net.Http.Headers;

using Newtonsoft.Json;

namespace TestClient
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            Console.Title = "대용량 데이터를 스트리밍 방식으로 전달받기";

            Console.WriteLine("PRESS ANY KEY TO CONTINUE...");

            Console.ReadKey(true);

            foreach(ValueModel value in GetValueEnumerable())
            {
                Console.WriteLine("{0}\t{1}", value.SequenceID, value.Data);
            }

            Console.WriteLine("PRESS ANY KEY TO EXIT...");

            Console.ReadKey(true);
        }

        #endregion
        #region 값 열거 가능형 구하기 - GetValueEnumerable()

        /// <summary>
        /// 값 열거 가능형 구하기
        /// </summary>
        /// <returns>값 열거 가능형</returns>
        private static IEnumerable<ValueModel> GetValueEnumerable()
        {
            JsonSerializer serializer = new JsonSerializer();

            HttpClient client = new HttpClient();

            MediaTypeWithQualityHeaderValue headerValue = new MediaTypeWithQualityHeaderValue("application/json");

            client.DefaultRequestHeaders.Accept.Add(headerValue);

            using(Stream stream = client.GetStreamAsync("http://localhost:63025/api/value").Result)
            {
                using(StreamReader streamReader = new StreamReader(stream))
                {
                    using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))
                    {
                        while(jsonTextReader.Read())
                        {
                            if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)
                            {
                                yield return serializer.Deserialize<ValueModel>(jsonTextReader);
                            }
                        }
                    }
                }
            }
        }

        #endregion
    }
}

using System;

using System.Collections.Generic;

using System.IO;

using System.Net.Http;

using System.Net.Http.Headers;

using Newtonsoft.Json;

namespace TestClient

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

Console.Title = "대용량 데이터를 스트리밍 방식으로 전달받기";

Console.WriteLine("PRESS ANY KEY TO CONTINUE...");

Console.ReadKey(true);

foreach(ValueModel value in GetValueEnumerable())

{

Console.WriteLine("{0}\t{1}", value.SequenceID, value.Data);

}

Console.WriteLine("PRESS ANY KEY TO EXIT...");

Console.ReadKey(true);

}

#endregion

#region 값 열거 가능형 구하기 - GetValueEnumerable()

/// <summary>

/// 값 열거 가능형 구하기

/// </summary>

/// <returns>값 열거 가능형</returns>

private static IEnumerable<ValueModel> GetValueEnumerable()

{

JsonSerializer serializer = new JsonSerializer();

HttpClient client = new HttpClient();

MediaTypeWithQualityHeaderValue headerValue = new MediaTypeWithQualityHeaderValue("application/json");

client.DefaultRequestHeaders.Accept.Add(headerValue);

using(Stream stream = client.GetStreamAsync("http://localhost:63025/api/value").Result)

{

using(StreamReader streamReader = new StreamReader(stream))

{

using(JsonTextReader jsonTextReader = new JsonTextReader(streamReader))

{

while(jsonTextReader.Read())

{

if(jsonTextReader.TokenType != JsonToken.StartArray && jsonTextReader.TokenType != JsonToken.EndArray)

{

yield return serializer.Deserialize<ValueModel>(jsonTextReader);

}

#endregion

}

[TestServer 프로젝트] ▶ Models/ValueModel.cs


using System.Runtime.Serialization;

namespace TestServer.Models
{
    /// <summary>
    /// 값 모델
    /// </summary>
    [DataContract]
    public class ValueModel
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 시퀀스 ID - Sequence

        /// <summary>
        /// 시퀀스 ID
        /// </summary>
        [DataMember]
        public int SequenceID { get; set; }

        #endregion
        #region 데이터 - Data

        /// <summary>
        /// 데이터
        /// </summary>
        [DataMember]
        public string Data { get; set; }

        #endregion
    }
}

using System.Runtime.Serialization;

namespace TestServer.Models

{

/// <summary>

/// 값 모델

/// </summary>

[DataContract]

public class ValueModel

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 시퀀스 ID - Sequence

/// <summary>

/// 시퀀스 ID

/// </summary>

[DataMember]

public int SequenceID { get; set; }

#endregion

#region 데이터 - Data

/// <summary>

/// 데이터

/// </summary>

[DataMember]

public string Data { get; set; }

#endregion

}

▶ Handlers/ValueHandler.cs


using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;

namespace TestServer.Handlers
{
    /// <summary>
    /// 값 핸들러
    /// </summary>
    public class ValueHandler : DelegatingHandler
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Protected

        #region 비동기 송신하기 - SendAsync(requestMessage, cancellationToken)

        /// <summary>
        /// 비동기 송신하기
        /// </summary>
        /// <param name="requestMessage">HTTP 요청 메시지</param>
        /// <param name="cancellationToken">취소 토큰</param>
        /// <returns>HTTP 응답 메시지 태스크</returns>
        protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage requestMessage, CancellationToken cancellationToken)
        {
            Task<HttpResponseMessage> responseMessageTask = base.SendAsync(requestMessage, cancellationToken);

            responseMessageTask.Result.Headers.TransferEncodingChunked = true;

            return responseMessageTask;
        }

        #endregion
    }
}

using System.Net.Http;

using System.Threading;

using System.Threading.Tasks;

namespace TestServer.Handlers

{

/// <summary>

/// 값 핸들러

/// </summary>

public class ValueHandler : DelegatingHandler

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Protected

#region 비동기 송신하기 - SendAsync(requestMessage, cancellationToken)

/// <summary>

/// 비동기 송신하기

/// </summary>

/// <param name="requestMessage">HTTP 요청 메시지</param>

/// <param name="cancellationToken">취소 토큰</param>

/// <returns>HTTP 응답 메시지 태스크</returns>

protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage requestMessage, CancellationToken cancellationToken)

{

Task<HttpResponseMessage> responseMessageTask = base.SendAsync(requestMessage, cancellationToken);

responseMessageTask.Result.Headers.TransferEncodingChunked = true;

return responseMessageTask;

}

#endregion

}

▶