Thread 동기화(Monitor, Mutex)

3.Monitor.Enter and Monitor.Exit
Monitor.Enter 와 Monitor.Exit 는 try/ finally 사용한다
Monitor.Enter(_locker); try { if(_val2 != 0) Console.WriteLine(_val1 / _val2); _val2 = 0; } finally { Monitor.Exit(_locker); } Monitor.Exit를 Monitor.Enter 없이 호출된다면 예외를 호출 한다.
CLR 4.0에서는 Monitor.Enter 메소드르 오버로드했다.
public static void Enter(object obj, ref bool lockTaken);
bool lockTaken = false; try { Monitor.Enter(_locker, ref lockTaken); } finally { if(lockTaken) Monitor.Exit(_locker); TryEnter Monitor 또한 TryEnter 메소드를 제공한다. millisecond 또는 TimeSpan으로TimtOut을 정한다.
Choosing the Synchronization Object
어떤 오브젝트라도 동기오브젝트로 사용가능하다 스레드 내에서
class ThreadSafe { List<string> _list = new List<string>(); void Test() { lock(_list) { _list.Add("Item 1"); .... lock(typeof(Widget)) {...} // For protecting access to statice 데드락(스레드내에서 서로 락을 걸음)
중첩락 (Nested Locking)은 가장 바깥쪽에 있는것이사용됨.
4. Mutex
뮤텍스는 C#에서 lock과 같다. 하지만 멀티프로세스 에서 across된다.
즉 뮤텍스는 애플리케이션에서 광범위하게사용된다(컴퓨터)
뮤텍스는 스레드간 아니라 프로세스간에서 사용된다.
뮤텍스로 현재 실행중인 프로그램이
이미 실행되었는지 파악하고 이를 취소하는방법을 사용했었다.
class OneAtATimePlease { staticc void Main() { using(var mutex = new Mutex(false, "oreilly,com OneAtATimeDemo")) { if(!mutex.WaitOne(TimeSpan.FromSeconds(3), false)) { Console.WriteLine("Another App instance is running. Bye!"); return; } RunProgram(); } } } static void RunProgram() { Console.WriteLine("Runing. Press Enter to exit"); Console.ReadLine(); }

Thread 동기화(Block,Lock)

쓰레드 동기화 문제에 대해 4가지 방법

1. Simple Blocking methods
특정시간의 경과하거나 다른스레드가 끝나기를 기다리여할떄
Sleep, Join and Task.Wait

2. Locking Constructs
제한된 여러 스레드가 실행되어질때 특정시간에 코드의 일부분(크리티컬섹션)을
읽거나 사용할때
하나의 스레드가 코드부분에 접근해야한다.
스레드들은 코드에 접근하기위해 경쟁을 해야하고 서로 방해가 된다.
lock(Monitor.Enter / Moniter.Exit), Mutex, SpinLock
The nonexclusive - Semaphore, SemaphoreSlim, reader/ writer locks.

3. Signaling constructs
스레드는 코드일부분을 사용하고 다른스레드에게 알려야한다.
event wait handles , Monitos' Wait/Pulse methods
Frmaework4.0 CountdownEvent , Barrier classes.

4. NOnblocking synchronization constructs
Thread.MemoryBarrier, Thread.VolatileRead, Thread.VolatileWrite, the volatile keyword, and the Interlocked class.

Blocking
unblocking 발생하는 4가지 방법에는
- 블록킹 조건(조건변수) 이 만족할떄
- 실행시간이 timing out
- Thread.Interrupt
- Thread.Abort
Thread.Suspend를 통한 block은 스레드가 간주하지 않는다.

while(!proceed) ; or while(DateTimeNow < nextStartTime); 같은 방법은..매우 wasteful -_- 좀 나아진다면
while(!proceed) Thread.Sleep(10);
Locking
하나의 스레드가 코드의 일부분을 사용하는데 매우 유용하다
lock과 Mutex가 있는데 lock은 Mutex보다 빠르고 편리하다.
class ThreadUnsafe { static int _val1 = 1, _val2 = 1; static void Go() { if(_val2 !=0) Console.WriteLine( _val1 / _val2); _val2 = 0; } } 이 방법은 클래스가 스레드로부터 안전하지 않다.
두개의 스레드가 Go()메소드를 호출한다. 아마 division-by-zero Exception을 발생시킨다.
이유는 _val2 가 하나의 스레드 로부터 0으로 되고 다른스레드에서 이를 0으로 나누려고 했으니말이다.

자 lock을 이용해서 문제를 고쳐보자
class ThreadSafe { static readonly object _locker = new object(); static int _val1, _val2; static void Go() { lock(_locker) { if(_val2 != 0) Console.WriteLine( _val1 / _val2); _val2 = 0; } } }
오직 하나의 스레드만이 synchronizing objet ( in this case, _locker)특정시간에 접근하므로
다른 스레드에서는 lock의 해제될떄가지 블락을 당할것이다.
이때 블럭된 스레드의 상태 ThreadState 는 WaitSleepJoin 이다.
The Task Parallel Libarary (TPL) and PLINQ sufficiently powerful and high-level
닷넷 4.0 버전부터 TPL을 지원한다고 한다? 잘 모르지만 알아보자
namespace ThreadStarted { class ThreadTest { static void Main(string[] args) { // .NET FrameWork 4.0 이전 버젼은 지원하지 않는다. // ThreadPool.QueueUserWorkItem and Asynchronous delegate 사용해라 Task<string> task = Task.Factory.StartNew<string>(() => DownloadString("http://www.linqpad.net")); RunSomeOntherMethod(); try { string result = task.Result; Console.WriteLine(result); } catch (AggregateException ae) { Console.WriteLine(ae.Message); } } static string DownloadString(string uri) { using (var wc = new System.Net.WebClient()) return wc.DownloadString(uri); } static void RunSomeOntherMethod() { for (int i = 0; i < 10; i++) { Console.WriteLine("aa"); Thread.Sleep(500); } } } }

Thread Getting Started [1]

스레드 사용에 있어서. 너무 혼란이 생겼다. 다시 스레드 공부해보자 namespace ThreadStarted { class ThreadTest { static void Main(string[] args) { Task.Factory.StartNew(Go); /// 스레드를 terminate 하기위한 방법은 finally 또는 Using을 사용하자 /// 스레드를 생성했다면 Join을 사용하자, /// Pooled Thread를 이용했다면 event Wait Handle을 사용하자 // 백그라운드로 돌리면 Main스레드는 그냥 바로 종료하게됩니다. // foreground로 돌리면 ReadLine()을 입력할때까지 대기를 하게되죠 Thread worker = new Thread(() => Console.ReadLine()); if (args.Length > 0) worker.IsBackground = true; // worker.Start(); // 쓰레드를 사용하는 많은 방법들이 있다. // 1. delegate인 new ThreadStart() Thread t = new Thread(new ThreadStart(Go)); t.Start(); Go(); //######################## // 2. 생성자로 메소드의 주소를 넘긴다. Thread t2 = new Thread(Go); t2.Start(); //######################## // 3. Lamda 표현식으로 바로 Thread t3 = new Thread(() => Console.WriteLine("new")); t3.Start(); //######################## // 4. 람다 표현식으로는 number of many argument를 넘겨줄수잇다. Thread t4 = new Thread(() => Print("HIHIHI", 1, 4.0)); t4.Start(); //######################## // 5. Thread 객체 생성없이 빠르고 간단하게 생성 가능하다. new Thread(() => { Console.WriteLine("I'm runing on anotehr Thread!"); Console.WriteLine("This is so easy"); } ).Start(); //######################## // 6. 요렇게도 가능하군요 new Thread(delegate() { Console.WriteLine("delegate USE Thread"); }).Start(); //######################## // 7. object인자를 받는 쓰레드를 만들었습니다. Thread newt1 = new Thread(Print); // object newt1.Start("Hello"); /// Thread Priority /// using(Process p = Process.GetCurrentProcee()) /// p.PriorityClass = ProcessPriorityClass.High; } static void Print(object messageObj) { string message = (string)messageObj; Console.WriteLine(message); } static void Print(string message, int i, double d) { Console.WriteLine(message); Console.WriteLine(i.ToString() + " " + d.ToString()); } static void Go() { Console.WriteLine("Hello!"); } } }

IMG 크기변환 및 압축

이전 포스트 Exif에 대해 알아보았습니다.
기술의발전??으로 디카나 핸드폰으로 찍은 사진(이미지)등
화질이 매우 좋아져서 그만큼 데이터 크기도 커졌습니다.

오늘은 JPEG파일 크기 변환과 압축을 해보겠습니다.
아래의해당 소스는 MSDN에서 친절하게 설명합니다.

크기가 큰 이미지 파일을
썸네일 이미지로 보여준다던지
압축하여 디비에 때려 넣든지 해야합니다. (자바 JAI, C# ziplib)

JPEG 압축 수준설정
GDI에서 이미지 자르기 및 배율조정
// 이미지 리사이즈 private void ImageReduction(string filename) { string PATH = AppDomain.CurrentDomain.BaseDirectory; Bitmap orijinalBMP = new Bitmap(filename); int oWidth = orijinalBMP.Width; // 구 이미지 너비 int oHeight = orijinalBMP.Height; // 구 이미지 높이 int sngRatio = oWidth / oHeight; // 비율 int newWidth = 100; // 신 이미지 너비 int newHeight = newWidth / sngRatio; // 신 이미지 높이 Bitmap newBMP = new Bitmap(orijinalBMP, newWidth, newHeight); Graphics oGraphics = Graphics.FromImage(newBMP); // 신이미지 Grpahics를가져와 oGraphics.SmoothingMode = System.Drawing.Drawing2D.SmoothingMode.AntiAlias; // 랜더링 품질설정 oGraphics.InterpolationMode = System.Drawing.Drawing2D.InterpolationMode.HighQualityBicubic; // 고품질로 oGraphics.DrawImage(orijinalBMP, 0, 0, newWidth, newHeight); // 그립니다. newBMP.Save(PATH + "thum_.jpg"); orijinalBMP.Dispose(); newBMP.Dispose(); oGraphics.Dispose(); } // 데이터 압축 private void VaryQualityLevel() { using (Bitmap bmp1 = new Bitmap(PATH + @"img2.jpg")) { ImageCodecInfo jgpEncoder = GetEncoder(ImageFormat.Jpeg); // jpeg코덱있는지파악 System.Drawing.Imaging.Encoder myEncoder = System.Drawing.Imaging.Encoder.Quality; // 고품질 EncoderParameters Enparameters = new EncoderParameters(1); EncoderParameter Enparameter = new EncoderParameter(myEncoder, 50L); Enparameters.Param[0] = Enparameter; bmp1.Save(PATH + "TestPhotoQualityFifty.jpg", jgpEncoder, Enparameters); Enparameter = new EncoderParameter(myEncoder, 100L); Enparameters.Param[0] = Enparameter; bmp1.Save(PATH + "TestPhotoQualityHundred.jpg", jgpEncoder, Enparameters); Enparameter = new EncoderParameter(myEncoder, 0L); Enparameters.Param[0] = Enparameter; bmp1.Save(PATH + "TestPhotoQualityZERO.jpg", jgpEncoder, Enparameters); bmp1.Dispose(); } } 위의 이미지 리사이즈 부분에서는 Bitmap을 사용했습니다만.- 많은 이미지 처리시에는 속도매우 느려졌습니다. 멋도모르고 걍 리사이즈 되니 좋았지요 ㅠㅠ Mj Blog, C#보다 빠르게 썸네일 이미지 만드는법 을 참고
좀 개선해봤습니다. public byte[] GetThumnailImage(string filename, string path) { byte[] b = null; using (FileStream fs = File.OpenRead(path + "\\" + filename)) { // case Image.FromFile 이용 // Image org = Image.FromFile(path + "\\" + filename); // case Image.FromStream 이용 = fileStream 속도 .. 향상 Image org = Image.FromStream(fs, false, false); int oWidth = org.Width; // 가로 int oHeight = org.Height; // 세로 int sngRatio = 1; // 가로 대 세로 비율 if (oWidth < oHeight) // 세로가 더큰경우 { sngRatio = oHeight / oWidth; // 세로 / 가로 } else // 가로보다 세로가 더클시 { sngRatio = oWidth / oHeight; // 가로 / 세로 } int nWidth = 40; // Thumnail 이미지 40으로세팅 int nHeight = nWidth / sngRatio; // 가로 / 비율 Image tn = org.GetThumbnailImage(nWidth, nHeight, delegate { return false; }, IntPtr.Zero); b = ImageToByteArray(tn); tn.Dispose(); org.Dispose(); } return b; } // IMG to byte[] public byte[] ImageToByteArray(Image img) { ImageConverter cvt = new ImageConverter(); byte[] b = (byte[])cvt.ConvertTo(img, typeof(byte[])); return b; }

Exif 이미지 파일형식

교환 이미지 파일 형식 (Exif; Exchangable Image File format)은 디지털 카메라에서
이용되는 이미지고 JPEG, TIFF6.0, RIFF, WAV파일에 이용되며
사진에 대한 정보를 포함하는 메타데이터를 추가한다고 한다. Exif는 JPEG2000, PNG, GIF파일에서는
지원하지 않는다.

Exif는 일본전자산업진흥회(JEIDA)에서 개발되었다고 한다-_-;
현재 교환이미지 파일형식을 정하는 단체가 기구는 존재하지않지만
디지털 카메라에서 전세계적으로 사용된다고합니다.

- 날짜와 시간정보, 카메라정보, 저작권정보, 그외GPS정보를 담고있습니다.
Exif 메타 데이터 정보
카메라 제조사, 카메라 모델, 회전 방향, 날짜와 시간, 색 공간, 초점 거리, 플래시, ISO 속도, 조리개, 셔터 속도 등의 정보를 제공한다.

위키 Exif

c#에서 GPS정보를 가진 jpeg파일을 읽어 GPS 와 정보등을 읽어보도록 하겠습니다.
우선 Exif파일을 읽어드리기 위해선 라이브러리 ExifLibrary를 다운받아봅시다.

codeproject ExifLibrary

만든이는 터키의 Ozgur Ozcitak 님이랍니다. 여행을 가셔서 많은 사진들을 찍었답니다.
gps정보가 담긴 사진말이죠 , 집으로 돌아와 자기가 어디에 가서 무얼했는지
사진만으로는 귀찬았답니다. 그래서 사진에는gps정보가 있을테니
구글어스나, 피카소, 등으로 gps정보를 가지고 지도에 내가 어디갔었는지를
표시해주려고 했엇지만 ... c#에서는 Exif파일포맷에 대한 기능을 제공하고있지만
마음에 들지 않았나봅니다 좀더 정확한 정보가 필요 했었나보군요.
그래서 자기가 손수 Exif라이브러리를 만들었다고 하네요!!! OH Showking ,,
개발자는 이런데서 빛을 발휘하는군요 ..오옷 나두ㅠ_ㅠ

다운받구 해당 폴더 안에 ExifLabrary.dll 을 프로젝트에
참조 추가해주고 사용해 봅시다.
뭐 사용법은 간단합니다.(codepoject 사용법이 나와있습니다.큭)
<br /> private readonly string img = @"\\img.jpg";<br /> ImageFile file = ImageFile.FromFile(img);<br /> foreach (ExifProperty item in file.Properties.Values)<br /> {<br /> Console.WriteLine("{0} 's IFD: {1}", img, item.IFD);<br /> Console.WriteLine("{0} 's Interoperablilty: {1}", img, item.Interoperability); <br /> Console.WriteLine("{0} 's NameD: {1}", img, item.Name);<br /> Console.WriteLine("{0} 's Value: {1}", img, item.Value);<br /> Console.WriteLine("{0}'s Tag: {1}",img ,item.Tag);<br /> if (item.Tag == ExifTag.GPSLatitude)<br /> {<br /> GPSLatitudeLongitude gps = item as GPSLatitudeLongitude;<br /> Console.WriteLine("GPS(Float) : {0}",gps.ToFloat());<br /> }<br /> }<br />


Exif파일의 각종 정보를 알아볼수가 있었습니다.~~
다음시간에는 이 위치정보를 가지고 지도에 찍어보도록 하겠습니다.
즐거운 클수마스 보내세요

아래는 Exif파일 포맷입니다.

믿음과 사람

블로그구경하던중 믿음에 관련해서 글을 읽었던적이 있습니다.
마음에 와닿아 자꾸 기억나는 글이지요

사람을 한결가이 믿는 다는것은 쉬운일이 아니다.
누구나 살아가면서 주변의 소문이나 다른 사람의 이야기로 인해 어떤 살마을
오해하여 인간관계가 꼬이는 경험을 한적이 있을것이다.
사업상 동반자에서 원수로 돌아서기도한다.

우리는 매일 의식적이든 무의식적이든 어떤 사람의 신뢰성에 대해서
크고 작은 판단을 하고 나름대로 점수를 매기기도 한다. 그 판단은 오차가 나기 마련이다
사람은 상대를 있는 그대로 보기보다는 지극히 주관적인 마음의 창을 통해서 바라보기 때문이다.
더군다나 이 마음의 창은 외부 상황에 따라 쉬이 흔들린다.


"증자는 어질고 효성이 지극한 공자의 제자이다.
한번은 그와 이름이 같은 이가 사람을 죽였다. 증자를 아는 사람이 걱정하여
증자 어머니에게 달려갔다.

"증삼(증자의 본명)의 사람을 죽였습니다."
어머니는 그말을 믿지 않고 여전지 베를 짰다 또 한사람이 찾아와 고했다.
"증삼이 살인을 했습니다."
"우리애는 그럴사람이 아니다."
증자의 어머니는 계속하여 베를 짰다. 얼마뒤 또 한사람이 달려와서 고했다.
"증삼이 사람을 죽였습니다"
마침내 증자의 어머니는 북을 내던지고 베틀에서 내려와 달아났다.
증자가 어질다는 사실을 믿고 있는 어미니도 처음 두 사람까지는 믿지 않았지만,
세 사람이나 와서 같은 말을 하자 믿지 않을수 없었던 것이다.



공자조차도 평소 덕행을 찬탄해 마지않았던 수제자 안회가
스승인 자신에게 올릴 밥에 먼저 손을 댄다고 의심한적이 있었다. 하지만 사실은
안회가 밥에 떨어진 재와 티를 걷어내다가 같이 딸려 나온 밥풀이 버리가 아까워 먹었던 것이다.
공자가 그러니 봍오 사람들이야 오죽하겠는가.
당시 공자는 자신의 실수를 한탄하며 다음과 같이 말했다고 한다.

"믿을수 있는 것은 눈이지만 그래도 믿을수가 없고, 의지할 것은 마음이지만 그래도 의지할것은 못된다.
제자는 이것을 기록하라. 사람을 아는일은 진실로 쉬운것이 아니라고.

마음으로 사람을 판단하려 한다면 여러가지 오류를 면하기 어렵다.
증자 어머니의 이야기처럼 아무리 황당한 거짓말이라도 반복적으로 들려온다면
마침내 마음은 사실로 받아들인다.
또한 마음은 그 당시 상태에 따라서 판단에 지대한 영향을 미칠수 있다.
자신의 마음이 우울할 때는 상대를 평소보다 부정적으로 볼 가능성이 높으며,
마음이 밝고 기쁠 때는 웬만하면 믿어줄 수 있게된다.

인간은 고정불변의 존재가 아니다
상대가 의심하느냐 혹은 믿어 주느냐에 따라서 그 사람의 신뢰성은 얼마든지
바꿀수 있는 상호간섭의 존재인것이다.
즉, 호감을 가지고 믿어준다면 상대의 믿음에 호응해서 변하기도 하는 것이 인간이다.

변하는것과 변하지 않는것을 구분하는 프로그래밍

변하는 것과 변하지 않는것: 개발철학

보기 알티베이스http://altistory.net/4539

[Windows] Apache2.2.x + php 5.x + MongoDb 설치

오래전에 간략하게 게시판에 메모해놓고 포맷하고 다시 구축하는김에
새로이 블로그에 작성합니다.

%php를 이클립스에서 개발위해 php 플러그인을 설치하자
Help- Install New Software..에서 inhttp://download.eclipse.org/tools/pdt/updates/2.0/

이럴 필요가없다!!!!! Help - Eclipse MarketPlace 에서 PTI 검색하 다운로드 받자!!!

구축 시점이 12년 12월 12일인데 이클립스 새로운버젼인 juno를 설치했다..(주노가 그닥 -_-)
기존 이클립스에서 자동완성기능인 Ctrl+ Space가 없다고 한다.
플러그인으로 다운받아야 한다고 해서

Help - Install New Software..에서 http://download.eclipse.org/releases/juno 의
Language 에서 Code Recommender를 설치하자

========== 이부분은 아래로는 확실하지 않습니다. 설치하고 정리하겠습니다. ============
1. 아파치 www.apache.org/ 으로 가서 다운로드한다.
- VC9 과 VC6 의 차이: VC9은 visual c++ 2008 Runtime / Runtime(x64)가 설치되어있어야만 사용가능,
2008로 컴파일되었다.

또한 IIS 서버에서 사용 VC6은 visual 6 컴파일된것으로 apache1 또는 apcahe2
사용한다면 VC6을 사용해야함

2. 다운로드 받은후 설치를 시작한다. 본인은 C:\Apache2.2

3. PHP http://www.php.net/ 로 가서 다운로드를 받는다.
(다른분들은 msi installer 파일보단 zip 파일로 다운로드 하라는데 관련 DLL 존재유무란다)
그냥 다운로드받음 C:\php (Thread 용으로 받아야 php5apache.dll 파일존재함)


기냥 C:\Apache2.2\ CONF\Extra 하지말고 걍 httpd-conf 파일에다가 아래 내용을 삽입하자(마지막줄에)

#BEGIN PHP INSTALLER EDITS - REMOVE ONLY ON UNINSTALL
PHPIniDir "c:\php"
LoadModule php5_module "c:\php\php5apache2_2.dll"
#END PHP INSTALLER EDITS - REMOVE ONLY ON UNINSTALL

중간 부분에다가
AddType application/x-httpd-php .amz .php .htm .inc .dos .phps .html
AddHandler application/x-httpd-php .phps
AddType application/x-httpd-php-source .phps

아래의 내용을 포함시키자 그런후
C:\Apache2.2\htdocs 아래의 디렉토리밑에 php 관련 파일을 하나 만들어넣고
서버를 재시작하고 http://localhost/XXX.php 를 돌려보면 잘 돌아갈것이다..

8. 몽고디비를 설치해보자
http://kr2.php.net/manual/en/mongo.installation.php#mongo.installation.manual
- 해당 사이트에서 Installing on Windows 부분에서 자신의 php 버젼에 맞는것을 다운로드 하자.
- unzip하고나서 해당 파일을 C:\PHP 아래에 EXT 디렉톨이를 만들어서 넣고
- PHP.INI 파일을 열어서 " extension=php_mongo.dll " 을 넣어주고 재시작 하면 끝~~


PHP Down
http://php.net/downloads.php

Mongo PHP Driver 알맞은거 다운
https://github.com/mongodb/mongo-php-driver/downloads

Mongo 설치 방법
http://se2.php.net/manual/en/mongo.installation.php#mongo.installation.windows


cmd창을 열어서
1. c:\ netstat -ano (netstat -help)
확인하다 우측의 PID를 확인

2. window 작업관리자 열고 해당 PID를 사용하는 프로세스를 확인하고 강제종료한다

Java개발환경구축

자바 환경 구축
1.JDK 설치 운영체제 32/ 64비트에 따른 JDK다운로드 설치
본인은 C:\JAVA\설치함
http://www.oracle.com/technetwork/java/javase/downloads/index.html

2. 이클립스 설치
http://www.eclipse.org/downloads/

자 자바환경변수를 등록해보까?
그렇다면 환경변수는 왜 ?등록하는것인가?
왜 등록하는것인가?(현실은시궁창:http://c36wn.egloos.com/4205675)

매번 구축할때마다..검색하는 번거로움을 없애기 위해 이렇게 남긴ㄷ..

소수 prime

소수 Prime Number http://ko.wikipedia.org/wiki/소수_(수론)

100까지의 처음 25개의 소수는
2, 3, 5, 7, 11, 13, 17, 19, 23, 29, 31, 37, 41, 43, 47, 53, 59, 61, 67, 71, 73, 79, 83, 89,
97, 101, 103, 107, 109, 113...
여기서 2는 유일한 짝수 소수이다.
소수를 찾는 현재까지 가장 간단한 방법으로 에라토스테네스의 체 가 있다.
1. 찾고자 하는 범위의 자연수를 나열한다.
2. 2부터 시작하여, 2의배수를 지워나간다.
3. 다음수의 배수를 모두 지운다(3-의배수,4...5..)

연속 소수체 예를 들어 8은 연속된 두 소수 3과 5의 합으로 나타내어질수 있으므로 2 - 연속 소수체이다.
아래는 에라토스테네스의 체를 사용하지 않고 소수를 구했다.
public static void FindPrimeNumber(int primeNumberLoopToFind) { int divisorsFound = 0; int startDivisor = 1; for (int i = 0; i < primeNumberLoopToFind; i++) { divisorsFound = 0; startDivisor = 1; while (startDivisor <= i) { if (i % startDivisor == 0) divisorsFound++; startDivisor++; } if (divisorsFound == 2) { Console.Write(i.ToString() + " "); } } }
Q.에라토스테네스의 체의 방법으로 구하려면
2의배수, 3의배수 4의배수를 지워나간다고 했다.
100 까지의 소수를 구할경우 지워나간다고 했다면
1, 2, 3 ..... 98, 99, 100 의 수를 정수형 배열에 가지고있어야 하는건가?
배열에 가지고있다가 2의배수 3의배수,,, 를 배열인덱스로 지워야하는건가?
다른방법??은 없으까

http://ko.wikipedia.org/wiki/에라토스테네스의_체 위키에 간단한 C++과 JAVA로 구현된 알고리즘과 이미지가 있으니 참고하자.

Stack Heap,,,메모리공간

아래와 같은 메소드와 변수들이 있을경우 메모리에서는 도대체 무슨일이 일어나는가??
public void Method1() { // Line 1 int i=4; // Line 2 int y=2; //Line 3 class1 cls1 = new class1(); }

출처 http://www.codeproject.com/Articles/76153/Six-important-NET-concepts-Stack-heap-value-types
다음에는 new로 인스턴스를 두개 생성했을경우의 그림이다.

이렇게 스택과 힙 두영역에 나누어 지고
힙영역의 메모리가 가득찬다면 C#? 닷넷에서는
Garbage Collecter가 자동적으로 메모리를 관리해준다.
사용하지 않거나 사용한지 오래된 것은 GC가 알아서 처리하여 메모리를관리해준다고 한다.
하지만 직접적인 GC 호출은 시스템에 성능저하를 유발할수 있어 불가피한상황이 아니라면 피해야한다고 함.

GC 사용을 하지말라면???
IDispose, Finalize 를 구현하자!!! 단, C#에서는 소멸자를 사용하지말자?
예를 들자면 대용량의 객체를 사용한뒤 시스템 부하를 줄여야 하는상황..

다음의 코드는 인자로 받아진 object의 메모리 주소를 알아보는 코드다
public static string Get(object o) { GCHandle handle = GCHandle.Alloc(o, GCHandleType.Normal); try { IntPtr pointer = GCHandle.ToIntPtr(handle); return "0x" + pointer.ToString("X"); } finally { handle.Free(); } } // 사용해보자 Cat Nabi = new Cat(); Nabi.Mew(); Console.WriteLine(Get(Nabi)); Nabi = new Cat("온순"); Nabi.Mew(); Console.WriteLine(Get(Nabi)); Nabi = new Cat(3, "난폭"); Nabi.Mew(); Console.WriteLine(Get(Nabi)); {

Thread 개념

Socket통신을 사용하다가 Client가 통신이 끊기게 되면
Server는 이를 알아채고 클라이언트의 접속을 다시 대기해야합니다.

Socket.Accept();

Accept()부분을 쓰레드로 생성하여
기본 스레드와 별개로 스레드를 생성해서 Accept()를 했습니다.
이러면 기본스레드에 대해 비동기적으로 Accept()를 수행됩니다.

스레드를 이해하고 얼마 지나지 않으면 스레드에 기억이..가물가물..
또 다시 스레드에대 학습하게 됩니다.-_-;;

간단히 스레드에 대해 알아봅시다.
public class Worker { // This method will be called when the thread is started. public void DoWork() { while (!_shouldStop) { Console.WriteLine("worker thread: working..."); } Console.WriteLine("worker thread: terminating gracefully."); } public void RequestStop() { _shouldStop = true; } // Volatile is used as hint to the compiler that this data // member will be accessed by multiple threads. private volatile bool _shouldStop; } public class WorkerThreadExample { static void Main() { // Create the thread object. This does not start the thread. Worker workerObject = new Worker(); Thread workerThread = new Thread(workerObject.DoWork); // Start the worker thread. workerThread.Start(); Console.WriteLine("main thread: Starting worker thread..."); // Loop until worker thread activates. while (!workerThread.IsAlive); // Put the main thread to sleep for 1 millisecond to // allow the worker thread to do some work: Thread.Sleep(1); // Request that the worker thread stop itself: workerObject.RequestStop(); // Use the Join method to block the current thread // until the object's thread terminates. workerThread.Join(); Console.WriteLine("main thread: Worker thread has terminated."); } } Worker클래스의 DoWork 메소드를
Thread.Start() 메소드로 실행하여 줍니다.

workThread.IsAlive 는 현재 스레드의 실행상태를 나타내는 값을 가져옵니다.
스레드가 시작되었으며 정상적으로 종료 또는 중단되지 않았으면 true고, 그렇지않으면 false

Thread.Sleep(1); 이렇게 한다면 기본스레드가 잠시 중단하고
다른 스레드(workerThread)는 DoWork메소드의 루프를 몇차례 반복하여 실행할수 있습니다.
Thraed.Abort()는 다른 스레드에서 스레드를 종료 할수 있습니다.
하지만 스레드의 작업이 완료됬는지 관계없이 스레드가 종료되어 리소스를 정리할수없습니다.

그래서 기본스레드(메인)에서 Thread.Join()메소드를 호출하여
개체가 가리키는 스레드가 종료될때까지 현재 스레드를 차단하거나 대기상태로 만듭니다.
Join()은 작업자스레드가 반환되고 자체 종료될떄까지 반환되지 않습니다.

관련내용은 http://msdn.microsoft.com/ko-kr/library/7a2f3ay4(v=vs.90).aspx
다음글에서 쓰레드와 관련되는 클래스를 만들어 사용해 보기로 합시다.

사용자정의 컨트롤 만들어보기 (ProgressBar)

C# 닷넷 컴포넌트의 ProgressBar가 있습니다.
닷넷 프로그래스바의 내부에 Text라던가 Label을 넣어
프로그래스바와 내부에 글자를 넣어 보겠습니다.
우리가 만들것은 아래의 그림과 같은 ProgressBar 사용자 정의 컨트롤 입니다.

추가 => 사용자 정의컨트롤을 선택하여 CProgressBar.cs 를 생성합니다.
이제 코딩을 시작해 봅시다.
우선, 디자인부분에서 프로그래스바와 내부에 위치할 Text를 가질 Label을 넣어줍니다.

하나의 TableLayoutPanel(열 두개)을 만들고
각 열에 Label을 만들어넣습니다(구분을 명확하게 하기위해 Color를 임의로 넣어준겁니다.)
TableLayoutPanel과 Label의 BackColor는 투명하게 해줍니다(TransParent)
코드를 살펴봅시다.

CProgressBa 생성자에 디자이너부분에서 만든 Label들의 ForeColor와 Font를 지정합니다.
(불필요한 작업같군요. 안해줘도 될거 같아요)
public partial class CProgressBa : UserControl { public CProgressBa() { InitializeComponent(); this.ForeColor = SystemColors.Highlight; // Label의 기본 ForeColor - Black 및 Font label1.ForeColor = Color.Black; label2.ForeColor = Color.Black; label1.Font = GetLabelFont(); label2.Font = GetLabelFont(); } public Font GetLabelFont() { return new Font("굴림", 9.0F, System.Drawing.FontStyle.Regular, System.Drawing.GraphicsUnit.Point, ((byte)(129))); } 맴버 변수 선언부분입니다.
Pen pen은 열을 구분하기 위해 OnPaint시 사용할 Color입니다.
┌───────────┐
│            │            │
└───────────┘빨간 구분선

protected 선언된 맴버변수는 디자이너의 속성창을 보면 생성되어져 보입니다.
속성창에서 값을 변경하게 되면 아래의 맴버변수들의 변경되는거지요.
protected로 선언되었으니 이를 대신 받아줄 get; set 변수들이 필요합니다.
private Pen pen = new Pen(Color.FromArgb(160, 160, 160)); private Point p1, p2; private readonly int bar_gap = 1; protected Color MedoColor = Color.FromArgb(227, 237, 251); // Label의 기본색 protected Color MesuColor = Color.FromArgb(253, 232, 226); // Label의 기본색 protected bool RightToLeft = false; protected float percent = 0.0f; // 0 - 100% Value protected string JanRyang = "잔량"; // Label의 기본 텍스트 protected string Debi = "대비"; protected float Maximum = 100.0f; // ProgressBar에 사용될 멕시멈 아래에서 Value 즉 Percent값의 변경될때마다 Invalidate()를 호출하는데요
this.Invalidate()메소드를 호출할때마다 OnPaint()메소드를 재 호출 합니다
public Color MEDOCOLOR { get { return MedoColor; } set { MedoColor = value; } } public Color MESUCOLOR { get { return MesuColor; } set { MesuColor = value; } } public float Value { get { return percent; } set { //if (value < 0) value = 0; //else if (value > 100) value = 100; percent = value; this.Invalidate(); } } [System.ComponentModel.Bindable(true)] public string JANRYANG { get { return JanRyang; } set { JanRyang = value; // 매도, 매수 if (this.RightToLeft) { this.label2.Text = JanRyang; } else { this.label1.Text = JanRyang; } } } [System.ComponentModel.Bindable(true)] public string DEBI { get { return Debi; } set { Debi = value; // 매도, 매수 if (this.RightToLeft) { this.label1.Text = Debi; } else { this.label2.Text = Debi; } } } [System.ComponentModel.Bindable(true)] public bool RIGHT2LEFT { get { return RightToLeft; } set { this.RightToLeft = value; } } public float MAXIMUM { get { return Maximum; } set { Maximum = value; } } OnPaint 메소드를 오버라이드 해서 필요한 것을 그려주면 되는것이지요
ClientRectangle은 컨트롤 영역의 사각형을 가지고 계산식으로
Rectangle에 색깔을 입히게 되는겁니다.
protected override void OnPaint(PaintEventArgs e) { base.OnPaint(e); try { Rectangle rect = ClientRectangle; Rectangle lb; if (RightToLeft) { lb = new Rectangle(rect.Width - (int)Math.Round(((float)Value / Maximum) * rect.Width), rect.Y + bar_gap, (int)Math.Round(((float)Value / Maximum) * rect.Width), rect.Height - bar_gap * 2); e.Graphics.FillRectangle(new SolidBrush(MedoColor), lb); } else { lb = new Rectangle(rect.X, rect.Y + bar_gap, (int)Math.Round(((float)Value / Maximum) * rect.Width), rect.Height - bar_gap * 2); e.Graphics.FillRectangle(new SolidBrush(MesuColor), lb); } e.Graphics.DrawLine(pen, new Point(this.Size.Width / 2, 0), new Point(this.Size.Width / 2, this.Size.Height)); } catch (Exception ex) { Console.WriteLine("Catch Error CProgressBa::OnPaint " + ex.Message); } } // Resize 자동조절 protected override void OnSizeChanged(EventArgs e) { base.OnSizeChanged(e); try { label1.Location = new Point(this.Width / 4 - 21 / 2 - 4, this.Height / 2 - 15 / 2); label2.Location = new Point(this.Width - this.Width / 4 - 21 / 2 - 4, this.Height / 2 - 15 / 2); } catch (Exception ex) { Console.WriteLine("Catch Error CProgressBa::OnSigeChanged" + ex.Message); } } }// close CProgressBar

Socket(Tcp) 비동기 Client

public class AsyncClient { private Socket hSock; private Socket ConnSock; private byte[] m_ReceiveByte; private const int MAXSIZE = 1024; private string HOST = "127.0.0.1"; private int PORT = 9999; public AsyncClient() { hSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); m_ReceiveByte = new byte[MAXSIZE]; } //########################## // Connet public void BeginConnect() { Console.WriteLine("서버로 접속 대기중입니다......."); try { hSock.BeginConnect(HOST, PORT, new AsyncCallback(ConnectCallBack), hSock); } catch (SocketException se) { Console.WriteLine("서버에 접속 실패했습니다... {0} , {1}", se.Message, se.SocketErrorCode); } } // CallBack COnnect private void ConnectCallBack(IAsyncResult ar) { try { // 보류중인 연결을 완성 Socket s = (Socket)ar.AsyncState; IPEndPoint serEP = (IPEndPoint)s.RemoteEndPoint; Console.WriteLine("서버로 접속 성공..... serverIP: {0}, Port: {1}", serEP.Address, serEP.Port); s.EndConnect(ar); ConnSock = s; ConnSock.BeginReceive(this.m_ReceiveByte, 0, m_ReceiveByte.Length, SocketFlags.None, new AsyncCallback(OnReceiveCallBack), ConnSock); } catch (SocketException se) { if (se.SocketErrorCode == SocketError.NotConnected) { Console.WriteLine("서버에 접속 실패했습니다... {0} , {1}", se.Message, se.SocketErrorCode); // 접속 실패시 연결 재호출 this.BeginConnect(); } } } // SEND public void BeginSend(string message) { try { // 연결 시 if (hSock.Connected) { Console.WriteLine("서버로 데이터 전송 준비... {0}", message); byte[] t_sendByte = new UTF8Encoding().GetBytes(message); hSock.BeginSend(t_sendByte, 0, t_sendByte.Length, SocketFlags.None, new AsyncCallback(SendCallBack), message); } } catch (SocketException e) { Console.WriteLine("Send Errorr {0}, {1}", e.Message, e.SocketErrorCode); } } // Send CallBack private void SendCallBack(IAsyncResult ar) { string Message = (string)ar.AsyncState; Console.WriteLine("서버로 데이터를 전송했습니다... Text: {0}", Message); } // Receive public void Receive() { ConnSock.BeginReceive(this.m_ReceiveByte, 0, m_ReceiveByte.Length, SocketFlags.None, new AsyncCallback(OnReceiveCallBack), ConnSock); } // Receive CallBack private void OnReceiveCallBack(IAsyncResult ar) { try { Socket t_Sock = (Socket)ar.AsyncState; int num_read = t_Sock.EndReceive(ar); if (num_read != 0) { string message = new UTF8Encoding().GetString(m_ReceiveByte, 0, num_read); Console.WriteLine(message); } this.Receive(); } catch (SocketException se) { if (se.SocketErrorCode == SocketError.ConnectionReset) { this.BeginConnect(); } } } } // AsyncClient CLose

Socket(Tcp) 비동기 Server

c# Socket의 비동기 서버 입니다.
비동기 부분에서 눈여겨 봐야할부분은
BeginAccept <====> EndAccept
BeginSend <====> EndSend
BeginReceive <====> EndReceive
메소드들의 짝을 이뤄야한다는점입니다.
Socket.BeginSend()의 원형을 보면(MSDN Library 참고 및 검색) public IAsyncResult BeginSend( byte[] buffer, int offset, int size, SocketFlags socketFlags, AsyncCallback callback, Object state ) AsyncCallback 대리자
Object state 상태정보를 포함한 객체(사용자정의객체도 됨)를 눈여겨봐야할것같습니다.
예외처리시 SocketException이 발생하는데요
SocketException.SocektErrorCode의 맴버들을 적절히 사용해야됩니다.
NotConnected = Socket의 연결되지 않은 상태로 응용프로그램에서 데이터를 보내고 받으...
ConnectionRefused = 원격호스트가 연결을 거부했습니다.
ConnectionReset = 원격피어가 연결을 다시 설정했습니다. 등등등.
public class StateObject { public Socket workSocket = null; public const int BUFFER_SIZE = 1024; public byte[] buffer = new byte[BUFFER_SIZE]; public StringBuilder sb = new StringBuilder(); } public class AsyncServer { /// Begin Connect ==> EndConnet 메서드를 호출하여 완료 /// private Socket hsock; private byte[] buffer; private const int MAXSIZE = 1024; private StateObject so1; private StateObject so2; private UTF8Encoding utf8; // private BackgroundWorker bw_Receiver; public AsyncServer() { // 비동기라 쓰레드를 사용하지 않아도 되는것 같습니다. // this.bw_Receiver = new BackgroundWorker(); // this.bw_Receiver.WorkerSupportsCancellation = true; // this.bw_Receiver.DoWork +=new DoWorkEventHandler(bw_Receiver_DoWork); // this.bw_Receiver.RunWorkerCompleted +=new RunWorkerCompletedEventHandler(bw_Receiver_RunWorkerCompleted); this.hsock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); this.buffer = new byte[MAXSIZE]; utf8 = new UTF8Encoding(); this.so2 = new StateObject(); // hsock.Connect( } public void Listen() { this.hsock.Bind(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9999)); this.hsock.Listen(2); Array.Clear(buffer, 0, MAXSIZE); // c 에서 memset(&buff, 0, buff.length) 엯할 Console.WriteLine("클라이언트 접속 대기 중입니다....."); this.hsock.BeginAccept(new AsyncCallback(OnListenCallBack), hsock); } public void Send(string message) { byte[] sendByte = utf8.GetBytes(message); Socket t_Csock = this.so2.workSocket; t_Csock.BeginSend(sendByte, 0, sendByte.Length, SocketFlags.None, new AsyncCallback(OnSendCallBack), t_Csock); } // Send CallBack private void OnSendCallBack(IAsyncResult ar) { Socket t_CientSock = (Socket)ar.AsyncState; int size = t_CientSock.EndSend(ar); // 전송이 성공적으로 되었다면 결과값으로 보낸 크기가 리턴(size) // 그렇지 않다면 에러가 나올것이다. if (size < 0) { Console.WriteLine("Sending.... 실패"); } } // Receive CallBack private void OnReceiveCallBack(IAsyncResult ar) { StateObject so = (StateObject)ar.AsyncState; Socket t_sock = so.workSocket; try { int read = t_sock.EndReceive(ar); IPEndPoint ep = (IPEndPoint)t_sock.RemoteEndPoint; Console.WriteLine("클라이언트로부터 데이터를 받았습니다.ip: {0}, port: {1}", ep.Address, ep.Port); if (read > 0) { // so.sb.Append(utf8.GetString(so.buffer, 0, read)); Console.WriteLine("===> \t {0}", utf8.GetString(so.buffer, 0, read)); t_sock.BeginReceive(so.buffer, 0, StateObject.BUFFER_SIZE, SocketFlags.None, new AsyncCallback(OnReceiveCallBack), so); } else // 데이터가 없다. { if (so.sb.Length > 1) { string strContent; strContent = so.sb.ToString(); Console.WriteLine(String.Format("Read {0} byte from socket" + "data = {1} ", strContent.Length, strContent)); } t_sock.Close(); } } catch (SocketException se) // 클라이언트가 연결이 끊겼을경우 { Console.WriteLine("Receive Catch Error {0}, {1}", se.Message, se.SocketErrorCode); if (se.SocketErrorCode == SocketError.ConnectionReset) { this.hsock.Close(); Console.WriteLine("클라이언트 연결이 끊겼습니다. "); } } } // Accept CallBack private void OnListenCallBack(IAsyncResult ar) { // 클라이언트가 접속한후에 종료하게 된다면 서버쪽에서는 에러가 남 // 새로운 클라이언트가 올떄마나 새로운 클래스 객체를 생성하고 // 클래스 객체안에서는 메세지를 주고 받을 byte형 try { Socket t_sock = (Socket)ar.AsyncState; Socket s2 = t_sock.EndAccept(ar); IPEndPoint ep = (IPEndPoint)s2.RemoteEndPoint; Console.WriteLine("클라이언트가 접속 했습니다. ip: {0}, port: {1}", ep.Address, ep.Port); this.so2.workSocket = s2; // 클라이언트 정보 s2.BeginReceive(so2.buffer, 0, MAXSIZE, SocketFlags.None, new AsyncCallback(OnReceiveCallBack), so2); } catch (SocketException se) { Console.WriteLine(se.Message + " / " + se.SocketErrorCode); } } public class AsyncServerEventArg : EventArgs { public bool ClientIsConnected; public IPEndPoint ClientEP; public string Message; public AsyncServerEventArg(bool isConnected, IPEndPoint ep) { this.ClientIsConnected = isConnected; this.ClientEP = ep; } public AsyncServerEventArg(string message) { this.Message = message; } } public delegate void ClientConnectedHandler(object sender, AsyncServerEventArg e); public event ClientConnectedHandler ClientIsConnected; }// close AsycServer CLASS }// CLOSE NameSpace

Socket(Tcp) 동기 Client

c# Socket(Tcp) 클라이언트를 구현해봤습니다. private Socket sock; private IPAddress serverIp; private int serverPort = 9999; private IPEndPoint ipep; private BackgroundWorker bwReceiver; private byte[] receivebyte; private int idx = 0; //constructor public LocalSocketClient() { receivebyte = new byte[1024]; serverIp = IPAddress.Parse("127.0.0.1"); serverPort = 9999; ipep = new IPEndPoint(serverIp, serverPort);// 서버 끝점 bwReceiver = new BackgroundWorker(); bwReceiver.WorkerSupportsCancellation = true; bwReceiver.DoWork += new DoWorkEventHandler(bw_Receiver); bwReceiver.RunWorkerCompleted += new RunWorkerCompletedEventHandler(DisconnectFromReciver); } private void DisconnectFromReciver(object sender, RunWorkerCompletedEventArgs e) { if (e.Cancelled) { this.Connect(); } } public void Send(string str) { if (sock.Connected) { byte[] sendByte = new UTF8Encoding().GetBytes(str); //ASCIIEncoding.UTF8.GetBytes(buff) sock.Send(sendByte, sendByte.Length, SocketFlags.None); } } private void bw_Receiver(object sender, DoWorkEventArgs e) { string s_Receive = string.Empty; while (true) { Array.Clear(receivebyte, 0, receivebyte.Length); s_Receive = ""; try { if (sock.Connected) { int size = sock.Receive(receivebyte); Console.WriteLine("받은 데이터 글자수 : {0}", size); s_Receive = ASCIIEncoding.UTF8.GetString(receivebyte); this.Received(this, new ClientEventArgs(s_Receive.Trim('\0'))); } else { Console.WriteLine("서버가 닫혔습니다"); break; } } catch (SocketException se) { if (se.SocketErrorCode == SocketError.ConnectionReset) // 클라이언트로부터 접속이 끊긴다면 { Console.WriteLine("{0} Error code: {1}. Receiver BackgroundWork() ", se.Message, se.ErrorCode); e.Cancel = true; this.bwReceiver.CancelAsync(); break; } } } } public void Connect() { Console.WriteLine("서버 접속 중입니다..."); sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); while (true) { try { sock.Connect(ipep); // 접속 에러 발생시 catch문 이동 if (sock.Connected) // 접속 완료시 receive 백그라운드 작동 { this.IsConnected(this, new ClientEventArgs(true)); bwReceiver.RunWorkerAsync(); Console.WriteLine("서버 접속 완료 ===> \t Receive Background 작동"); break; } } catch (SocketException e) // 서버 접속 에러 발생시 { if (e.SocketErrorCode == SocketError.ConnectionRefused) { Console.WriteLine("서버 접속 실패 ===> \t 접속 대기중입니다."); } } } }// close ServerConnect // Evevent Fire Class public class ClientEventArgs : EventArgs { public bool IsConnected; public string Message; public ClientEventArgs(string str) { this.Message = str; } public ClientEventArgs(bool isconnect) { this.IsConnected = isconnect; } } public delegate void SendEventHandler(object sender, ClientEventArgs e); public event SendEventHandler SendDest; public delegate void ReceiveHandler(object sender, ClientEventArgs e); public event ReceiveHandler Received; public delegate void ConnectedEvnetHandler(object sender, ClientEventArgs e); public event ConnectedEvnetHandler IsConnected; }// close TCLIENT

Socket(Tcp) 동기 Server

c# Socket(Tcp)를 이용한 싱글 서버를 구현해봤습니다. 수정할 부분이 많습니다.-_- public class LocalSocket { private Socket m_hSock; // host private Socket m_cSock; // client private IPEndPoint m_hEp; private byte[] m_receiveByte; private BackgroundWorker m_bwReceiver; public static LocalSocket sockTrade; private readonly int MAXSIZE = 1024; private bool m_CLOSE = false; public static LocalSocket Instance() { if (sockTrade == null) { sockTrade = new LocalSocket(); } return sockTrade; } private LocalSocket() { this.m_bwReceiver = new BackgroundWorker(); this.m_bwReceiver.WorkerSupportsCancellation = true; this.m_bwReceiver.DoWork += new DoWorkEventHandler(bw_Receiver); this.m_bwReceiver.RunWorkerCompleted += new RunWorkerCompletedEventHandler(DisconnectFormClient); try { this.m_hSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); this.m_hEp = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9999); this.m_cSock = null; this.m_receiveByte = new byte[MAXSIZE]; this.m_hSock.Bind(m_hEp); // bind } catch (SocketException se) { // } } /// <summary> /// 1. 서버(자신)의 포트를 열고 /// 2. 클라이언트의 연결시도 대기 -> 연결완료 /// 3. BackgroundWorker로 Receive(메소드 호출 ) /// </summary> public void Open() { this.m_hSock.Listen(1); // Console.WriteLine("클라이언트 연결을 대기중입니다....."); m_cSock = m_hSock.Accept(); // client instance 생성 if (m_cSock.IsBound) // 재차 확인 { // Console.WriteLine("클라이언트 연결 완료....."); IPEndPoint ep = (IPEndPoint)m_cSock.RemoteEndPoint; if (this.ClientIsConnected != null) this.ClientIsConnected(this, new LocalSocketEvent(true, ep)); // Background 실행여부 if (!m_bwReceiver.IsBusy) this.m_bwReceiver.RunWorkerAsync(); // Receive Backgorund 호출 } else { // Disconnect Event Fire if (this.ClientFireDisConnected != null) this.ClientFireDisConnected(this, new LocalSocketEvent(true)); } } // close Open public void Send(string str) { try { if (m_cSock.Connected) { byte[] sendByte = new UTF8Encoding().GetBytes(str); m_cSock.Send(sendByte, sendByte.Length, SocketFlags.None); } } catch (SocketException se) { // Sending Event Fire if (this.SendingFireError != null) this.SendingFireError(this, new LocalSocketEvent(true)); return; } } public void Dispose() { try { if (this.m_hSock != null) { this.m_CLOSE = true; this.m_bwReceiver.CancelAsync(); if (this.m_cSock != null && this.m_cSock.Connected) { this.m_cSock.Close(); } // this.m_hSock.Shutdown(SocketShutdown.Both); this.m_hSock.Close(); } } catch (SocketException e) { Console.WriteLine("LocalSocket Exception {0}, {1}", e.Message, e.SocketErrorCode); } Console.WriteLine(" localSocket CLOSE"); } /// <summary> /// 백그라운드로 데이터 계속 받음 /// 중간에 연결 끊김시 재시작 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void bw_Receiver(object sender, DoWorkEventArgs e) { string t_Receive = string.Empty; while (this.m_cSock.Connected) { try { // Console.WriteLine("클라이언트로부터 응답을 받을때까지 대기합니다..."); Array.Clear(this.m_receiveByte, 0, MAXSIZE); int size = 0; if ((size = m_cSock.Receive(this.m_receiveByte)) > 0) // { // Console.WriteLine("받은 데이터 charact 수: {0}", size); t_Receive = new UTF8Encoding().GetString(m_receiveByte); // Receive Event Fire if (this.Received != null) this.Received(this, new LocalSocketEvent(t_Receive.Trim('\0'))); } } catch (SocketException se) { if (se.SocketErrorCode == SocketError.ConnectionReset) // Client 접속이 끊김 { // Console.WriteLine("{0} Error Code: {1}, Receiver BW()", se.Message, se.ErrorCode); e.Cancel = true; // Disconnecte Event Fire if (this.ClientFireDisConnected != null) this.ClientFireDisConnected(this, new LocalSocketEvent(true)); this.m_bwReceiver.CancelAsync(); break; } } } // close while } // close bw_Receiver(objet sender, DoWorkEventArgs e); private void DisconnectFormClient(object sender, RunWorkerCompletedEventArgs e) { if (e.Cancelled) { if(!this.m_CLOSE) this.Open(); // 서버(본인) 다시 개방하고 클라이언트로 부터접속대기 } } public class LocalSocketEvent : EventArgs { public string Message; public bool ClientIsConnected; // 연결 public bool ClientIsDisConnected; // 끊김 public IPEndPoint ClientEP; public LocalSocketEvent(string str) { this.Message = str; } public LocalSocketEvent(bool isConnected, IPEndPoint ep) { this.ClientIsConnected = isConnected; this.ClientEP = ep; } public LocalSocketEvent(bool isDisconnect) { this.ClientIsDisConnected = isDisconnect; } } // close SockTrade // 받았을때 BW_RECEIVER 발생 public delegate void ReceiverHandler(object sender, LocalSocketEvent e); public event ReceiverHandler Received; // 클라이언트 접속시발생 public delegate void ClientIsConnectHandler(object sender, LocalSocketEvent e); public event ClientIsConnectHandler ClientIsConnected; // 클라이언트로 데이터 전송시 발생 public delegate void SendErrorHandler(object sender, LocalSocketEvent e); public event SendErrorHandler SendingFireError; public delegate void ClientFireDisConnect(object sender, LocalSocketEvent e); public event ClientFireDisConnect ClientFireDisConnected; } }