STREAMMING Archives - icodebroker

[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/.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

}

▶

[C#/WEB API/.NETCORE] ControllerBase 클래스 : Response 속성을 사용해 파일 다운로드시 스트리밍 처리하기

■ ControllerBase 클래스의 Response 속성을 사용해 파일 다운로드시 스트리밍을 처리하는 방법을 보여준다. ▶ Controllers/TestController.cs


using Microsoft.AspNetCore.Mvc;
using Microsoft.Net.Http.Headers;
using System.Collections.Generic;
using System.IO;
using System.Threading.Tasks;

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

        #region 값 리스트 구하기 - GetValueList() // GET api/test

        /// <summary>
        /// 값 리스트 구하기
        /// </summary>
        /// <returns>값 리스트</returns>
        [HttpGet]
        public List<string> GetValueList()
        {
            return new List<string> { "value1", "value2" };
        }

        #endregion
        #region 파일 다운로드 하기 - DownloadFile() // GET api/test/download

        /// <summary>
        /// 파일 다운로드 하기
        /// </summary>
        /// <returns>태스크</returns>
        [HttpGet]
        [Route("download")]
        public async Task DownloadFile()
        {
            string filePath = @"d:\The Best of New Age Music Collection.mp4";

            Response.Headers.Add(HeaderNames.ContentType       , "application/octet-stream");
            Response.Headers.Add(HeaderNames.ContentDisposition, $"attachment; filename=\"{Path.GetFileName(filePath)}\"" );

            Response.StatusCode = 200;

            Stream sourceStream = new FileStream(filePath, FileMode.Open, FileAccess.Read);
            Stream targetStream = Response.Body;

            int bufferSize = 1024;

            byte[] bufferByteArray = new byte[bufferSize];

            while(true)
            {
                int readCount = await sourceStream.ReadAsync(bufferByteArray, 0, bufferSize);

                if(readCount == 0)
                {
                    break;
                }

                await targetStream.WriteAsync(bufferByteArray, 0, readCount);
            }

            await targetStream.FlushAsync();
        }

        #endregion
    }
}

using Microsoft.AspNetCore.Mvc;

using Microsoft.Net.Http.Headers;

using System.Collections.Generic;

using System.IO;

using System.Threading.Tasks;

namespace TestProject.Controllers

