Microsoft MVP성태의 닷넷 이야기
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

C# - PeerFinder를 이용한 Wi-Fi Direct 데이터 통신 예제

다음과 같은 멋진 글이 있군요. ^^

Using PeerFinder from Console: Wi-Fi Direct data transfer in C# 
; http://blog.plasticscm.com/2016/09/using-peerfinder-from-console-wi-fi.html

사실 아래의 글도 저 블로그를 통해 쓰인 것이었습니다.

윈도우 데스크톱 응용 프로그램(예: Console)에서 알림 메시지(Toast notifications) 띄우기
; https://www.sysnet.pe.kr/2/0/11073

그나저나, 윈도우의 UWP 기능으로 인해 기존 (classic) 데스크톱 유형의 응용 프로그램도 이런 식으로 혜택을 받게 되니 그저 좋을 따름입니다. ^^

자, 그럼 이 글에서는 "Using PeerFinder from Console: Wi-Fi Direct data transfer in C#"에서 설명한 대로 윈도우 콘솔 응용 프로그램에서 Wi-Fi Direct 통신을 하는 프로그램을 만들어 보겠습니다.

전에도 말했지만, UWP 기능을 일반 데스크톱 응용 프로그램에서 이용하기 위해선 약간의 사전 작업이 필요한데요. 우선 다음과 같이 .csproj에 TargetPlatformVersion 최소 요구 사항을 8.1로 명시해 줍니다.

<TargetPlatformVersion>8.1</TargetPlatformVersion>

그리고, 다음의 DLL들을 참조 추가해줍니다.

C:\Program Files (x86)\Windows Kits\8.1\References\CommonConfiguration\Neutral\Windows.winmd
C:\Program Files (x86)\Reference Assemblies\Microsoft\Framework\.NETFramework\v4.5\WindowsBase.dll
C:\Program Files (x86)\Reference Assemblies\Microsoft\Framework\.NETFramework\v4.5\Facades\System.Runtime.dll
C:\Program Files (x86)\Reference Assemblies\Microsoft\Framework\.NETCore\v4.5\System.Runtime.WindowsRuntime.dll

그다음 클라이언트는 다음과 같이 코드를 추가해 주고,

using System;
using System.IO;
using System.Runtime.InteropServices;
using System.Threading.Tasks;
using Windows.Networking.Proximity;

namespace PeerClient
{
    class Program
    {
        static void Main(string[] args)
        {
            PeerClient client = new PeerClient();
            client.Start();

            Console.WriteLine("Press any key to exit...");
            Console.ReadLine();

            PeerFinder.Stop();
        }
    }

    class PeerClient
    {
        [DllImport("shell32.dll")]
        static extern int SetCurrentProcessExplicitAppUserModelID([MarshalAs(UnmanagedType.LPWStr)] string AppID);

        public PeerClient()
        {
            SetCurrentProcessExplicitAppUserModelID("ConsoleApp.Test1");

            PeerFinder.Role = PeerRole.Client;
            PeerFinder.AllowWiFiDirect = true;

            if ((Windows.Networking.Proximity.PeerFinder.SupportedDiscoveryTypes &
                 Windows.Networking.Proximity.PeerDiscoveryTypes.Browse) !=
                 Windows.Networking.Proximity.PeerDiscoveryTypes.Browse)
            {
                Console.WriteLine("Peer discovery using Wi-Fi Direct is not supported.\n");
                return;
            }
        }

        public async void Start()
        {
            PeerFinder.Start();

            var peerInfoCollection = await PeerFinder.FindAllPeersAsync();

            if (peerInfoCollection.Count == 0)
            {
                Console.WriteLine("No peers found");
                return;
            }

            foreach (var info in peerInfoCollection)
            {
                Console.WriteLine("Peer found: {0} - {1}", info.DisplayName, info.Id);

                Windows.Networking.Sockets.StreamSocket socket = null;

                try
                {
                    Task<Windows.Networking.Sockets.StreamSocket> task = PeerFinder.ConnectAsync(info).AsTask();
                    if (task.Wait(5000) == false)
                    {
                        Console.WriteLine("timeout");
                        continue;
                    }

                    socket = task.Result;
                    Sender(socket);
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.ToString());
                }

                if (socket != null)
                {
                    socket.Dispose();
                }
            }
        }

