subject는 옵저버나 observable처러 행동하는 일부 ReactiveX구현체에서만 사용가능한 일종의 프록시다. subject는 옵저버이기 때문에 하나이상의 observable을 구독할 수 있으며, 동시에 observable 이기도 하기 때문에 항목을 하나하나 거치면서 다시 push하고 새로운 항목을 push할 수 있다.

총 4종류의 subject가 있다.

### AsyncSubject
![](http://reactivex.io/documentation/operators../../../images/S.AsyncSubject.png)

Observable이 마지막으로 push한 값만 push 하고, 원 Observable의 동작이 다 끝나면 동작한다. 아무값도 push되지 않으면, 이 subject 역시 배출하지 않는다. 또한 맨 마지막 값 바로 뒤에 오는 옵저버에도 값을 전달하는데, 만약 오류에 의해 종류될 경우 이 오류를 그냥 전달한다.

### BehaviorSubject
![](http://reactivex.io/documentation/operators../../../images/S.BehaviorSubject.png)
옵저버가 BehaviorSubject를 구독하면, 옵저버는 Observable 이 가장 최근에 발행한 항목 (또는 값이 없을 경우 맨처음 값이나 기본값) 을 push하며, 이후 Observable 이 push한 값을 push한다.

### PublishSubject
![](http://reactivex.io/documentation/operators../../../images/S.PublishSubject.png)
Subscribe 이후에 push한 항목에 대해서 모두 Observable에게 배출한다. 하지만 이 때문에 subject가 생성되는 시점과 구독하는 시점사이에 빈 공간이 생긴다는 단점이 있다. 따라서 모든 push하는 모든 항목을 받기 위해서는 cold observable을 생성하거나, 아래의 subject를 사용해야 한다.

### RelaySubject
![](http://reactivex.io/documentation/operators../../../images/S.ReplaySubject.png)
PublishSubject 와 다르게, 구독한 시점에 상관없이 Observable이 push한 모든 항목을 받는다. 다만 재생버퍼의 크기가 특정이상으로 증가할 경우에는, 처음 배출후 지정한 시간이 경과하면 오래된 항목을 제거한다. 또한 onNext사용을 주의해야한다. (순서의 모호함이 있기 때문)


subject는 옵저버나 observable처러 행동하는 일부 ReactiveX구현체에서만 사용가능한 일종의 프록시다. subject는 옵저버이기 때문에 하나이상의 observable을 구독할 수 있으며, 동시에 observable 이기도 하기 때문에 항목을 하나하나 거치면서 다시 push하고 새로운 항목을 push할 수 있다. 총 4종류의 subject...

ReactiveX) Subject

bitcoin-core를 설치했다면 bitcoind daemon 에서는 모든  block 정보를 동기화 하게 된다.

이는 꽤나 많은 양이기 때문에, 동기화에 하루이틀 이상의 오랜 시간이 소요된다.

![스크린샷 2016-04-20 08.53.33](../images/bitcoin-sync-1.png)

지갑주소 공개합니다. 0.00001 BTC있는데 가져가쉴??

현재 Sync상황을 알기 위해선, 일단 내 bitcoin-core가 얼마나 동기화 는지 확인 해야 한다.

```
bitcoind getinfo bitcoind getblockcount
```

getinfo 명령어는 bitcoin daemon 의 전반적인 상황을 볼 수 있고, bitcoind getblockcount는 현재 동기화된 block의 count를 볼 수 가 있다.

281205개가 동기화가 되어 있다.  전체 block의 height는 [blockchain.info/ko/](https://blockchain.info/ko/) 여기에서 확인할 수 있다.

현재 약 408506개가 있는데, 절반정도 동기화되어 있는 걸 볼 수 있다.


이는 약 11시간에 걸쳐서 동기화한 결과다.

스펙은 아래와 같다.

Google Cloud Compute

n1-standard-2(vCPU 2개, 7.5GB 메모리)  
 Intel Haswell  
 SSD 75 GB

CPU 사용량 ( 사용량이 많이 튀는 시간 대는 내가 환경설정을 세팅할 때다.)

![스크린샷 2016-04-20 09.05.00](../images/bitcoin-sync-2.png)

 
용량

30여만개의 정보들은 약 20기가를 차지한다. (core 포함)

```
 savurself11@bitcoin:~/bitcoin$ df -h
 Filesystem Size Used Avail Use% Mounted on udev 3.7G 8.0K 3.7G 1%
 /dev tmpfs 749M 340K 748M 1%
 /run /dev/sda1 74G 20G 52G 28%
 / none 4.0K 0 4.0K 0%
 /sys/fs/cgroup none 5.0M 0 5.0M 0%
 /run/lock none 3.7G 0 3.7G 0%
 /run/shm none 100M 0 100M 0% /run/user
 ```

음.. 아마 8시간이 더 있으면 동기화가 완료 될 것 같다.

동기화가 완료되는 대로 다시 포스팅 해야지.

----


8시간후

서버를 켜 놓은지 약 20여 시간이 지났다.

그 사이에 컴퓨터 스펙을 업그레이드 했다. (CPU 4개, Ram 16gb)

실시간으로 프로세서의 상황을 모니터링하고 있었는데, 너무나 과부하가 걸리고 있어서 어쩔 수 없었다. (내돈 ㅠㅠ)

난 그저 내가 보낸 transaction 을 보고 싶었을  뿐인데, 이를 bitcoin-core로 보기위해서는 어마무시한 노력이 필요하다는 것을 알게 됐다.

```
 savurself11@bitcoin:~$ bitcoin-cli getinfo
 ```

 ```json
 {
   "version" : 90500,
   "protocolversion" : 70002,
   "walletversion" : 60000,
   "balance" : 0.00000000,
   "blocks" : 324389,
   "timeoffset" : -1,
   "connections" : 8,
   "proxy" : "",
   "difficulty" : 34661425923.97693634,
   "testnet" : false,
   "keypoololdest" : 1461075368,
   "keypoolsize" : 101,
   "paytxfee" : 0.00000000,
   "relayfee" : 0.00001000,
   "errors" : ""
 }
```

```
savurself11@bitcoin:~$ bitcoin-cli getblockcount 324398 savurself11@bitcoin:~$
```

전체 블록인 40만 8천여개 중에 이제 32만개를 돌파하고 있다. 이정도 추세라면 내일이 되어서야 완료될 성 싶다.

![스크린샷 2016-04-20 20.00.01](../images/bitcoin-sync-1.png)

--

정확히 이틀이 지났다.

어제 32만개라고 포스팅했는데, 간밤에 4만개 밖에 동기화 하지 못했다. ㅠㅠ


bitcoin-cli 의 현재 sync 상황을 확인해보자.
```
savurself11@bitcoin:~$ bitcoin-cli getblockcount
364511
```

364511 번 까지 왔다. 이 블록은 언제적 블록인지 알아보자.

```
savurself11@bitcoin:~$ bitcoin-cli getblockhash 364511 000000000000000014136f884dbf60e529a1cd296d3b321bcac22420c97be03d
```

블록 해쉬 정보만 있으면, 이 블록에 대한 정보를 가져올 수 있다.

```
bitcoin-cli getblock "000000000000000014136f884dbf60e529a1cd296d3b321bcac22420c97be03d"
```
transaction정보는 너무 많아서 생략한다.

```json
{
  "time" : 1436418994,
  "nonce" : 2453655801,
  "bits" : "1816418e",
  "difficulty" : 49402014931.22746277,
  "chainwork" : "0000000000000000000000000000000000000000000847c569a240f670fc6820", "previousblockhash" : "000000000000000006588b7d0aefa8045d5c6822e975b5d37558610f406880ac", "nextblockhash" : "0000000000000000015b001aca1ba32cfedc54fe3deae0f4b724b321e3b7b425"
}
```
 
```
savurself11@bitcoin:~$ date -d @1436418994
Thu Jul 9 05:16:34 UTC 2015
```
 
2015년 7월 정보까지 따라왔다. 이 정도 추세면 내일 모레쯤이면 따라 잡을 수 있을 것 같기도하다.

---

동기화가 완료되었다 으헝헣ㅎ
그 사이에 google cloud compute engine(이하 gce) 의 쿠폰 유효기간이 다해 (내 300달러 ㅠㅠ) 과금이 되고 있었다.

4월 21 경에 서버를 돌리다가 과부하 되는 cpu 가 안쓰러워 업그레이드를 했고

![Compute Engine study workspace](../images/bitcoin-sync-4.png)

5시간 전에는 70기가에서 100기가로 업그레이드를 했다.

**참고로 디스크 점유율이 90%를 넘어가면 동기화를 정지한다.**

이제 내가 보낸 비트코인정보를 내 서버에서 볼 수 있게 되었다.

내 30만원 ^^


2018년 현재: 거래량이 많아진 지금은 더 오랜 시간이 소요될 것.


bitcoin-core를 설치했다면 bitcoind daemon 에서는 모든  block 정보를 동기화 하게 된다. 이는 꽤나 많은 양이기 때문에, 동기화에 하루이틀 이상의 오랜 시간이 소요된다.  ![스크린샷 2016-04-20 08.53.33](../images/bitcoin-sync-1.png)  지갑주소 공개합니다. 0...

Bitcoin) Bitcoin-core의 Sync를 동기화 해보자.

앞선 [포스팅](https://yceffort.github.io/notes/Levenshtein-distance) 을 통해서 두 String을 문자열 기반으로 분석하였을때. 유사도를 어떻게 측정하는지 알아보았다.

그러나 음성인식으로 String을 비교 했을 때,  다음과 같은 문제에 직면하였다.

“Eggs”를 말했을때, Android Voice API는 “X” 를 반환하는 것이 아닌가?

String의 물리적인 비교를 해보았을때, 두 비교값은 앞선 나의 방식으로 한다면 당연히 0 일 것이다.

그렇다면, 발음 기반으로 비교를 하고 싶으면 어떻게 할 수 있을까?

[아파치 코덱 라이브러리](http://commons.apache.org/proper/commons-codec/download_codec.cgi) 가 그 문제의 해결책을 줄 수 있다.

그 중에서도 사용할 것은 [SoundEx](http://commons.apache.org/proper/commons-codec/apidocs/org/apache/commons/codec/language/Soundex.html) 다.

사용법은 다음과 같다.

일단 위의 링크에서 관련 라이브러리를 받아서 Import를 한다.

```java
 public static double getVoiceSimilarity(String s1, String s2)
{
  Soundex soundex = new Soundex();
  double sim = 0;
    try {
      sim = soundex.difference(s1, s2);
    } catch (Exception e) {
      sim = 0;
    }
  return sim;
}
```

대략 원리는 이렇다.

The correct value can be found as follows:

1. Retain the first letter of the name and drop all other occurrences of a, e, i, o, u, y, h, w.
2. Replace consonants with digits as follows (after the first letter): - b, f, p, v → 1

- c, g, j, k, q, s, x, z → 2
- d, t → 3
- l → 4
- m, n → 5
- r → 6

3. If two or more letters with the same number are adjacent in the original name (before step 1), only retain the first letter; also two letters with the same number separated by ‘h’ or ‘w’ are coded as a single number, whereas such letters separated by a vowel are coded twice. This rule also applies to the first letter.
4. If you have too few letters in your word that you can’t assign three numbers, append with zeros until there are three numbers. If you have more than 3 letters, just retain the first 3 numbers.

영어는 귀찮으니까 delphi라는 단어로 예를 들어보자.

1.  맨 앞글자를 제외하고 나머지 단어는 냄겨둔다.  
    결과: d?????
2.  ‘A’, E’, ‘I’, ‘O’, ‘U’, ‘H’, ‘W’, ‘Y’는 숫자 0으로 바꾼다.  
    결과: d0??00
3.  나머지단어는 아래처럼 바꾼다.  
    b, f, p, v → 1  
    c, g, j, k, q, s, x, z → 2  
    d, t → 3  
    l → 4  
    m, n → 5  
    r → 6  
    결과: d04100
4.  연속해서 붙어있는 글자들은 하나를 남기고 지운다.  
    결과: d0410
5.  0을 다 지운다.  
    결과: d41
6.  4자리를 만드는 대신, 오른쪽 빈 공간을 0으로 채운다.  
    최종결과: d410

```java
System.out.println(soundex(“dellfhai”));
System.out.println(soundex(“delphi”));
```

를 하게 되면, 동일하게 d410이 나온다. 싱기방기.

영어의 알파벳별 단어발음을 적극적으로 활용 한 것이다.

보면 알겠지만,  하나의 단어에 대해서 무조건 4글자의 규칙적인 발음표(?) 를 만들어서 리턴한다.

어떤 단어든 최초 앞글자 + lenght 3의 String을 리턴하며, 이런 변환 과정에 있어서 비슷한 자음 (b, p 를 같은 것으로 본다던지) 을 같은것으로 가정하여 판단하는 것이다.

```java
public static void main(String[] args) {
  System.out.println(soundex("eggs"));
  System.out.println(soundex("X"));
  System.out.println(soundex("Soundex"));
  System.out.println(soundex("Saundthax"));
}
```

결과

```
E200
X000
S532
S532
```

꽤비슷한 단어로 추정하는 것을 볼수 있다.  
eggs, x 는 스펠링 비교를 했을 때 절대로 같거나 비슷한 단어로 볼수 없지만,

이알고리즘을 사용할 경우 비슷한단어라고 추정이 가능하다.


앞선 [포스팅](https://yceffort.github.io/notes/Levenshtein-distance) 을 통해서 두 String을 문자열 기반으로 분석하였을때. 유사도를 어떻게 측정하는지 알아보았다. 그러나 음성인식으로 String을 비교 했을 때,  다음과 같은 문제에 직면하였다.  “Eggs”를 말했을때, Android Voice API는...

발음 기반으로 String의 유사도를 비교해 보자.

보통 일반적인 프로그램의 경우에는, 하나씩 작성된 순서에 따라 로직이 실행되고, 완료되면 또다른 로직이 실행되는 등의 순서가 있음을 알수 있다.

그러나 이와 달리 ReactiveX는 "Observer"에 의해 임의의 순서에 따라 병렬적으로 실행되고 나중에 결과나 나온다.

즉 메서드를 호출하는 것이 아니라, Observable안의 데이터를 조회하고, 변환 하는 등의 프로세스를 정의한 후, Observable이 이벤트를 발생시키면 옵저버의 관찰자가 그 순간을 감지하고 준비된 연산을 실행하고 결과를 리턴한다. 그래서 Observable을 Subscribe한다는 표현을 쓴다.

일반적으로 Observable을 구현하기 위해서 다음과 같은 절차를 거친다.

1. 비동기 호출로 결과를 리턴받고, 필요한 동작을 처리하는 메서드를 정의한다.
2. Observable로 비동기 호출을 정의한다.
3. Subscribe를 통해 옵저버를 Observable에 연결 시킨다.
4. 메서드 호출로 결과가 리턴 될 때마다, 옵저버의 메서더는 리턴 값 또는 항목을 사용해서 연산을 한다.


`onNext` Observable은 새로운 항목을 push 할 때 마다 이 메서드를 호출한다. 이 메서드는 Observable 이 배출하는 항목을 parameter 로 전달 받는다.

`oNError` 기대하는 데이터가 생성되지 않았거나, 오류가 발생할 경우 호출된다. 이 경우 `onNext`, `onCompleted`는 호출되지 않는다.

`onCompleted` 마지막 `onNext`가 호출된 뒤에 호출된다.

더이상 구독을 하지 않으려면 `unSubscirbe`를 호출한다.

Observable이 연속된 항목을 push하는 방법에는 두가지가 있는데 바로 hot과 cold다. hot은 생성되자마자 push하고, cold는 옵저버가 구독할때까지 배출하지 않는다.

이러한 Observable은 연산자와 연결하여 사용할 수 있는데, 이런 연산자들은 리턴된 observable을 변경하여 제공할 수 있다.


보통 일반적인 프로그램의 경우에는, 하나씩 작성된 순서에 따라 로직이 실행되고, 완료되면 또다른 로직이 실행되는 등의 순서가 있음을 알수 있다. 그러나 이와 달리 ReactiveX는 "Observer"에 의해 임의의 순서에 따라 병렬적으로 실행되고 나중에 결과나 나온다.  즉 메서드를 호출하는 것이 아니라, Observable안의 데이터를 조회하고, 변환...

ReactiveX) Observable

보통 일반적인 프로그램의 경우에는, 하나씩 작성된 순서에 따라 로직이 실행되고, 완료되면 또다른 로직이 실행되는 등의 순서가 있음을 알수 있다.
그러나 이와 달리 ReactiveX는 "Observer"에 의해 임의의 순서에 따라 병렬적으로 실행되고 나중에 결과나 나온다.
즉 메서드를 호출하는 것이 아니라, Observable안의 데이터를 조회하고, 변환 하는 등의 프로세스를 정의한 후, Observable이 이벤트를 발생시키면 옵저버의 관찰자가 그 순간을 감지하고 준비된 연산을 실행하고 결과를 리턴한다. 그래서 Observable을 Subscribe한다는 표현을 쓴다.
일반적으로 Observable을 구현하기 위해서 다음과 같은 절차를 거친다.
<ol>
<li>비동기 호출로 결과를 리턴받고, 필요한 동작을 처리하는 메서드를 정의한다.</li>
<li>Observable로 비동기 호출을 정의한다.</li>
<li>Subscribe를 통해 옵저버를 Observable에 연결 시킨다.</li>
<li>메서드 호출로 결과가 리턴 될 때마다, 옵저버의 메서더는 리턴 값 또는 항목을 사용해서 연산을 한다.</li>
</ol>
<code>onNext</code> Observable은 새로운 항목을 push 할 때 마다 이 메서드를 호출한다. 이 메서드는 Observable 이 배출하는 항목을 parameter 로 전달 받는다.
<code>oNError</code> 기대하는 데이터가 생성되지 않았거나, 오류가 발생할 경우 호출된다. 이 경우 <code>onNext</code>, <code>onCompleted</code>는 호출되지 않는다.
<code>onCompleted</code> 마지막 <code>onNext</code>가 호출된 뒤에 호출된다.
더이상 구독을 하지 않으려면 <code>unSubscirbe</code>를 호출한다.
Observable이 연속된 항목을 push하는 방법에는 두가지가 있는데 바로 hot과 cold다. hot은 생성되자마자 push하고, cold는 옵저버가 구독할때까지 배출하지 않는다.
이러한 Observable은 연산자와 연결하여 사용할 수 있는데, 이런 연산자들은 리턴된 observable을 변경하여 제공할 수 있다.

정보: github page code highlight는 델파이를 지원하지 않는다.

## checksum

```pascal
function GetCheckSum(FileName: string): DWORD;
var
 F: file of DWORD;
 P: Pointer;
 Fsize: DWORD;
 Buffer: array [0..500] of DWORD;
begin
 FileMode := 0;
 AssignFile(F, FileName);
 Reset(F);
 Seek(F, FileSize(F) div 2);
 Fsize := FileSize(F) - 1 - FilePos(F);
 if Fsize > 500 then Fsize := 500;
 BlockRead(F, Buffer, Fsize);
 Close(F);
 P := @Buffer;
 asm
 xor eax, eax
 xor ecx, ecx
 mov edi , p
 @again:
 add eax, [edi + 4*ecx]
 inc ecx
 cmp ecx, fsize
 jl @again
 mov @result, eax
 end;
end;
```

## 프로세스 실행 중인지 확인

```pascal
function CheckProcessRunning(exeFileName: string): Boolean;
var
 ContinueLoop: BOOL;
 FSnapshotHandle: THandle;
 FProcessEntry32: TProcessEntry32;
begin
 FSnapshotHandle := CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0);
 FProcessEntry32.dwSize := SizeOf(FProcessEntry32);
 ContinueLoop := Process32First(FSnapshotHandle, FProcessEntry32);
 Result := False;
 while Integer(ContinueLoop) <> 0 do
 begin
 if ((UpperCase(ExtractFileName(FProcessEntry32.szExeFile)) =
 UpperCase(ExeFileName)) or (UpperCase(FProcessEntry32.szExeFile) =
 UpperCase(ExeFileName))) then
 begin
 Result := True;
 end;
 ContinueLoop := Process32Next(FSnapshotHandle, FProcessEntry32);
 end;
 CloseHandle(FSnapshotHandle);
end;
```


## 프로세스 죽이기

```pascal
function StopProcess(ExeFileName: string) : Integer;
const
 PROCESS_TERMINATE = $0001;
var
 ContinueLoop: BOOL;
 FSnapshotHandle: THandle;
 FProcessEntry32: TProcessEntry32;
begin
 Result := 0;
 FSnapshotHandle := CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0);
 FProcessEntry32.dwSize := SizeOf(FProcessEntry32);
 ContinueLoop := Process32First(FSnapshotHandle, FProcessEntry32);
 while Integer(ContinueLoop) <> 0 do
 begin
 if ((UpperCase(ExtractFileName(FProcessEntry32.szExeFile)) =
 UpperCase(ExeFileName)) or (UpperCase(FProcessEntry32.szExeFile) =
 UpperCase(ExeFileName)))
 then
 Result := Integer(TerminateProcess(
 OpenProcess(PROCESS_TERMINATE,
 BOOL(0),
 FProcessEntry32.th32ProcessID),
 0));
 ContinueLoop := Process32Next(FSnapshotHandle, FProcessEntry32);
 end;
 CloseHandle(FSnapshotHandle);
end;
```

## string to html (html parsing)

```pascal
procedure TForm2.ParsingHTML;
var
 IdHTTP: TIdHTTP;
 Stream: TStringStream;
begin
 IdHTTP := TIdHTTP.Create(nil);
 Stream := TStringStream.Create;
 try
 try
 IdHTTP.Get(edt1.Text, Stream);
 JenkinsParsingResult := Stream.DataString;
 except
 //exception Raise... (올바르지 않은 주소일때)
 end;
 finally
 tmr1.Enabled := True;
 Stream.Free;
 IdHTTP.Free;
 end;
end;
```

## File Drag & drop (파일 드래그 앤 드랍)

in formcreate

```pascal
DragAcceptFiles(Handle, True);
```

```pascal
procedure TForm2.WMDROPFILES(var Msg: TWMDropFiles);
var
 i, amount: Integer;
 FileName: array[0..MAX_PATH] of Char;
begin
 inherited;
 try
 Amount := DragQueryFile(Msg.Drop, $FFFFFFFF, FileName, MAX_PATH);
 for i := 0 to (Amount - 1) do
 begin
 DragQueryFile(Msg.Drop, i, FileName, MAX_PATH);
 //FileName에 파일/폴더 path가 들어옵니다.
 finally
 DragFinish(Msg.Drop);
 end;
end;
```

## get md5
```pascal
function GetCheckSum(FileName: string): string;
var
 IdMD5: TIdHashMessageDigest5;
 FS: TFileStream;
begin
 IdMD5 := TIdHashMessageDigest5.Create;
 FS := TFileStream.Create(FileName, fmOpenRead or fmShareDenyWrite);
 try
 Result := IdMD5.HashStreamAsHex(FS);
 finally
 FS.Free;
 IdMD5.Free;
 end;
end;
```

## 작업표시줄 제어

### auto hide를 always show로 변경

```pascal
var
 ABData: TAppBarData;
begin
 ABData.cbSize := SizeOf(TAppBarData);
 ABData.hWnd := FindWindow('SHELL_TRAYWND', nil);
 ABData.lParam := LParam(0);
 SHAppBarMessage($0000000a, ABData);
```

### 작업표시줄 숨기기. 숨기는게 아니고 레알루다가 없앰

```pascal
var
 hTaskbar: THandle;
begin
 hTaskbar := FindWindow('Shell_TrayWnd', Nil);
 ShowWindow(hTaskbar, SW_HIDE);
```

### 작업표시줄 보이기

```pascal
var
 hTaskbar: THandle;
begin
 hTaskbar := FindWindow('Shell_TrayWnd', Nil);
 ShowWindow(hTaskbar, SW_SHOWNORMAL);
```

## 인터넷 연결상태 확인
```pascal
function CheckInternetConnection(): Boolean;
const
 // Local system has a valid connection to the Internet, but it might or might
 // not be currently connected.
 INTERNET_CONNECTION_CONFIGURED = $40;

 // Local system uses a local area network to connect to the Internet.
 INTERNET_CONNECTION_LAN = $02;

 // Local system uses a modem to connect to the Internet
 INTERNET_CONNECTION_MODEM = $01;

 // Local system is in offline mode.
 INTERNET_CONNECTION_OFFLINE = $20;

 // Local system uses a proxy server to connect to the Internet
 INTERNET_CONNECTION_PROXY = $04;

 // Local system has RAS installed.
 INTERNET_RAS_INSTALLED = $10;

var
 InetState: DWORD;
 hHttpSession, hReqUrl: HInternet;
begin
 Result:= InternetGetConnectedState(@InetState, 0);
 if (
 Result
 and
 (
 InetState and INTERNET_CONNECTION_CONFIGURED
 = INTERNET_CONNECTION_CONFIGURED)
 ) then
 begin
 // so far we ONLY know there's a valid connection. See if we can grab some
 // known URL ...
 hHttpSession:= InternetOpen(
 PChar(Application.Title), // this line is the agent string
 INTERNET_OPEN_TYPE_PRECONFIG, nil, nil, 0
 );
 try
 hReqUrl:= InternetOpenURL(
 hHttpSession,
 PChar('http://wwww.example.com'{ the URL to check }),
 nil,
 0,
 0,
 0
 );
 Result := hReqUrl <> nil;
 InternetCloseHandle(hReqUrl);
 finally
 InternetCloseHandle(hHttpSession);
 end;
 end
 else
 if (
 InetState and INTERNET_CONNECTION_OFFLINE = INTERNET_CONNECTION_OFFLINE
 ) then
 Result := False; // we know for sure we are offline.
end;
```

첫 직장에서 델파이로 개발했을 때 유용하게 사용하던 코드 모음.

yceffort

programming

ReactiveX) Subject

Bitcoin) Bitcoin-core의 Sync를 동기화 해보자.

발음 기반으로 String의 유사도를 비교해 보자.

ReactiveX) Observable

Delphi) Some tricks