{

/// <summary>

/// 테스트 컨트롤러

/// </summary>

[ApiController]

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

public class TestController : Controller

{

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

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

#region 값 리스트 구하기 - GetValueList() // GET api/test

/// <summary>

/// 값 리스트 구하기

/// </summary>

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

[HttpGet]

public List<string> GetValueList()

{

return new List<string> { "value1", "value2" };

}

#endregion

#region 파일 다운로드 하기 - DownloadFile() // GET api/test/download

/// <summary>

/// 파일 다운로드 하기

/// </summary>

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

[HttpGet]

[Route("download")]

public async Task DownloadFile()

{

string filePath = @"d:\The Best of New Age Music Collection.mp4";

Response.Headers.Add(HeaderNames.ContentType , "application/octet-stream");

Response.Headers.Add(HeaderNames.ContentDisposition, $"attachment; filename=\"{Path.GetFileName(filePath)}\"" );

Response.StatusCode = 200;

Stream sourceStream = new FileStream(filePath, FileMode.Open, FileAccess.Read);

Stream targetStream = Response.Body;

int bufferSize = 1024;

byte[] bufferByteArray = new byte[bufferSize];

while(true)

{

int readCount = await sourceStream.ReadAsync(bufferByteArray, 0, bufferSize);

if(readCount == 0)

{

break;

}

await targetStream.WriteAsync(bufferByteArray, 0, readCount);

}

await targetStream.FlushAsync();

}

#endregion

}

TestProject.zip

[C#/WINFORM] 실시간 스트리밍 프로토콜(RTSP)을 사용해 동영상 재생하기

■ 실시간 스트리밍 프로토콜(RTSP)을 사용해 동영상을 재생하는 방법을 보여준다. [TestProject 프로젝트] ▶ MainForm.cs


using System;
using System.Windows.Forms;

using TestLibrary;

namespace TestProject
{
    /// <summary>
    /// 메인 폼
    /// </summary>
    public partial class MainForm : Form
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - MainForm()

        /// <summary>
        /// 생성자
        /// </summary>
        public MainForm()
        {
            InitializeComponent();

            this.streamPlayerControl.StreamStarted += streamPlayerControl_StreamStarted;
            this.streamPlayerControl.StreamStopped += streamPlayerControl_StreamStopped;
            this.streamPlayerControl.StreamFailed  += streamPlayerControl_StreamFailed;
            this.playButton.Click                  += playButton_Click;
            this.stopButton.Click                  += stopButton_Click;
            this.imageButton.Click                 += imageButton_Click;
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Private
        //////////////////////////////////////////////////////////////////////////////// Event

        #region 스트림 재생기 컨트롤 스트림 시작시 처리하기 - streamPlayerControl_StreamStarted(sender, e)

        /// <summary>
        /// 스트림 재생기 컨트롤 스트림 시작시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void streamPlayerControl_StreamStarted(object sender, EventArgs e)
        {
            SetButtonEnabled();

            this.statusTextBox.Text = "재생";
        }

        #endregion
        #region 스트림 재생기 컨트롤 스트림 중단시 처리하기 - streamPlayerControl_StreamStopped(sender, e)

        /// <summary>
        /// 스트림 재생기 컨트롤 스트림 중단시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void streamPlayerControl_StreamStopped(object sender, EventArgs e)
        {
            SetButtonEnabled();

            this.statusTextBox.Text = "중단";
        }

        #endregion
        #region 스트림 재생기 컨트롤 스트림 실패시 처리하기 - streamPlayerControl_StreamFailed(sender, e)

        /// <summary>
        /// 스트림 재생기 컨트롤 스트림 실패시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void streamPlayerControl_StreamFailed(object sender, StreamFailedEventArgs e)
        {
            SetButtonEnabled();

            this.statusTextBox.Text = "실패";

            MessageBox.Show(e.Error, "에러", MessageBoxButtons.OK, MessageBoxIcon.Error);
        }

        #endregion
        #region 재생하기 버튼 클릭시 처리하기 - playButton_Click(sender, e)

        /// <summary>
        /// 재생하기 버튼 클릭시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void playButton_Click(object sender, EventArgs e)
        {
            var uri = new Uri(this.urlTextBox.Text);

            this.streamPlayerControl.StartPlay(uri);

            this.statusTextBox.Text = "연결중...";
        }

        #endregion
        #region 중단하기 버튼 클릭시 처리하기 - stopButton_Click(sender, e)

        /// <summary>
        /// 중단하기 버튼 클릭시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void stopButton_Click(object sender, EventArgs e)
        {
            this.streamPlayerControl.Stop();
        }

        #endregion
        #region 이미지 버튼 클릭시 처리하기 - imageButton_Click(sender, e)

        /// <summary>
        /// 이미지 버튼 클릭시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void imageButton_Click(object sender, EventArgs e)
        {
            SaveFileDialog saveFileDialog = new SaveFileDialog();

            saveFileDialog.Filter = "비트맵 이미지|*.bmp";

            if(saveFileDialog.ShowDialog() == DialogResult.OK)
            {
                this.streamPlayerControl.GetCurrentFrame().Save(saveFileDialog.FileName);
            }
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////// Function

        #region 버튼 이용 가능 여부 설정하기 - SetButtonEnabled()

        /// <summary>
        /// 버튼 이용 가능 여부 설정하기
        /// </summary>
        private void SetButtonEnabled()
        {
            this.playButton.Enabled  = !this.streamPlayerControl.IsPlaying;
            this.stopButton.Enabled  = this.streamPlayerControl.IsPlaying;
            this.imageButton.Enabled = this.streamPlayerControl.IsPlaying;
        }

        #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

using System;

using System.Windows.Forms;

using TestLibrary;

namespace TestProject

{

/// <summary>

/// 메인 폼

/// </summary>

public partial class MainForm : Form

{

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

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

#region 생성자 - MainForm()

/// <summary>

/// 생성자

/// </summary>

public MainForm()

{

InitializeComponent();

this.streamPlayerControl.StreamStarted += streamPlayerControl_StreamStarted;

this.streamPlayerControl.StreamStopped += streamPlayerControl_StreamStopped;

this.streamPlayerControl.StreamFailed += streamPlayerControl_StreamFailed;

this.playButton.Click += playButton_Click;

this.stopButton.Click += stopButton_Click;

this.imageButton.Click += imageButton_Click;

}

#endregion

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

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

//////////////////////////////////////////////////////////////////////////////// Event

#region 스트림 재생기 컨트롤 스트림 시작시 처리하기 - streamPlayerControl_StreamStarted(sender, e)

/// <summary>

/// 스트림 재생기 컨트롤 스트림 시작시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void streamPlayerControl_StreamStarted(object sender, EventArgs e)

{

SetButtonEnabled();

this.statusTextBox.Text = "재생";

}

#endregion

#region 스트림 재생기 컨트롤 스트림 중단시 처리하기 - streamPlayerControl_StreamStopped(sender, e)

/// <summary>

/// 스트림 재생기 컨트롤 스트림 중단시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void streamPlayerControl_StreamStopped(object sender, EventArgs e)

{

SetButtonEnabled();

this.statusTextBox.Text = "중단";

}

#endregion

#region 스트림 재생기 컨트롤 스트림 실패시 처리하기 - streamPlayerControl_StreamFailed(sender, e)

/// <summary>

/// 스트림 재생기 컨트롤 스트림 실패시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void streamPlayerControl_StreamFailed(object sender, StreamFailedEventArgs e)

{

SetButtonEnabled();

this.statusTextBox.Text = "실패";

MessageBox.Show(e.Error, "에러", MessageBoxButtons.OK, MessageBoxIcon.Error);

}

#endregion

#region 재생하기 버튼 클릭시 처리하기 - playButton_Click(sender, e)

/// <summary>

/// 재생하기 버튼 클릭시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void playButton_Click(object sender, EventArgs e)

{

var uri = new Uri(this.urlTextBox.Text);

this.streamPlayerControl.StartPlay(uri);

this.statusTextBox.Text = "연결중...";

}

#endregion

#region 중단하기 버튼 클릭시 처리하기 - stopButton_Click(sender, e)

/// <summary>

/// 중단하기 버튼 클릭시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void stopButton_Click(object sender, EventArgs e)

{

this.streamPlayerControl.Stop();

}

#endregion

#region 이미지 버튼 클릭시 처리하기 - imageButton_Click(sender, e)

/// <summary>

/// 이미지 버튼 클릭시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void imageButton_Click(object sender, EventArgs e)

{

SaveFileDialog saveFileDialog = new SaveFileDialog();

saveFileDialog.Filter = "비트맵 이미지|*.bmp";

if(saveFileDialog.ShowDialog() == DialogResult.OK)

{

this.streamPlayerControl.GetCurrentFrame().Save(saveFileDialog.FileName);

}

#endregion

//////////////////////////////////////////////////////////////////////////////// Function

#region 버튼 이용 가능 여부 설정하기 - SetButtonEnabled()

/// <summary>

/// 버튼 이용 가능 여부 설정하기

/// </summary>

private void SetButtonEnabled()

{

this.playButton.Enabled = !this.streamPlayerControl.IsPlaying;

this.stopButton.Enabled = this.streamPlayerControl.IsPlaying;

this.imageButton.Enabled = this.streamPlayerControl.IsPlaying;

}

#endregion

}

TestSolution.zip

[FFMPEG] 비디오 파일 스트리밍 전송하기

■ 비디오 파일 스트리밍을 전송하는 방법을 보여준다. ▶ 실행 명령


ffmpeg -re -i d:\source.mkv -c copy -f rtp_mpegts rtp://127.0.0.1:9000

ffplay rtp://127.0.0.1:9000

ffmpeg -re -i d:\source.mkv -c copy -f rtp_mpegts rtp://127.0.0.1:9000

ffplay rtp://127.0.0.1:9000

[FFMPEG] 웹 카메라 스트리밍 전송하기

■ 웹 카메라 스트리밍을 전송하는 방법을 보여준다. ▶ 실행 명령


ffmpeg -f dshow -rtbufsize 64M -i "video=USB2.0 PC CAMERA" -s 320x200 -f rtp_mpegts rtp://127.0.0.1:9000

ffplay rtp://127.0.0.1:9000

ffmpeg -f dshow -rtbufsize 64M -i "video=USB2.0 PC CAMERA" -s 320x200 -f rtp_mpegts rtp://127.0.0.1:9000

ffplay rtp://127.0.0.1:9000

[C#/WCF] JSON 압축 스트리밍 데이터 구하기

■ JSON 압축 스트리밍 데이터를 구하는 방법을 보여준다. [TestServer 프로젝트] ▶ IDataService.cs


using System.IO;
using System.ServiceModel;

namespace TestServer
{
    /// <summary>
    /// 데이터 서비스 인터페이스
    /// </summary>
    [ServiceContract]
    public interface IDataService
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method

        #region 데이터 구하기 - GetData(dataID, conditionData)

        /// <summary>
        /// 데이터 구하기
        /// </summary>
        /// <param name="dataID">데이터 ID</param>
        /// <param name="conditionData">조건 데이터</param>
        /// <returns>데이터</returns>
        [OperationContract]
        Stream GetData(string dataID, string conditionData);

        #endregion
    }
}

using System.IO;

using System.ServiceModel;

namespace TestServer

{

/// <summary>

/// 데이터 서비스 인터페이스

/// </summary>

[ServiceContract]

public interface IDataService

{

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

#region 데이터 구하기 - GetData(dataID, conditionData)

/// <summary>

/// 데이터 구하기

/// </summary>

/// <param name="dataID">데이터 ID</param>

/// <param name="conditionData">조건 데이터</param>

/// <returns>데이터</returns>

[OperationContract]

Stream GetData(string dataID, string conditionData);

#endregion

}

▶ DataService.cs


using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Compression;
using System.ServiceModel;

using TestCommon;

namespace TestServer
{
    /// <summary>
    /// 데이터 서비스
    /// </summary>
    public class DataService : IDataService
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 임시 디렉토리 경로
        /// </summary>
        private const string TEMPORARY_DIRECTORY_PATH = "d:\\temporary_server";

        #endregion

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

        #region 데이터 구하기 - GetData(dataID, conditionData)

        /// <summary>
        /// 데이터 구하기
        /// </summary>
        /// <param name="dataID">데이터 ID</param>
        /// <param name="conditionData">조건 데이터</param>
        /// <returns>데이터</returns>
        public Stream GetData(string dataID, string conditionData)
        {
            WriteMessage("START GET DATA");
            WriteMessage("DATA ID : {0}", dataID);
            WriteMessage("CONDITION DATA");
            WriteMessage("--------------------------------------------------");
            WriteMessage(conditionData);
            WriteMessage("--------------------------------------------------");

            string transactionID = GUIDHelper.GetGUID();

            if(!Directory.Exists(TEMPORARY_DIRECTORY_PATH))
            {
                Directory.CreateDirectory(TEMPORARY_DIRECTORY_PATH);
            }

            //////////////////////////////////////////////////
            int dataCount = JSONHelper.Deserialize<int>(conditionData);

            List<Student> list = Student.GetData(dataCount);
            //////////////////////////////////////////////////

            WriteMessage("START CREATE TRANSACTION FILE");

            string transactionFilePath = Path.Combine(TEMPORARY_DIRECTORY_PATH, string.Format("{0}.dat", transactionID));

            using(FileStream fileStream = new FileStream(transactionFilePath, FileMode.Create, FileAccess.Write))
            {
                using(GZipStream gZipStream = new GZipStream(fileStream, CompressionMode.Compress))
                {
                    JSONHelper.Serialize(list, gZipStream);
                }
            }

            WriteMessage("END CREATE TRANSACTION FILE");

            Stream stream = null;

            try
            {
                stream = File.Open(transactionFilePath, FileMode.Open, FileAccess.Read, FileShare.Read);
            }
            catch
            {
            }

            OperationContext operationContext = OperationContext.Current;

            operationContext.OperationCompleted += delegate(object sender, EventArgs e)
            {
                try
                {
                    File.Delete(transactionFilePath);
                }
                catch
                {
                }
            };

            WriteMessage("END GET DATA");

            return stream;
        }

        #endregion

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

        #region 메시지 쓰기 - WriteMessage(format, parameterArray)

        /// <summary>
        /// 메시지 쓰기
        /// </summary>
        /// <param name="format">포맷 문자열</param>
        /// <param name="parameterArray">매개 변수 배열</param>
        private void WriteMessage(string format, params object[] parameterArray)
        {
            string message;

            if(parameterArray.Length == 0)
            {
                message = format;
            }
            else
            {
                message = string.Format(format, parameterArray);
            }

            Console.WriteLine(string.Format("[{0}] {1}", DateTime.Now.ToString("HH:mm:ss"), message));
        }

        #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

using System;

using System.Collections.Generic;

using System.IO;

using System.IO.Compression;

using System.ServiceModel;

using TestCommon;

namespace TestServer

{

/// <summary>

/// 데이터 서비스

/// </summary>

public class DataService : IDataService

{

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

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

#region Field

/// <summary>

/// 임시 디렉토리 경로

/// </summary>

private const string TEMPORARY_DIRECTORY_PATH = "d:\\temporary_server";

#endregion

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

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

#region 데이터 구하기 - GetData(dataID, conditionData)

/// <summary>

/// 데이터 구하기

/// </summary>

/// <param name="dataID">데이터 ID</param>

/// <param name="conditionData">조건 데이터</param>

/// <returns>데이터</returns>

public Stream GetData(string dataID, string conditionData)

{

WriteMessage("START GET DATA");

WriteMessage("DATA ID : {0}", dataID);

WriteMessage("CONDITION DATA");

WriteMessage("--------------------------------------------------");

WriteMessage(conditionData);

WriteMessage("--------------------------------------------------");

string transactionID = GUIDHelper.GetGUID();

if(!Directory.Exists(TEMPORARY_DIRECTORY_PATH))

{

Directory.CreateDirectory(TEMPORARY_DIRECTORY_PATH);

}

//////////////////////////////////////////////////

int dataCount = JSONHelper.Deserialize<int>(conditionData);

List<Student> list = Student.GetData(dataCount);

//////////////////////////////////////////////////

WriteMessage("START CREATE TRANSACTION FILE");

string transactionFilePath = Path.Combine(TEMPORARY_DIRECTORY_PATH, string.Format("{0}.dat", transactionID));

using(FileStream fileStream = new FileStream(transactionFilePath, FileMode.Create, FileAccess.Write))

{

using(GZipStream gZipStream = new GZipStream(fileStream, CompressionMode.Compress))

{

JSONHelper.Serialize(list, gZipStream);

}

WriteMessage("END CREATE TRANSACTION FILE");

Stream stream = null;

try

{

stream = File.Open(transactionFilePath, FileMode.Open, FileAccess.Read, FileShare.Read);

}

catch

{

}

OperationContext operationContext = OperationContext.Current;

operationContext.OperationCompleted += delegate(object sender, EventArgs e)

{

try

{

File.Delete(transactionFilePath);

}

catch

{

}

};

WriteMessage("END GET DATA");

return stream;

}

#endregion

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

#region 메시지 쓰기 - WriteMessage(format, parameterArray)

/// <summary>

/// 메시지 쓰기

/// </summary>

/// <param name="format">포맷 문자열</param>

/// <param name="parameterArray">매개 변수 배열</param>

private void WriteMessage(string format, params object[] parameterArray)

{

string message;

if(parameterArray.Length == 0)

{

message = format;

}

else

{

message = string.Format(format, parameterArray);

}

Console.WriteLine(string.Format("[{0}] {1}", DateTime.Now.ToString("HH:mm:ss"), message));

}

#endregion

}

▶ Program.cs


using System;
using System.ServiceModel;

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

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

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            using(ServiceHost serviceHost = new ServiceHost(typeof(DataService)))
            {
                serviceHost.Open();

                Console.WriteLine("서버가 시작되었습니다 : " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));

                Console.ReadKey(true);
            }
        }

        #endregion
    }
}

using System;

using System.ServiceModel;

namespace TestServer

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

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

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

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

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

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

using(ServiceHost serviceHost = new ServiceHost(typeof(DataService)))

{

serviceHost.Open();

Console.WriteLine("서버가 시작되었습니다 : " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));

Console.ReadKey(true);

}

#endregion

}

▶ App.config


<?xml version="1.0" encoding="utf-8" ?>
<configuration>
    <startup>
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />
    </startup>
    <system.serviceModel>
        <behaviors>
            <serviceBehaviors>
                <behavior name="mexBehavior">
                    <serviceMetadata httpGetEnabled="true" />
                    <serviceDebug includeExceptionDetailInFaults="true" />
                </behavior>
            </serviceBehaviors>
        </behaviors>
        <bindings>
            <basicHttpBinding>
                <binding name="basicHttp"
                    sendTimeout="00:10:00"
                    receiveTimeout="00:10:00"
                    maxReceivedMessageSize="1262485504"
                    transferMode="Streamed" />
            </basicHttpBinding>
            <netTcpBinding>
                <binding name="netTcp"
                    sendTimeout="00:10:00"
                    receiveTimeout="00:10:00"
                    maxReceivedMessageSize="1262485504"
                    transferMode="Streamed" />
            </netTcpBinding>
        </bindings>
        <services>
            <service name="TestServer.DataService" behaviorConfiguration="mexBehavior">
                <endpoint
                    address="DataService"
                    binding="basicHttpBinding"
                    bindingConfiguration="basicHttp"
                    contract="TestServer.IDataService" />
                <endpoint
                    address="DataService"
                    binding="netTcpBinding"
                    bindingConfiguration="netTcp"
                    contract="TestServer.IDataService" />
                <host>
                    <baseAddresses>
                        <add baseAddress="http://localhost:8080" />
                        <add baseAddress="net.tcp://localhost:8090" />
                    </baseAddresses>
                </host>
            </service>
        </services>
    </system.serviceModel>
</configuration>

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

</startup>

<system.serviceModel>

</behavior>

</serviceBehaviors>

</behaviors>

<binding name="basicHttp"

sendTimeout="00:10:00"

receiveTimeout="00:10:00"

maxReceivedMessageSize="1262485504"

transferMode="Streamed" />

</basicHttpBinding>

<binding name="netTcp"

sendTimeout="00:10:00"

receiveTimeout="00:10:00"

maxReceivedMessageSize="1262485504"

transferMode="Streamed" />

</netTcpBinding>

</bindings>

<endpoint

address="DataService"

binding="basicHttpBinding"

bindingConfiguration="basicHttp"

contract="TestServer.IDataService" />

<endpoint

address="DataService"

binding="netTcpBinding"

bindingConfiguration="netTcp"

contract="TestServer.IDataService" />

<host>

</baseAddresses>

</host>

</service>

</services>

</system.serviceModel>

</configuration>

[C#/WCF] 이진 포매터를 사용해 스트리밍 데이터 구하기

■ 이진 포매터를 사용해 스트리밍 데이터를 구하는 방법을 보여준다. [TestServer 프로젝트] ▶ IDataService.cs


using System.IO;
using System.ServiceModel;

namespace TestServer
{
    /// <summary>
    /// 데이터 서비스 인터페이스
    /// </summary>
    [ServiceContract]
    public interface IDataService
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method

        #region 데이터 구하기 - GetData(dataCount, useGZipStream)

        /// <summary>
        /// 데이터 구하기
        /// </summary>
        /// <param name="dataCount">데이터 카운트</param>
        /// <param name="useGZipStream">GZipStream 사용 여부</param>
        /// <returns>스트림</returns>
        [OperationContract]
        Stream GetData(int dataCount, bool useGZipStream);

        #endregion
    }
}

using System.IO;

using System.ServiceModel;

namespace TestServer

{

/// <summary>

/// 데이터 서비스 인터페이스

/// </summary>

[ServiceContract]

public interface IDataService

{

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

#region 데이터 구하기 - GetData(dataCount, useGZipStream)

/// <summary>

/// 데이터 구하기

/// </summary>

/// <param name="dataCount">데이터 카운트</param>

/// <param name="useGZipStream">GZipStream 사용 여부</param>

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

[OperationContract]

Stream GetData(int dataCount, bool useGZipStream);

#endregion

}

▶ DataService.cs


using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Compression;
using System.Runtime.Serialization.Formatters.Binary;

namespace TestServer
{
    /// <summary>
    /// 데이터 서비스
    /// </summary>
    public class DataService : IDataService
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 데이터 구하기 - GetData(dataCount, useGZipStream)

        /// <summary>
        /// 데이터 구하기
        /// </summary>
        /// <param name="dataCount">데이터 카운트</param>
        /// <param name="useGZipStream">GZipStream 사용 여부</param>
        /// <returns>스트림</returns>
        public Stream GetData(int dataCount, bool useGZipStream)
        {
            WriteMessage("START GetData : DataCount={0}", dataCount);

            #region 결과 리스트를 생성한다.

            List<string> resultlist = new List<string>();

            for(int i = 0; i < dataCount; i++)
            {
                resultlist.Add(Guid.NewGuid().ToString().ToUpper());
            }

            #endregion

            if(useGZipStream)
            {
                BinaryFormatter binaryFormatter = new BinaryFormatter();

                MemoryStream memoryStream = new MemoryStream();

                GZipStream gZipStream = new GZipStream(memoryStream, CompressionMode.Compress, true);

                binaryFormatter.Serialize(gZipStream, resultlist);

                gZipStream.Close();

                memoryStream.Position = 0;

                WriteMessage("END GetData");

                return memoryStream;
            }
            else
            {
                BinaryFormatter binaryFormatter = new BinaryFormatter();

                MemoryStream memoryStream = new MemoryStream();

                binaryFormatter.Serialize(memoryStream, resultlist);

                memoryStream.Position = 0;

                WriteMessage("END GetData");

                return memoryStream;
            }
        }

        #endregion

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

        #region 메시지 쓰기 - WriteMessage(format, parameterArray)

        /// <summary>
        /// 메시지 쓰기
        /// </summary>
        /// <param name="format">포맷 문자열</param>
        /// <param name="parameterArray">매개 변수 배열</param>
        private void WriteMessage(string format, params object[] parameterArray)
        {
            string message;

            if(parameterArray.Length == 0)
            {
                message = format;
            }
            else
            {
                message = string.Format(format, parameterArray);
            }

            Console.WriteLine(string.Format("[{0}] {1}", DateTime.Now.ToString("HH:mm:ss"), message));
        }

        #endregion
    }
}

100

101

102

103

104

105

using System;

using System.Collections.Generic;

using System.IO;

using System.IO.Compression;

using System.Runtime.Serialization.Formatters.Binary;

namespace TestServer

{

/// <summary>

/// 데이터 서비스

/// </summary>

public class DataService : IDataService

{

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

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

#region 데이터 구하기 - GetData(dataCount, useGZipStream)

/// <summary>

/// 데이터 구하기

/// </summary>

/// <param name="dataCount">데이터 카운트</param>

/// <param name="useGZipStream">GZipStream 사용 여부</param>

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

public Stream GetData(int dataCount, bool useGZipStream)

{

WriteMessage("START GetData : DataCount={0}", dataCount);

#region 결과 리스트를 생성한다.

List<string> resultlist = new List<string>();

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

{

resultlist.Add(Guid.NewGuid().ToString().ToUpper());

}

#endregion

if(useGZipStream)

{

BinaryFormatter binaryFormatter = new BinaryFormatter();

MemoryStream memoryStream = new MemoryStream();

GZipStream gZipStream = new GZipStream(memoryStream, CompressionMode.Compress, true);

binaryFormatter.Serialize(gZipStream, resultlist);

gZipStream.Close();

memoryStream.Position = 0;

WriteMessage("END GetData");

return memoryStream;

}

else

{

BinaryFormatter binaryFormatter = new BinaryFormatter();

MemoryStream memoryStream = new MemoryStream();

binaryFormatter.Serialize(memoryStream, resultlist);

memoryStream.Position = 0;

WriteMessage("END GetData");

return memoryStream;

}

#endregion

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

#region 메시지 쓰기 - WriteMessage(format, parameterArray)

/// <summary>

/// 메시지 쓰기

/// </summary>

/// <param name="format">포맷 문자열</param>

/// <param name="parameterArray">매개 변수 배열</param>

private void WriteMessage(string format, params object[] parameterArray)

{

string message;

if(parameterArray.Length == 0)

{

message = format;

}

else

{

message = string.Format(format, parameterArray);

}

Console.WriteLine(string.Format("[{0}] {1}", DateTime.Now.ToString("HH:mm:ss"), message));

}

#endregion

}

▶ Program.cs


using System;
using System.ServiceModel;

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

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

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            using(ServiceHost serviceHost = new ServiceHost(typeof(DataService)))
            {
                serviceHost.Open();

                Console.WriteLine("서버가 시작되었습니다 : " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));

                Console.ReadKey(true);
            }
        }

        #endregion
    }
}

using System;

using System.ServiceModel;

namespace TestServer

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

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

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

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

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

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

using(ServiceHost serviceHost = new ServiceHost(typeof(DataService)))

{

serviceHost.Open();

Console.WriteLine("서버가 시작되었습니다 : " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));

Console.ReadKey(true);

}

#endregion

}

▶ App.config

[C#/WCF] WCF 스트리밍 사용하기

■ WCF 스트리밍을 사용하는 방법을 보여준다. [TestServer 프로젝트] ▶ FileData.cs


using System.IO;
using System.ServiceModel;

namespace TestServer
{
    /// <summary>
    /// 파일 데이터
    /// </summary>
    [MessageContract]
    public class FileData
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 파일 경로 - FilePath

        /// <summary>
        /// 파일 경로
        /// </summary>
        [MessageHeader]
        public string FilePath { get; set; }

        #endregion
        #region 파일 길이 - FileLength

        /// <summary>
        /// 파일 길이
        /// </summary>
        [MessageHeader]
        public long FileLength { get; set; }

        #endregion
        #region 소스 스트림 - SourceStream

        /// <summary>
        /// 소스 스트림
        /// </summary>
        [MessageBodyMember]
        public Stream SourceStream { get; set; }

        #endregion
    }
}

using System.IO;

using System.ServiceModel;

namespace TestServer

{

/// <summary>

/// 파일 데이터

/// </summary>

[MessageContract]

public class FileData

{

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

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

#region 파일 경로 - FilePath

/// <summary>

/// 파일 경로

/// </summary>

[MessageHeader]

public string FilePath { get; set; }

#endregion

#region 파일 길이 - FileLength

/// <summary>

/// 파일 길이

/// </summary>

[MessageHeader]

public long FileLength { get; set; }

#endregion

#region 소스 스트림 - SourceStream

/// <summary>

/// 소스 스트림

/// </summary>

[MessageBodyMember]

public Stream SourceStream { get; set; }

#endregion

}

▶ FileRequest.cs


using System.ServiceModel;

namespace TestServer
{
    /// <summary>
    /// 파일 요청
    /// </summary>
    [MessageContract]
    public class FileRequest
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 파일명 - FileName