        void Sender(Windows.Networking.Sockets.StreamSocket socket)
        {
            using (Stream streamWrite = socket.OutputStream.AsStreamForWrite())
            using (BinaryWriter writer = new BinaryWriter(streamWrite))
            using (Stream streamRead = socket.InputStream.AsStreamForRead())
            using (BinaryReader reader = new BinaryReader(streamRead))
            {
                int ini = Environment.TickCount;
                long totalToSend = 64 * 1024 * 1024;

                writer.Write(totalToSend);
                Console.WriteLine("Going to send {0} bytes", totalToSend);

                byte[] buffer = new byte[totalToSend];
                writer.Write(buffer);
                writer.Flush();

                try
                {
                    reader.ReadBoolean();
                } catch { }

                float MB = totalToSend / 1024 / 1024;
                float secs = (Environment.TickCount - ini) / 1000;
                Console.WriteLine("Sent {0} MB in {1} secs = {2:#0.##} MB/s",
                    MB, secs, MB / secs);
            }
        }
    }
}

서버는 이렇게 추가해 주면 됩니다.

using System;
using System.IO;
using System.Runtime.InteropServices;
using System.Threading;
using System.Threading.Tasks;
using Windows.Networking.Proximity;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            PeerHost peerHost = new PeerHost();

            Console.WriteLine("Press any key to exit...");
            Console.ReadLine();

            peerHost.Stop();
        }
    }

    class PeerHost
    {
        [DllImport("shell32.dll")]
        static extern int SetCurrentProcessExplicitAppUserModelID([MarshalAs(UnmanagedType.LPWStr)] string AppID);

        public PeerHost()
        {
            SetCurrentProcessExplicitAppUserModelID("ConsoleApp.Test1");

            if ((Windows.Networking.Proximity.PeerFinder.SupportedDiscoveryTypes &
                    Windows.Networking.Proximity.PeerDiscoveryTypes.Browse) !=
                    Windows.Networking.Proximity.PeerDiscoveryTypes.Browse)
            {
                Console.WriteLine("Peer discovery using Wi-Fi Direct is not supported.\n");
                return;
            }

            PeerFinder.Role = PeerRole.Host;

            PeerFinder.DisplayName = "PeerFinderConsoleApp";
            PeerFinder.AllowWiFiDirect = true;

            PeerFinder.ConnectionRequested += ConnectionRequested;

            PeerFinder.Start();
        }

        void ConnectionRequested(object sender, Windows.Networking.Proximity.ConnectionRequestedEventArgs e)
        {
            Console.WriteLine("Connection requested by " + e.PeerInformation.DisplayName + ". " +
                "Will be accepted automatically.");

            Windows.Networking.Sockets.StreamSocket socket = null;

            try
            {
                Console.WriteLine("Receiver waiting to connect async");

                Task<Windows.Networking.Sockets.StreamSocket> task = PeerFinder.ConnectAsync(e.PeerInformation).AsTask();
                if (task.Wait(5000) == false)
                {
                    Console.WriteLine("timeout");
                    return;
                }

                socket = task.Result;
                Receiver(socket);
            } catch { }

            if (socket != null)
            {
                Thread.Sleep(1000);
                socket.Dispose();
            }
        }

        static void Receiver(Windows.Networking.Sockets.StreamSocket socket)
        {
            Console.WriteLine("Receiver connection happened");

            int ini = Environment.TickCount;

            using (Stream streamRead = socket.InputStream.AsStreamForRead())
            using (Stream streamWrite = socket.OutputStream.AsStreamForWrite())
            using (BinaryReader reader = new BinaryReader(streamRead))
            using (BinaryWriter writer = new BinaryWriter(streamWrite))
            {
                long totalToRead = reader.ReadInt64();
                Console.WriteLine("Going to read {0} bytes", totalToRead);
                long read = 0;
                byte[] buffer = new byte[32 * 1024 * 1024];

                while (read < totalToRead)
                {
                    long toRead = totalToRead - read;

                    if (toRead >= buffer.Length)
                    {
                        toRead = buffer.Length;
                    }

                    reader.Read(buffer, 0, (int)toRead);

                    Console.WriteLine("{0}/{1}", read, totalToRead);
                    read += toRead;
                }

                writer.Write(true);
                writer.Flush();

                float MB = totalToRead / 1024 / 1024;
                float secs = (Environment.TickCount - ini) / 1000;

                Console.WriteLine("Received {0} MB in {1} secs = {2:#0.##} MB/s",
                    MB, secs, MB / secs);
            }
        }

        internal void Stop()
        {
            PeerFinder.Stop();
        }
    }
}