        /// <summary>
        /// 파일명
        /// </summary>
        [MessageBodyMember]
        public string FileName { get; set; }

        #endregion
    }
}

using System.ServiceModel;

namespace TestServer

{

/// <summary>

/// 파일 요청

/// </summary>

[MessageContract]

public class FileRequest

{

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

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

#region 파일명 - FileName

/// <summary>

/// 파일명

/// </summary>

[MessageBodyMember]

public string FileName { get; set; }

#endregion

}

▶ IFileService.cs


using System.Collections.Generic;
using System.ServiceModel;

namespace TestServer
{
    /// <summary>
    /// 파일 서비스 인터페이스
    /// </summary>
    [ServiceContract]
    public interface IFileService
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method

        #region 모든 파일명 리스트 구하기 - GetAllFileNameList()

        /// <summary>
        /// 모든 파일명 리스트 구하기
        /// </summary>
        /// <returns>모든 파일명 리스트</returns>
        [OperationContract]
        List<string> GetAllFileNameList();

        #endregion
        #region 업로드 하기 - Upload(fileData)

        /// <summary>
        /// 업로드 하기
        /// </summary>
        /// <param name="fileData">파일 데이터</param>
        [OperationContract]
        void Upload(FileData fileData);

        #endregion
        #region 다운로드 하기 - Download(fileRequest)

        /// <summary>
        /// 다운로드 하기
        /// </summary>
        /// <param name="fileRequest">파일 요청</param>
        /// <returns>파일 데이터</returns>
        [OperationContract]
        FileData Download(FileRequest fileRequest);

        #endregion
    }
}

using System.Collections.Generic;

using System.ServiceModel;

namespace TestServer

{

/// <summary>

/// 파일 서비스 인터페이스

/// </summary>

[ServiceContract]

public interface IFileService

{

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

#region 모든 파일명 리스트 구하기 - GetAllFileNameList()

/// <summary>

/// 모든 파일명 리스트 구하기

/// </summary>

/// <returns>모든 파일명 리스트</returns>

[OperationContract]

List<string> GetAllFileNameList();

#endregion

#region 업로드 하기 - Upload(fileData)

/// <summary>

/// 업로드 하기

/// </summary>

/// <param name="fileData">파일 데이터</param>

[OperationContract]

void Upload(FileData fileData);

#endregion

#region 다운로드 하기 - Download(fileRequest)

/// <summary>

/// 다운로드 하기

/// </summary>

/// <param name="fileRequest">파일 요청</param>

/// <returns>파일 데이터</returns>

[OperationContract]

FileData Download(FileRequest fileRequest);

#endregion

}

▶ FileService.cs


using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.ServiceModel;

namespace TestServer
{
    /// <summary>
    /// 파일 서비스
    /// </summary>
    public class FileService : IFileService
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 모든 파일명 리스트 구하기 - GetAllFileNameList()