Wi-Fi Direct가 재미있는 것은, 통신 속도입니다. 제가 집에 있는 USB 외장 하드로 파일을 복사하면 초당 20MB 정도 되는데, Wi-Fi Direct는 위의 실습 코드인 64MB도 1초에 끝내 버립니다. (오히려 Peer 탐색 시간이 더 걸립니다. ^^;)

따라서, 상황에 따라 꽤나 유용한 기능이 될 수 있습니다.

(첨부 파일은 이 글의 예제 코드를 포함합니다.)

참고로, Wi-Fi Direct 통신의 HOST 측 응용 프로그램이 동작하면 제어판의 "Windows Firewall" 항목에 다음과 같이 임시 네트워크가 생성되는 것을 볼 수 있습니다.

wifi_direct_network_info_1.png




그런데... Wi-Fi Direct 구축 환경이 예상외로 거의 없는 편입니다.

Wi-Fi Direct 지원 여부 확인 방법
; https://www.sysnet.pe.kr/2/0/11100

게다가 실습하는 것도 좀 까다로워서 저 역시 다음과 같은 시행착오를 겪었습니다.

PeerFinder Wi-Fi Direct 통신 시 Read/Write/Dispose 문제
; https://www.sysnet.pe.kr/2/0/11105

PeerFinder로 Wi-Fi Direct 연결 시 방화벽 문제
; https://www.sysnet.pe.kr/2/0/11104

PeerFinder.ConnectAsync의 결과 값인 Task.Result를 호출할 때 System.AggregateException 예외 발생
; https://www.sysnet.pe.kr/2/0/11103

PeerFinder.FindAllPeersAsync 호출 시 System.UnauthorizedAccessException 예외 발생
; https://www.sysnet.pe.kr/2/0/11102

그 외에 참고 자료로 마이크로소프트의 (약간 오래된) 예제와 설명이 있습니다.

Proximity sample
; https://code.msdn.microsoft.com/windowsapps/proximity-sample-88129731/