        /// <summary>
        /// 모든 파일명 리스트 구하기
        /// </summary>
        /// <returns>모든 파일명 리스트</returns>
        public List<string> GetAllFileNameList()
        {
            List<string> fileNameList = Directory.GetFiles("d:\\upload").Select(Path.GetFileName).ToList();

            return fileNameList;
        }

        #endregion
        #region 업로드 하기 - Upload(fileData)

        /// <summary>
        /// 업로드 하기
        /// </summary>
        /// <param name="fileData">파일 데이터</param>
        public void Upload(FileData fileData)
        {
            string sourceFilePath      = fileData.FilePath;
            string sourceFileName      = Path.GetFileName(sourceFilePath);
            string targetDirectoryPath = "d:\\upload";
            string targetFilePath      = Path.Combine(targetDirectoryPath, sourceFileName);

            if(!Directory.Exists(targetDirectoryPath))
            {
                Directory.CreateDirectory(targetDirectoryPath);
            }

            try
            {
                using(FileStream targetStream = File.Create(targetFilePath))
                {
                    using(Stream sourceStream = fileData.SourceStream)
                    {
                        sourceStream.CopyTo(targetStream);
                    }
                }
            }
            catch(IOException exception)
            {
                Console.WriteLine(exception.Message);

                if(File.Exists(targetFilePath))
                {
                    try
                    {
                        File.Delete(targetFilePath);
                    }
                    catch
                    {
                    }
                }
            }
        }