Quickstart: Connecting applications using tapping or browsing (C#) 
; https://docs.microsoft.com/en-us/previous-versions/windows/apps/hh465205(v=win.10)

Quickstart: Publishing and subscribing to messages using tapping (C#) 
; https://docs.microsoft.com/en-us/previous-versions/windows/apps/hh465213(v=win.10)




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]



donaricano-btn



[최초 등록일: ]
[최종 수정일: 7/17/2021]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 쓴 사람
 



2021-11-27 12시42분
[캐티] 윈도우 10에서 안드로이드 Wi-Fi 다이렉트 연결을 해놓으면 몇 초 지나서 끊겨버리네요.
윈도우 OS 자체의 문제인 것일까요.
[손님]
2021-11-27 12시43분
글쎄요... 제가 지금은 Window 11이라서 테스트를 할 수가 없군요. ^^;
정성태

[1]  2  3  4  5  6  7  8  9  10  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
12938정성태1/24/202229개발 환경 구성: 633. Docker Desktop + k8s 환경에서 local 이미지를 사용하는 방법
12937정성태1/24/202235.NET Framework: 1139. C# - ffmpeg(FFmpeg.AutoGen)를 이용해 오디오(mp2) 인코딩하는 예제(encode_audio.c)파일 다운로드1
12936정성태1/22/202235.NET Framework: 1138. C# - ffmpeg(FFmpeg.AutoGen)를 이용해 멀티미디어 파일의 메타데이터를 보여주는 예제(metadata.c)파일 다운로드1
12935정성태1/22/202230.NET Framework: 1137. ffmpeg의 파일 해시 예제(ffhash.c)를 C#으로 포팅파일 다운로드1
12934정성태1/22/202217오류 유형: 788. Warning C6262 Function uses '65564' bytes of stack: exceeds /analyze:stacksize '16384'. Consider moving some data to heap.
12933정성태1/21/202231.NET Framework: 1136. C# - ffmpeg(FFmpeg.AutoGen)를 이용해 MP2 오디오 파일 디코딩 예제(decode_audio.c)파일 다운로드1
12932정성태1/20/202282.NET Framework: 1135. C# - ffmpeg(FFmpeg.AutoGen)로 하드웨어 가속기를 이용한 비디오 디코딩 예제(hw_decode.c) [2]파일 다운로드1
12931정성태1/20/202289개발 환경 구성: 632. ASP.NET Core 프로젝트를 AKS/k8s에 올리는 과정
12930정성태1/19/202237개발 환경 구성: 631. AKS/k8s의 Volume에 파일 복사하는 방법
12929정성태1/19/202258개발 환경 구성: 630. AKS/k8s의 Pod에 Volume 연결하는 방법
12928정성태1/18/202256개발 환경 구성: 629. AKS/Kubernetes에서 호스팅 중인 pod에 shell(/bin/bash)로 진입하는 방법
12927정성태1/18/202263개발 환경 구성: 628. AKS 환경에 응용 프로그램 배포 방법
12926정성태1/17/202239오류 유형: 787. AKS - pod 배포 시 ErrImagePull/ImagePullBackOff 오류
12925정성태1/17/202274개발 환경 구성: 627. AKS의 준비 단계 - ACR(Azure Container Registry)에 docker 이미지 배포
12924정성태1/15/2022167.NET Framework: 1134. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 비디오 디코딩 예제(decode_video.c) [2]파일 다운로드1
12923정성태1/15/202286개발 환경 구성: 626. ffmpeg.exe를 사용해 비디오 파일을 MPEG1 포맷으로 변경하는 방법
12922정성태1/14/202295개발 환경 구성: 625. AKS - Azure Kubernetes Service 생성 및 SLO/SLA 변경 방법
12921정성태1/14/202256개발 환경 구성: 624. Docker Desktop에서 별도 서버에 설치한 docker registry에 이미지 올리는 방법
12920정성태1/14/202223오류 유형: 786. Camtasia - An error occurred with the camera: Failed to Add Video Sampler.
12919정성태1/13/202283Windows: 199. Host Network Service (HNS)에 의해서 점유되는 포트
12918정성태1/13/202286Linux: 47. WSL - shell script에서 설정한 환경 변수가 스크립트 실행 후 반영되지 않는 문제
12917정성태1/12/202250오류 유형: 785. C# - The type or namespace name '...' could not be found (are you missing a using directive or an assembly reference?)
12916정성태1/12/202230오류 유형: 784. TFS - One or more source control bindings for this solution are not valid and are listed below.
12915정성태1/11/202267오류 유형: 783. Visual Studio - We didn't find any interpreters
12914정성태1/11/2022180VS.NET IDE: 172. 비주얼 스튜디오 2022의 파이선 개발 환경 지원
[1]  2  3  4  5  6  7  8  9  10  11  12  13  14  15  ...