        #endregion
        #region 다운로드 하기 - Download(fileRequest)

        /// <summary>
        /// 다운로드 하기
        /// </summary>
        /// <param name="fileRequest">파일 요청</param>
        /// <returns>파일 데이터</returns>
        public FileData Download(FileRequest fileRequest)
        {
            string sourceFilePath = Path.Combine("d:\\upload", fileRequest.FileName);

            Stream sourceStream = null;

            try
            {
                sourceStream = File.Open(sourceFilePath, FileMode.Open, FileAccess.Read, FileShare.Read);
            }
            catch(Exception)
            {
                return null;
            }

            OperationContext clientContext = OperationContext.Current;

            clientContext.OperationCompleted += delegate(object sender, EventArgs e)
            {
                if(sourceStream != null)
                {
                    sourceStream.Dispose();
                }
            };

            return new FileData
            {
                FilePath     = fileRequest.FileName,
                FileLength   = sourceStream.Length,
                SourceStream = sourceStream
            };
        }

        #endregion
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.ServiceModel;

namespace TestServer

{

/// <summary>

/// 파일 서비스

/// </summary>

public class FileService : IFileService

{

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

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

#region 모든 파일명 리스트 구하기 - GetAllFileNameList()

/// <summary>

/// 모든 파일명 리스트 구하기

/// </summary>

/// <returns>모든 파일명 리스트</returns>

public List<string> GetAllFileNameList()

{

List<string> fileNameList = Directory.GetFiles("d:\\upload").Select(Path.GetFileName).ToList();

return fileNameList;

}

#endregion

#region 업로드 하기 - Upload(fileData)

/// <summary>

/// 업로드 하기

/// </summary>

/// <param name="fileData">파일 데이터</param>

public void Upload(FileData fileData)

{

string sourceFilePath = fileData.FilePath;

string sourceFileName = Path.GetFileName(sourceFilePath);

string targetDirectoryPath = "d:\\upload";

string targetFilePath = Path.Combine(targetDirectoryPath, sourceFileName);

if(!Directory.Exists(targetDirectoryPath))

{

Directory.CreateDirectory(targetDirectoryPath);

}

try

{

using(FileStream targetStream = File.Create(targetFilePath))

{

using(Stream sourceStream = fileData.SourceStream)

{

sourceStream.CopyTo(targetStream);

}

catch(IOException exception)

{

Console.WriteLine(exception.Message);

if(File.Exists(targetFilePath))

{

try

{

File.Delete(targetFilePath);

}

catch

{

}

#endregion

#region 다운로드 하기 - Download(fileRequest)

/// <summary>

/// 다운로드 하기

/// </summary>

/// <param name="fileRequest">파일 요청</param>

/// <returns>파일 데이터</returns>

public FileData Download(FileRequest fileRequest)

{

string sourceFilePath = Path.Combine("d:\\upload", fileRequest.FileName);

Stream sourceStream = null;

try

{

sourceStream = File.Open(sourceFilePath, FileMode.Open, FileAccess.Read, FileShare.Read);

}

catch(Exception)

{

return null;

}

OperationContext clientContext = OperationContext.Current;

clientContext.OperationCompleted += delegate(object sender, EventArgs e)

{

if(sourceStream != null)

{

sourceStream.Dispose();

}

};

return new FileData

{

FilePath = fileRequest.FileName,

FileLength = sourceStream.Length,

SourceStream = sourceStream

};

}

#endregion

}

▶ Program.cs