IOS網絡開發實戰（一）

時間  2020-08-18
標籤 ios 網絡 開發 實戰 欄目 iOS 简体版
原文   原文鏈接
 

1 局域網羣聊軟件

1.1 問題

UDP協議將獨立的數據包從一臺計算機傳輸到另一臺計算機，可是並不保證接受方可以接收到該數據包，也不保證接收方所接收到的數據和發送方所發送的數據在內容和順序上是徹底一致的。html

UDP廣播就是創建於UDP協議上的數據傳輸,當網絡中的某一臺計算機向交換機或路由發送一個廣播數據時，交換機或路由則會將此廣播數據發送到其節點下的全部接收者。本案例使用第三方Socket編程框架AsyncUdpSocket框架，基於UDP廣播實現一個局域網羣聊軟件，一個基於UD廣播的聊天室程序，不須要任何的服務端程序作數據中轉，如圖-1所示：編程

圖-1數組

1.2 方案

首先建立一個SingleViewApplication應用，導入AsyncUdpSocket框架。在Storyboard中搭建聊天界面，場景左邊拖放一個大的TableView控件用於展現聊天記錄，設置tag值爲0。右邊拖放一個小的TableView控件，用於展現參與羣聊的用戶IP，tag值設置爲1，並將這兩個TableView控件關聯成ViewController的輸出口屬性myChatRecordTV和usersList。服務器

在場景的下方拖放一個Textfield控件用於輸入接受用戶輸入的聊天信息端，該控件上方是一個選擇全部人的按鈕，右邊是一個發送按鈕，將Textfield控件關聯成ViewController的輸出口屬性myTF，將按鈕分別關聯成動做方法sendAll:和send:。網絡

接下來首先實現聊天功能，在ViewController中定義一個屬性AsyncUdpSocket類型的udpSocket。在viewDidLoad方法中建立服務器端udpSocket，將端口號設置爲8000，委託對象設置爲self，並設置廣播屬性。併發

而後再定義兩個NSMutableArray類型的屬性users和chatRecord，分別用於記錄參與聊天用戶的IP和聊天記錄，在viewDidLoad方法中進行初始化。而後實現兩個TableView的協議方法，展現數據。app

接下來定義一個NSString類型的currentHost屬性，該屬性記錄用戶所選擇的聊天的對象，若該屬性爲空則表示聊天對象是全部用戶，而後實現sendAll:方法和send:方法。框架

當用戶點擊輸入框準備輸入的時候會彈出鍵盤，這時候須要將整個聊天界面上移，這裏使用註冊鍵盤通知的方式調整self.view的座標位置。在viewDidLoad方法中註冊鍵盤即將出現和鍵盤即將消失兩個通知，分別實現對應的方法便可。最後在viewWillDisappear:方法中註銷通知。socket

sendAll:方法中直接將屬性currentHost設置爲nil便可，send:方法中將根據是否存在currentHost進行消息發送，若是currentHost存在則將消息發送給currentHost，若是不存在則發送給255.255.255.255，即發送給全員，並更新myChatRecordTV的顯示內容。tcp

最後實現AsyncUdpSocketDelegate的協議方法onUdpSocket:didReceiveData:withTag:fromHost:port:，讀取數據和在線用戶，分別更新顯示聊天記錄內容和用戶列表。

1.3 步驟

實現此案例須要按照以下步驟進行。

步驟一：搭建聊天界面

首先建立一個SingleViewApplication應用，導入AsyncUdpSocket框架。在Storyboard中搭建聊天界面，場景左邊拖放一個大的TableView控件用於展現聊天記錄，設置tag值爲0。右邊拖放一個小的TableView控件，用於展現參與羣聊的用戶IP，tag值設置爲1，並將這兩個TableView控件關聯成ViewController的輸出口屬性myChatRecordTV和usersList，代碼以下所示：

  1. @interface ViewController ()
  2. @property (strong, nonatomic) IBOutlet UITableView *myChatRecordTV;
  3. @property (strong, nonatomic) IBOutlet UITableView *usersList;
  4. @end

而後在場景的下方拖放一個Textfield控件用於輸入接受用戶輸入的聊天信息端，該控件上方是一個選擇全部人的按鈕，右邊是一個發送按鈕，將Textfield控件關聯成ViewController的輸出口屬性myTF，將按鈕分別關聯成動做方法sendAll:和send:，如圖-2所示：

圖-2

步驟二：實現聊天功能

首先實現聊天功能，在ViewController中定義一個屬性AsyncUdpSocket類型的udpSocket。在viewDidLoad方法中建立服務器端udpSocket，將端口號設置爲8000，委託對象設置爲self，並設置廣播屬性，代碼以下所示：

  1. //建立服務器端
  2. self.udpSocket = [[AsyncUdpSocket alloc]initWithDelegate:self];
  3. [self.udpSocket bindToPort:8000 error:nil];
  4. [self.udpSocket enableBroadcast:YES error:nil];
  5. [self.udpSocket joinMulticastGroup:@"192.168.1.104" error:nil];
  6. //持續接受
  7. [self.udpSocket receiveWithTimeout:-1 tag:0];

再定義兩個NSMutableArray類型的屬性users和chatRecord，分別用於記錄參與聊天用戶的IP和聊天記錄，在viewDidLoad方法中進行初始化，代碼以下所示：

  1. @property (strong,nonatomic) NSMutableArray *users;
  2. @property (strong,nonatomic) NSMutableArray *chatRecord;
  3. - (void)viewDidLoad {
  4. [super viewDidLoad];
  5. //初始化數組
  6. self.users = [NSMutableArray array];
  7. self.chatRecord = [NSMutableArray array];
  8. }

接下來實現兩個TableView的協議方法，展現數據，代碼以下所示：

  1. //表視圖協議方法
  2. - (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {
  3. if (tableView.tag == 0) {
  4. return self.chatRecord.count;
  5. }else {
  6. return self.users.count;
  7. }
  8. }
  9. - (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath {
  10. static NSString *identifier = @"Cell";
  11. UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:identifier];
  12. if (!cell) {
  13. cell = [[UITableViewCell alloc]initWithStyle:UITableViewCellStyleDefault reuseIdentifier:@"Cell"];
  14. }
  15. switch (tableView.tag) {
  16. case 0:
  17. cell.textLabel.text = self.chatRecord[indexPath.row];
  18. [cell.textLabel setFont:[UIFont systemFontOfSize:12]];
  20. break;
  21. case 1:
  22. cell.textLabel.text = self.users[indexPath.row];
  23. [cell.textLabel setFont:[UIFont systemFontOfSize:10]];
  24. break;
  25. }
  26. return cell;
  27. }

接下來定義一個NSString類型的currentHost屬性，該屬性記錄用戶所選擇的聊天的對象，若該屬性爲空則表示聊天對象是全部用戶。在選擇一個聊天對象時進行賦值，代碼以下所示：

  1. -(void)tableView:(UITableView *)tableView didSelectRowAtIndexPath:(NSIndexPath *)indexPath {
  2. self.currentHost = [self.users objectAtIndex:indexPath.row];
  3. }

而後實現sendAll:方法和send:方法。當用戶點擊輸入框準備輸入的時候會彈出鍵盤，這時候須要將整個聊天界面上移，這裏使用註冊鍵盤通知的方式調整self.view的座標位置。在viewDidLoad方法中註冊鍵盤即將出現和鍵盤即將消失兩個通知，分別實現對應的方法便可，代碼以下所示：

  1. //註冊鍵盤信息
  2. [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(keyboardShow:) name:UIKeyboardWillShowNotification object:nil];
  3. [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(keyboardHidden:) name:UIKeyboardWillHideNotification object:nil];
  4. //當鍵盤即將出現的時候self.view根據鍵盤的高度上移
  5. -(void)keyboardShow:(NSNotification*) notification {
  6. CGRect keyboardRect = [notification.userInfo[UIKeyboardFrameEndUserInfoKey] CGRectValue];
  7. NSTimeInterval duration =
  8. [notification.userInfo[UIKeyboardAnimationDurationUserInfoKey] doubleValue];
  9. UIViewAnimationOptions options =
  10. [notification.userInfo[UIKeyboardAnimationCurveUserInfoKey] unsignedIntegerValue];
  11. duration -= 0.1;
  12. [UIView animateWithDuration:duration
  13. delay:0
  14. options:options
  15. animations:
  16. ^{
  17. self.view.center = CGPointMake(p.x, p.y-keyboardRect.size.height);
  18. } completion:nil];
  19. }
  20. //當鍵盤即將消失的時候self.view恢復到原來的位置
  21. -(void)keyboardHidden:(NSNotification*)notification {
  22. NSTimeInterval duration =
  23. [notification.userInfo[UIKeyboardAnimationDurationUserInfoKey] doubleValue];
  24. UIViewAnimationOptions options =
  25. [notification.userInfo[UIKeyboardAnimationCurveUserInfoKey] unsignedIntegerValue];
  26. duration -= 0.1;
  27. [UIView animateWithDuration:duration
  28. delay:0
  29. options:options
  30. animations:
  31. ^{
  32. self.view.center = CGPointMake(p.x, p.y);
  33. } completion:nil];
  34. }

最後須要在viewWillDisappear:方法中註銷通知，代碼以下所示：

  1. //註銷鍵盤通知
  2. -(void)viewWillDisappear:(BOOL)animated {
  3. [super viewWillDisappear:animated];
  4. [[NSNotificationCenter defaultCenter] removeObserver:self name:UIKeyboardWillShowNotification object:nil];
  5. [[NSNotificationCenter defaultCenter] removeObserver:self name:UIKeyboardWillHideNotification object:nil];
  6. }

sendAll:方法中直接將屬性currentHost設置爲nil便可，代碼以下所示：

  1. - (IBAction)sendAll:(UIButton *)sender {
  2. self.currentHost = nil;
  3. }

send:方法中將根據是否存在currentHost進行消息發送，若是currentHost存在則將消息發送給currentHost，若是不存在則發送給255.255.255.255，即發送給全員，並更新myChatRecordTV的顯示內容，代碼以下所示：

  1. - (IBAction)send:(UIButton *)sender {
  2. [self.myTF resignFirstResponder];
  3. if (self.currentHost) {
  4. NSString *chat = [NSString stringWithFormat:@"我saidto%@：%@",self.currentHost,self.myTF.text];
  5. NSString *chatSend = [NSString stringWithFormat:@"%@",self.myTF.text];
  6. [self.udpSocket sendData:[chatSend dataUsingEncoding:NSUTF8StringEncoding] toHost:self.currentHost port:8000 withTimeout:-1 tag:0];
  7. [self.chatRecord addObject:chat];
  9. }else {
  10. [self.udpSocket sendData:[self.myTF.text dataUsingEncoding:NSUTF8StringEncoding] toHost:@"255.255.255.255" port:8000 withTimeout:-1 tag:0];
  11. NSString *chat = [NSString stringWithFormat:@"我saidToAll：%@",self.myTF.text];
  12. [self.chatRecord addObject:chat];
  13. }
  14. [self.myChatRecordTV reloadData];
  15. [self.udpSocket receiveWithTimeout:-1 tag:0];
  16. }

最後實現AsyncUdpSocketDelegate的協議方法onUdpSocket:didReceiveData: withTag:fromHost:port:，讀取數據和在線用戶，分別更新顯示聊天記錄內容和用戶列表，代碼以下所示：

  1. -(BOOL)onUdpSocket:(AsyncUdpSocket *)sock didReceiveData:(NSData *)data withTag:(long)tag fromHost:(NSString *)host port:(UInt16)port {
  2. NSString *str = [[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding];
  3. if([str isEqualToString:@"誰在線"]) {
  4. [self.udpSocket sendData:[@"我在線" dataUsingEncoding:NSUTF8StringEncoding] toHost:@"255.255.255.255" port:8000 withTimeout:-1 tag:0];
  5. NSString *chat = [NSString stringWithFormat:@"%@:我在線",host];
  6. [self.chatRecord addObject:chat];
  7. [self.myChatRecordTV reloadData];
  8. }else if([str isEqualToString:@"我在線"]) {
  9. //更新聊天用戶列表
  10. NSLog(@"%@",host);
  11. [self.users addObject:host];
  12. [self.usersList reloadData];
  13. }else {
  14. NSString *chat = [NSString stringWithFormat:@"%@saidToMe:%@",host,str];
  15. [self.chatRecord addObject:chat];
  16. [self.myChatRecordTV reloadData];
  17. }
  19. return YES;
  20. }

1.4 完整代碼

本案例中，ViewController.m文件中的完整代碼以下所示：

 
  1. #import "ViewController.h"
  2. #import "AsyncUdpSocket.h"
  3. #import "AppDelegate.h"
  5. @interface ViewController ()<UITableViewDataSource,UITableViewDelegate,UITextFieldDelegate>{
  7. CGPoint p;
  8. }
  10. @property (strong, nonatomic) IBOutlet UITextField *myTF;
  11. @property (strong, nonatomic) IBOutlet UITableView *myChatRecordTV;
  12. @property (strong, nonatomic) IBOutlet UITableView *usersList;
  13. @property (strong,nonatomic) AsyncUdpSocket *udpSocket;
  14. @property (strong,nonatomic) NSMutableArray *users;
  15. @property (strong,nonatomic) NSMutableArray *chatRecord;
  16. @property (nonatomic,retain) NSString *currentHost;
  17. @end
  19. @implementation ViewController
  21. - (void)viewDidLoad
  22. {
  23. [super viewDidLoad];
  24. //初始化數組
  25. self.users = [NSMutableArray array];
  26. self.chatRecord = [NSMutableArray array];
  27. //記錄self.view的中心位置
  28. p = self.view.center;
  29. //建立服務器端
  30. self.udpSocket = [[AsyncUdpSocket alloc]initWithDelegate:self];
  31. [self.udpSocket bindToPort:8000 error:nil];
  32. [self.udpSocket enableBroadcast:YES error:nil];
  33. [self.udpSocket joinMulticastGroup:@"192.168.1.104" error:nil];
  34. //持續接受
  35. [self.udpSocket receiveWithTimeout:-1 tag:0];
  36. //註冊鍵盤信息
  37. [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(keyboardShow:) name:UIKeyboardWillShowNotification object:nil];
  38. [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(keyboardHidden:) name:UIKeyboardWillHideNotification object:nil];
  39. }
  40. //當鍵盤即將出現的時候self.view根據鍵盤的高度上移
  41. -(void)keyboardShow:(NSNotification*) notification {
  42. CGRect keyboardRect = [notification.userInfo[UIKeyboardFrameEndUserInfoKey] CGRectValue];
  43. NSTimeInterval duration =
  44. [notification.userInfo[UIKeyboardAnimationDurationUserInfoKey] doubleValue];
  45. UIViewAnimationOptions options =
  46. [notification.userInfo[UIKeyboardAnimationCurveUserInfoKey] unsignedIntegerValue];
  47. duration -= 0.1;
  48. [UIView animateWithDuration:duration
  49. delay:0
  50. options:options
  51. animations:
  52. ^{
  53. self.view.center = CGPointMake(p.x, p.y-keyboardRect.size.height);
  54. } completion:nil];
  55. }
  56. //當鍵盤即將消失的時候self.view恢復到原來的位置
  57. -(void)keyboardHidden:(NSNotification*)notification {
  58. NSTimeInterval duration =
  59. [notification.userInfo[UIKeyboardAnimationDurationUserInfoKey] doubleValue];
  60. UIViewAnimationOptions options =
  61. [notification.userInfo[UIKeyboardAnimationCurveUserInfoKey] unsignedIntegerValue];
  62. duration -= 0.1;
  63. [UIView animateWithDuration:duration
  64. delay:0
  65. options:options
  66. animations:
  67. ^{
  68. self.view.center = CGPointMake(p.x, p.y);
  69. } completion:nil];
  71. }
  72. //註銷鍵盤通知
  73. -(void)viewWillDisappear:(BOOL)animated {
  74. [super viewWillDisappear:animated];
  75. [[NSNotificationCenter defaultCenter] removeObserver:self name:UIKeyboardWillShowNotification object:nil];
  76. [[NSNotificationCenter defaultCenter] removeObserver:self name:UIKeyboardWillHideNotification object:nil];
  77. }
  79. -(BOOL)onUdpSocket:(AsyncUdpSocket *)sock didReceiveData:(NSData *)data withTag:(long)tag fromHost:(NSString *)host port:(UInt16)port {
  80. NSString *str = [[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding];
  81. if([str isEqualToString:@"誰在線"]) {
  82. [self.udpSocket sendData:[@"我在線" dataUsingEncoding:NSUTF8StringEncoding] toHost:@"255.255.255.255" port:8000 withTimeout:-1 tag:0];
  83. NSString *chat = [NSString stringWithFormat:@"%@:我在線",host];
  84. [self.chatRecord addObject:chat];
  85. [self.myChatRecordTV reloadData];
  86. }else if([str isEqualToString:@"我在線"]) {
  87. //更新聊天用戶列表
  88. NSLog(@"%@",host);
  89. [self.users addObject:host];
  90. [self.usersList reloadData];
  91. }else {
  92. NSString *chat = [NSString stringWithFormat:@"%@saidToMe:%@",host,str];
  93. [self.chatRecord addObject:chat];
  94. [self.myChatRecordTV reloadData];
  95. }
  97. return YES;
  98. }
  99. //表視圖協議方法
  100. - (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {
  101. if (tableView.tag == 0) {
  102. return self.chatRecord.count;
  103. }else {
  104. return self.users.count;
  105. }
  106. }
  107. - (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath {
  108. static NSString *identifier = @"Cell";
  109. UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:identifier];
  110. if (!cell) {
  111. cell = [[UITableViewCell alloc]initWithStyle:UITableViewCellStyleDefault reuseIdentifier:@"Cell"];
  112. }
  113. switch (tableView.tag) {
  114. case 0:
  115. cell.textLabel.text = self.chatRecord[indexPath.row];
  116. [cell.textLabel setFont:[UIFont systemFontOfSize:12]];
  118. break;
  119. case 1:
  120. cell.textLabel.text = self.users[indexPath.row];
  121. [cell.textLabel setFont:[UIFont systemFontOfSize:10]];
  122. break;
  123. }
  124. return cell;
  125. }
  127. -(void)tableView:(UITableView *)tableView didSelectRowAtIndexPath:(NSIndexPath *)indexPath {
  128. self.currentHost = [self.users objectAtIndex:indexPath.row];
  129. }
  131. -(CGFloat)tableView:(UITableView *)tableView heightForRowAtIndexPath:(NSIndexPath *)indexPath {
  132. return 25;
  133. }
  135. - (IBAction)done:(UITextField *)sender {
  136. [self.myTF resignFirstResponder];
  137. }
  139. - (IBAction)send:(UIButton *)sender {
  140. [self.myTF resignFirstResponder];
  141. if (self.currentHost) {
  142. NSString *chat = [NSString stringWithFormat:@"我saidto%@：%@",self.currentHost,self.myTF.text];
  143. NSString *chatSend = [NSString stringWithFormat:@"%@",self.myTF.text];
  144. [self.udpSocket sendData:[chatSend dataUsingEncoding:NSUTF8StringEncoding] toHost:self.currentHost port:8000 withTimeout:-1 tag:0];
  145. [self.chatRecord addObject:chat];
  147. }else {
  148. [self.udpSocket sendData:[self.myTF.text dataUsingEncoding:NSUTF8StringEncoding] toHost:@"255.255.255.255" port:8000 withTimeout:-1 tag:0];
  149. NSString *chat = [NSString stringWithFormat:@"我saidToAll：%@",self.myTF.text];
  150. [self.chatRecord addObject:chat];
  151. }
  152. [self.myChatRecordTV reloadData];
  153. [self.udpSocket receiveWithTimeout:-1 tag:0];
  154. }
  156. - (IBAction)sendAll:(UIButton *)sender {
  157. self.currentHost = nil;
  158. }
  160. -(BOOL)prefersStatusBarHidden {
  161. return YES;
  162. }
  163. @end
 

2 基於服務發現的Socket通訊

2.1 問題

Socket須要指定服務器的端口和IP地址，在有些狀況下得到服務器的這些信息是很困難的，蘋果公司提供一種零配置服務發現協議，命名爲Bonjour，使應用在沒必要指定服務器端口和IP地址就能夠動態發現。

蘋果提供的Bonjour編程的相關類主要是兩個，NSNetService和NSNetServiceBrowser，以及和這兩個類配套的協議NSNetServiceDelegate和NSNetServiceBrowserDelegate。本案例經過Bonjour服務發現實現Socket通訊。

2.2 方案

首先建立服務器端應用NetServiceServer，用Xcode建立一個Command Line命令行項目，發現服務並不包含Socket服務器的啓動，所以啓動Socket服務器的代碼須要先編寫，服務器啓動後會得到動態端口，再把這個端口做爲參數傳遞給Bonjour發現服務，發佈成功創建Socket，本案例使用NSStream和CFStream實現服務器代碼。

接下來建立一個NetServiceServer類，幾乎所有的代碼都在該類中實現，在該類中定義兩個私有屬性，一個是NSNetService類型的service，用於發佈Bonjour服務並重寫setter方法進行初始化，另外一個屬性是short類型的port，用於記錄端口號。

其次啓動服務器，將啓動服務器的代碼封裝在setupServer方法，本案例使用NSStream和CFStream來實現服務器的啓動，而後在init方法中調用setupServer方法。

而後發佈服務，將發佈服務的代碼封裝在publishService方法中，並在init方法中調用。而後再實現協議方法netServiceDidPublish:，該方法在服務發佈結束後被調用，能夠經過該方法查看服務是否發佈成功。

最後在main函數中建立NetServiceServer實例對象，並調用CFRunLoopRun()函數，該函數能夠在當前線程啓動一個Runloop循環，使得服務器一直在運行狀態。

接下來建立客戶端應用NetServiceClient，使用Xcode建立一個SingleViewApplication應用，在Storyboard中搭建應用的界面，拖放兩個Button控件和一個Label控件，將Label關聯成TRViewController的輸出口屬性displayLabel，將兩個Button分別關聯成動做方法sendMessage和recvMessage，分別用於發送消息和接受消息。

建立NetServiceClient客戶端類，用於發現Bonjour服務，該類有一個NSMutableArray類型的屬性services用於記錄發現的服務對象，在.h文件中該屬性是隻讀的，在.m文件中該屬性是可讀可寫的。

另外還有一個私用屬性NSNetService類型的service，用於發現解析服務，在init方法中對以上兩個屬性進行初始化併發布服務，最後實現NSNetServiceDelegate協議相關方法。

而後完成ViewController類中的代碼，該類中沒有任何與服務發現相關的代碼，它從NetServiceClient類中得到輸入和輸出流對象，而後進行通訊就能夠了，這裏的讀寫數據流的操做一樣也是使用NSStream和CFStream類來實現。

在ViewController類中定義兩個私有屬性NSInputStream類型的inputStream，以及NSOutputStream類型的outputStream，分別用於記錄輸入流和輸出流，他們分別和服務器中的輸出流CFWriteStreamRef和輸入流CFReadStreamRef對應。

最後實現sendMessage和recvMessage方法，更新displayLabel的顯示。

2.3 步驟

實現此案例須要按照以下步驟進行。

步驟一：建立服務器端應用

首先建立服務器端應用NetServiceServer，用Xcode建立一個Command Line命令行項目，發現服務並不包含Socket服務器的啓動，所以啓動Socket服務器的代碼須要先編寫，服務器啓動後會得到動態端口，再把這個端口做爲參數傳遞給Bonjour發現服務，發佈成功創建Socket，本案例使用NSStream和CFStream實現服務器代碼，所以須要導入頭文件CoreFoundation.h，還須要包含頭文件sys/socket.h和netinet/in.h。

接下來建立一個NetServiceServer類，幾乎所有的代碼都在該類中實現，在該類中定義兩個私有屬性，一個是NSNetService類型的service，用於發佈Bonjour服務並重寫setter方法進行初始化，另外一個屬性是short類型的port，用於記錄端口號，代碼以下所示：

 
  1. @interface NetServiceServer () <NSNetServiceDelegate>
  2. @property (strong,nonatomic)NSNetService *service;
  3. @property (nonatomic) short port;
  4. @end
  5. //重寫setter方法初始化
  6. - (NSNetService *)service
  7. {
  8. if (!_service) {
  9. _service = [[NSNetService alloc]initWithDomain:@"local." type:@"_tarenaipp._tcp." name:@"tarena" port:self.port];
  10. }
  11. return _service;
  12. }

其次啓動服務器，將啓動服務器的代碼封裝在setupServer方法，本案例使用NSStream和CFStream來實現服務器的啓動，代碼以下所示：

 
  1. - (void)setupServer
  2. {
  3. CFSocketContext CTX = {};
  4. //建立Socket，其實就是指針
  5. CFSocketRef serverSocket;
  6. //設置回調函數
  7. serverSocket = CFSocketCreate(NULL, PF_INET, SOCK_STREAM, IPPROTO_TCP, kCFSocketAcceptCallBack, AcceptCallBack, &CTX);
  8. if(serverSocket == NULL){
  9. NSLog(@"socket建立失敗");
  10. return;
  11. }
  12. //設置一些socket的屬性
  13. //布爾值類型, 能夠重複使用一個已經使用過的地址和端口
  14. int yes = 1;
  15. setsockopt(CFSocketGetNative(serverSocket), SOL_SOCKET, SO_REUSEADDR, (void*)&yes, sizeof(yes));
  16. //設置地址
  17. struct sockaddr_in addr = {};
  18. //設置IPv4
  19. addr.sin_family = PF_INET;
  20. //內核分配，本機地址，htonl函數將無符號短整型數轉換成網絡字節序
  21. addr.sin_addr.s_addr = htonl(INADDR_ANY);
  22. //端口號設置爲0
  23. addr.sin_port = 0;
  24. addr.sin_len = sizeof(addr);
  25. //將struct sockaddr_in ==> CFDataRef，從指定字節緩衝區複試一個不可變的CFData對象
  26. CFDataRef address = CFDataCreate(kCFAllocatorDefault, (UInt8*)&addr, sizeof(addr));
  27. //設置Socket
  28. if(CFSocketSetAddress(serverSocket, address) != kCFSocketSuccess){
  29. NSLog(@"綁定失敗");
  30. return;
  31. }
  32. NSLog(@"綁定成功");
  34. //在Bonjour廣播時須要port
  35. NSData *socketAddressActualData = (__bridge NSData *)CFSocketCopyAddress(serverSocket);
  36. struct sockaddr_in socketAddressActual;
  37. memcpy(&socketAddressActual, [socketAddressActualData bytes], [socketAddressActualData length]);
  38. self.port = ntohs(socketAddressActual.sin_port);
  39. NSLog(@"ServerSocket監聽的端口號:%hu\n", self.port);
  41. //建立Run Loop Socket源
  42. CFRunLoopSourceRef sourceRef = CFSocketCreateRunLoopSource(kCFAllocatorDefault, serverSocket, 0);
  43. //將socket源加入到Run Loop中
  44. CFRunLoopAddSource(CFRunLoopGetCurrent(), sourceRef, kCFRunLoopCommonModes);
  45. CFRelease(sourceRef);
  47. }

實現Socket的回調函數，並在init方法中調用setupServer方法，代碼以下所示：

 
  1. //在init方法中調用setupServer
  2. - (instancetype)init
  3. {
  4. self = [super init];
  5. if(self){
  6. [self setupServer];
  7. }
  8. return self;
  9. }
  11. #pragma mark - 回調函數
  12. //CFSocket回調函數, 有客戶端鏈接上來時調用
  13. void AcceptCallBack(CFSocketRef s, CFSocketCallBackType type, CFDataRef address, const void *data, void *info)
  14. {
  15. NSLog(@"....");
  16. CFReadStreamRef readStream = NULL;
  17. CFWriteStreamRef writeStream = NULL;
  18. //若是回調類型是kCFSocketAcceptCallBack, data就是CFSocketNativeHandle類型的指針,指向生成的socket
  19. CFSocketNativeHandle sock = *(CFSocketNativeHandle*)data;
  20. //建立讀寫socket流 readStream, writeStream
  21. CFStreamCreatePairWithSocket(kCFAllocatorDefault, sock, &readStream, &writeStream);
  22. if(!readStream || !writeStream){
  23. NSLog(@"建立socket的讀寫流失敗.");
  24. close(sock);
  25. return;
  26. }
  28. //註冊讀寫回調函數
  29. CFStreamClientContext streamCTX = {};
  30. CFReadStreamSetClient(readStream, kCFStreamEventHasBytesAvailable, ReadStreamClientCallBack, &streamCTX);
  31. CFWriteStreamSetClient(writeStream, kCFStreamEventCanAcceptBytes, WriteStreamClientCallBack, &streamCTX);
  33. //加入循環
  34. CFReadStreamScheduleWithRunLoop(readStream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
  35. CFWriteStreamScheduleWithRunLoop(writeStream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
  37. //打開讀寫
  38. CFReadStreamOpen(readStream);
  39. CFWriteStreamOpen(writeStream);
  40. }
  42. //讀數據的回調函數, 讀取客戶端數據時調用
  43. void ReadStreamClientCallBack(CFReadStreamRef stream, CFStreamEventType type, void *clientCallBackInfo)
  44. {
  45. if(stream){
  46. UInt8 buf[1024] = {};
  47. CFReadStreamRead(stream, buf, sizeof(buf));
  48. NSLog(@"從客戶端讀到數據:%s", buf);
  49. CFReadStreamClose(stream);
  50. CFReadStreamUnscheduleFromRunLoop(stream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
  51. }
  52. }
  54. //寫數據的回調函數，向客戶端寫出數據時調
  55. void WriteStreamClientCallBack(CFWriteStreamRef stream, CFStreamEventType type, void *clientCallBackInfo)
  56. {
  57. if(stream){
  58. UInt8 buf[1024] = "嗨, 您好客戶端, 哈哈哈哈";
  59. CFWriteStreamWrite(stream, buf, strlen((const char*)buf)+1);
  60. CFWriteStreamClose(stream);
  61. CFWriteStreamUnscheduleFromRunLoop(stream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
  62. }
  65. }

而後發佈服務，將發佈服務的代碼封裝在publishService方法中，該方法中將服務添加到Runloop循環，並設置委託對象發佈服務，最後在init方法中調用該方法，代碼以下所示：

  1. - (void)publishService
  2. {
  3. //添加服務到當前的Run Loop
  4. [self.service scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSRunLoopCommonModes];
  5. //設置委託對象
  6. self.service.delegate = self;
  7. //發佈服務
  8. [self.service publish];
  9. }
  11. - (instancetype)init
  12. {
  13. self = [super init];
  14. if(self){
  15. [self setupServer];
  16. [self publishService];
  17. }
  18. return self;
  19. }

接下來實現協議方法netServiceDidPublish:，該方法在服務發佈結束後被調用，能夠經過該方法查看服務是否發佈成功，代碼以下所示：

  1. #pragma mark - NSNetServiceDelegate
  2. - (void)netServiceDidPublish:(NSNetService *)sender
  3. {
  4. NSLog(@"服務發佈結束");
  5. if([sender.name isEqualToString:@"tarena"]){
  6. // [sender getInputStream:<#(out NSInputStream *__strong *)#> outputStream:<#(out NSOutputStream *__strong *)#>];
  7. }
  8. }

最後在main函數中建立NetServiceServer實例對象，並調用CFRunLoopRun()函數，該函數能夠在當前線程啓動一個Runloop循環，使得服務器一直在運行狀態，代碼以下所示：

 
  1. int main(int argc, const char * argv[])
  2. {
  4. @autoreleasepool {
  5. NetServiceServer *server = [[NetServiceServer alloc]init];
  6. CFRunLoopRun();
  7. server = nil; 
  8. }
  9. return 0;
  10. }

運行服務器端的應用，能夠看到在控制檯輸出以下結果，如圖-3所示：

圖-3

步驟二：建立客戶端應用

建立客戶端應用NetServiceClient，使用Xcode建立一個SingleViewApplication應用，在Storyboard中搭建應用的界面，拖放兩個Button控件和一個Label控件，將Label關聯成TRViewController的輸出口屬性displayLabel，將兩個Button分別關聯成動做方法sendMessage和recvMessage，分別用於發送消息和接受消息。

完成的Storyboard界面如圖-4所示：

圖-4

接下來建立NetServiceClient客戶端類，用於發現Bonjour服務，該類有一個NSMutableArray類型的屬性services用於記錄發現的服務對象，在.h文件中該屬性是隻讀的，在.m文件中該屬性是可讀可寫的。

另外還有一個私用屬性NSNetService類型的service，用於發現解析服務，代碼以下所示：

 
  1. //NetServiceClient.h
  2. @interface NetServiceClient : NSObject
  3. //發現的全部service
  4. @property (strong, nonatomic, readonly) NSMutableArray *services;
  5. @end
  6. //NetServiceClient.m
  7. #import "NetServiceClient.h"
  8. @interface NetServiceClient () <NSNetServiceDelegate>
  9. @property (strong, nonatomic, readwrite) NSMutableArray *services;
  10. @property (strong, nonatomic) NSNetService *service;
  11. @end

在init方法中對以上兩個屬性進行初始化併發布服務，最後實現NSNetServiceDelegate協議相關方法，代碼以下所示：

 
  1. - (instancetype)init
  2. {
  3. self = [super init];
  4. if (self) {
  5. _services = [[NSMutableArray alloc]init];
  6. _service = [[NSNetService alloc]initWithDomain:@"local." type:@"_tarenaipp._tcp." name:@"tarena"];
  7. _service.delegate = self;
  8. //設置解析超時時間
  9. [_service resolveWithTimeout:1.0];
  10. }
  11. return self;
  12. }
  13. //NSNetServiceDelegate方法，解析成功調用如下方法
  14. - (void)netServiceDidResolveAddress:(NSNetService *)sender
  15. {
  16. NSLog(@"發現Bonjour服務.");
  17. [self.services addObject:sender];
  18. }
  20. //錯誤處理，解析失敗調用如下方法
  21. - (void)netService:(NSNetService *)sender didNotResolve:(NSDictionary *)errorDict
  22. {
  23. NSLog(@"%@", errorDict);
  24. }
  25. @end

而後完成ViewController類中的代碼，該類中沒有任何與服務發現相關的代碼，它從NetServiceClient類中得到輸入和輸出流對象，而後進行通訊就能夠了，所以它有一個NetServiceClient類型的屬性client。

這裏的讀寫數據流的操做一樣也是使用NSStream和CFStream類來實現。在ViewController類中定義兩個私有屬性NSInputStream類型的inputStream，以及NSOutputStream類型的outputStream，分別用於記錄輸入流和輸出流，他們分別和服務器中的輸出流CFWriteStreamRef和輸入流CFReadStreamRef對應，代碼以下所示：

 
  1. @interface TRViewController () <NSStreamDelegate>{
  2. //進行讀寫操做的標記 flag==0 寫 flag==1 讀
  3. int flag;
  4. }
  5. @property (weak, nonatomic) IBOutlet UILabel *displayLabel;
  6. @property (strong, nonatomic) NetServiceClient *client;
  7. @property (strong, nonatomic) NSInputStream *inputStream;
  8. @property (strong, nonatomic) NSOutputStream *outputStream;
  9. @end

讀寫操做代碼以下所示：

 
  1. - (void)openStream
  2. {
  3. for (NSNetService *service in self.client.services) {
  4. if ([@"tarena" isEqualToString:service.name]) {
  5. if(![service getInputStream:&_inputStream outputStream:&_outputStream]){
  6. NSLog(@"鏈接服務器失敗");
  7. return;
  8. }
  9. break;
  10. }
  11. }
  12. //使用輸入輸出流進行通訊
  13. self.inputStream.delegate = self;
  14. [self.inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
  15. [self.inputStream open];
  17. self.outputStream.delegate = self;
  18. [self.outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
  19. [self.outputStream open];
  20. }
  22. #pragma mark - NSStreamDelegate
  23. - (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode
  24. {
  25. //進行讀寫操做 flag==0 寫 flag==1 讀
  26. switch (eventCode) {
  27. case NSStreamEventNone:
  28. break;
  29. case NSStreamEventOpenCompleted:
  30. break;
  31. case NSStreamEventHasBytesAvailable://讀
  32. if(flag==1 && aStream==self.inputStream){
  33. uint8_t buffer[1024] = {};
  34. if([self.inputStream hasBytesAvailable]){
  35. int len = [self.inputStream read:buffer maxLength:sizeof(buffer)];
  36. if(len>0){
  37. NSString *string = [NSString stringWithCString:(const char*)buffer encoding:NSUTF8StringEncoding];
  38. self.displayLabel.text = [@"接收到數據:" stringByAppendingString:string];
  39. }
  40. }
  41. }
  42. break;
  43. case NSStreamEventHasSpaceAvailable:
  44. if(flag==0 && aStream==self.outputStream){
  45. UInt8 buffer[] = "Hello Server.";
  46. [self.outputStream write:buffer maxLength:strlen((const char*)buffer)+1];
  47. [self.outputStream close];
  48. }
  49. break;
  50. default:
  51. break;
  52. }
  53. }

最後實現sendMessage和recvMessage方法，更新displayLabel的顯示，代碼以下所示：

 
  1. - (IBAction)sendMessage
  2. {
  3. flag = 0;
  4. [self openStream];
  5. }
  7. - (IBAction)recvMessage:(id)sender
  8. {
  9. flag = 1;
  10. [self openStream];
  11. }

運行服務器端和客戶端程序，結果如圖-5所示：

圖-5

2.4 完整代碼

本案例中，服務器端應用中的NetServiceServer.m文件中的完整代碼以下所示：

 
  1. #import "NetServiceServer.h"
  2. #import <sys/socket.h>
  3. #import <netinet/in.h>
  4. #import <string.h>
  6. @interface NetServiceServer () <NSNetServiceDelegate>
  7. @property (strong,nonatomic)NSNetService *service;
  8. @property (nonatomic) short port;
  9. @end
  11. @implementation NetServiceServer
  12. - (instancetype)init
  13. {
  14. self = [super init];
  15. if(self){
  16. [self setupServer];
  17. [self publishService];
  18. }
  19. return self;
  20. }
  21. - (void)setupServer
  22. {
  23. CFSocketContext CTX = {};
  24. //建立Socket，其實就是指針
  25. CFSocketRef serverSocket;
  26. //設置回調函數
  27. serverSocket = CFSocketCreate(NULL, PF_INET, SOCK_STREAM, IPPROTO_TCP, kCFSocketAcceptCallBack, AcceptCallBack, &CTX);
  28. if(serverSocket == NULL){
  29. NSLog(@"socket建立失敗");
  30. return;
  31. }
  32. //設置一些socket的屬性
  33. //布爾值類型, 能夠重複使用一個已經使用過的地址和端口
  34. int yes = 1;
  35. setsockopt(CFSocketGetNative(serverSocket), SOL_SOCKET, SO_REUSEADDR, (void*)&yes, sizeof(yes));
  36. //設置地址
  37. struct sockaddr_in addr = {};
  38. //設置IPv4
  39. addr.sin_family = PF_INET;
  40. //內核分配，本機地址，htonl函數將無符號短整型數轉換成網絡字節序
  41. addr.sin_addr.s_addr = htonl(INADDR_ANY);
  42. //端口號設置爲0
  43. addr.sin_port = 0;
  44. addr.sin_len = sizeof(addr);
  46. //將struct sockaddr_in ==> CFDataRef，從指定字節緩衝區複試一個不可變的CFData對象
  47. CFDataRef address = CFDataCreate(kCFAllocatorDefault, (UInt8*)&addr, sizeof(addr));
  48. //設置Socket
  49. if(CFSocketSetAddress(serverSocket, address) != kCFSocketSuccess){
  50. NSLog(@"綁定失敗");
  51. return;
  52. }
  53. NSLog(@"綁定成功");
  55. //在Bonjour廣播時須要port
  56. NSData *socketAddressActualData = (__bridge NSData *)CFSocketCopyAddress(serverSocket);
  57. struct sockaddr_in socketAddressActual;
  58. memcpy(&socketAddressActual, [socketAddressActualData bytes], [socketAddressActualData length]);
  59. self.port = ntohs(socketAddressActual.sin_port);
  60. NSLog(@"ServerSocket監聽的端口號:%hu\n", self.port);
  62. //建立Run Loop Socket源
  63. CFRunLoopSourceRef sourceRef = CFSocketCreateRunLoopSource(kCFAllocatorDefault, serverSocket, 0);
  64. //將socket源加入到Run Loop中
  65. CFRunLoopAddSource(CFRunLoopGetCurrent(), sourceRef, kCFRunLoopCommonModes);
  66. CFRelease(sourceRef);
  68. }
  69. - (NSNetService *)service
  70. {
  71. if (!_service) {
  72. _service = [[NSNetService alloc]initWithDomain:@"local." type:@"_tarenaipp._tcp." name:@"tarena" port:self.port];
  73. }
  74. return _service;
  75. }
  77. - (void)publishService
  78. {
  79. //添加服務到當前的Run Loop
  80. [self.service scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSRunLoopCommonModes];
  81. //設置委託對象
  82. self.service.delegate = self;
  83. //發佈服務
  84. [self.service publish];
  85. }
  86. #pragma mark - NSNetServiceDelegate
  87. - (void)netServiceDidPublish:(NSNetService *)sender
  88. {
  89. NSLog(@"服務發佈結束");
  90. if([sender.name isEqualToString:@"tarena"]){
  91. // [sender getInputStream:<#(out NSInputStream *__strong *)#> outputStream:<#(out NSOutputStream *__strong *)#>];
  92. }
  93. }
  94. #pragma mark - 回調函數
  95. //CFSocket回調函數, 有客戶端鏈接上來時調用
  96. void AcceptCallBack(CFSocketRef s, CFSocketCallBackType type, CFDataRef address, const void *data, void *info)
  97. {
  98. NSLog(@"....");
  99. CFReadStreamRef readStream = NULL;
  100. CFWriteStreamRef writeStream = NULL;
  101. //若是回調類型是kCFSocketAcceptCallBack, data就是CFSocketNativeHandle類型的指針,指向生成的socket
  102. CFSocketNativeHandle sock = *(CFSocketNativeHandle*)data;
  103. //建立讀寫socket流 readStream, writeStream
  104. CFStreamCreatePairWithSocket(kCFAllocatorDefault, sock, &readStream, &writeStream);
  105. if(!readStream || !writeStream){
  106. NSLog(@"建立socket的讀寫流失敗.");
  107. close(sock);
  108. return;
  109. }
  111. //註冊讀寫回調函數
  112. CFStreamClientContext streamCTX = {};
  113. CFReadStreamSetClient(readStream, kCFStreamEventHasBytesAvailable, ReadStreamClientCallBack, &streamCTX);
  114. CFWriteStreamSetClient(writeStream, kCFStreamEventCanAcceptBytes, WriteStreamClientCallBack, &streamCTX);
  116. //加入循環
  117. CFReadStreamScheduleWithRunLoop(readStream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
  118. CFWriteStreamScheduleWithRunLoop(writeStream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
  120. //打開讀寫
  121. CFReadStreamOpen(readStream);
  122. CFWriteStreamOpen(writeStream);
  123. }
  125. //讀數據的回調函數, 讀取客戶端數據時調用
  126. void ReadStreamClientCallBack(CFReadStreamRef stream, CFStreamEventType type, void *clientCallBackInfo)
  127. {
  128. if(stream){
  129. UInt8 buf[1024] = {};
  130. CFReadStreamRead(stream, buf, sizeof(buf));
  131. NSLog(@"從客戶端讀到數據:%s", buf);
  132. CFReadStreamClose(stream);
  133. CFReadStreamUnscheduleFromRunLoop(stream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
  134. }
  135. }
  137. //寫數據的回調函數， 向客戶端寫出數據時調
  138. void WriteStreamClientCallBack(CFWriteStreamRef stream, CFStreamEventType type, void *clientCallBackInfo)
  139. {
  140. if(stream){
  141. UInt8 buf[1024] = "嗨, 您好客戶端, 哈哈哈哈";
  142. CFWriteStreamWrite(stream, buf, strlen((const char*)buf)+1);
  143. CFWriteStreamClose(stream);
  144. CFWriteStreamUnscheduleFromRunLoop(stream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
  145. }
  148. }
  149. @end
 

本案例中，服務器端應用中的main.m文件中的完整代碼以下所示：

 
  1. #import <Foundation/Foundation.h>
  2. #import "NetServiceServer.h"
  4. int main(int argc, const char * argv[])
  5. {
  7. @autoreleasepool {
  8. NetServiceServer *server = [[NetServiceServer alloc]init];
  9. CFRunLoopRun();
  10. server = nil;
  12. }
  13. return 0;
  14. }

本案例中，客戶端應用中的ViewController.m文件中的完整代碼以下所示：

 
  1. #import "TRViewController.h"
  2. #import "NetServiceClient.h"
  4. @interface TRViewController () <NSStreamDelegate>{
  5. //進行讀寫操做的標記 flag==0 寫 flag==1 讀
  6. int flag;
  7. }
  8. @property (weak, nonatomic) IBOutlet UILabel *displayLabel;
  9. @property (strong, nonatomic) NetServiceClient *client;
  10. @property (strong, nonatomic) NSInputStream *inputStream;
  11. @property (strong, nonatomic) NSOutputStream *outputStream;
  12. @end
  14. @implementation TRViewController
  16. - (NetServiceClient *)client
  17. {
  18. if(!_client)_client = [[NetServiceClient alloc]init];
  19. return _client;
  20. }
  22. - (IBAction)sendMessage
  23. {
  24. flag = 0;
  25. [self openStream];
  26. }
  28. - (IBAction)recvMessage:(id)sender
  29. {
  30. flag = 1;
  31. [self openStream];
  32. }
  34. - (void)openStream
  35. {
  36. for (NSNetService *service in self.client.services) {
  37. if ([@"tarena" isEqualToString:service.name]) {
  38. if(![service getInputStream:&_inputStream outputStream:&_outputStream]){
  39. NSLog(@"鏈接服務器失敗");
  40. return;
  41. }
  42. break;
  43. }
  44. }
  45. //使用輸入輸出流進行通訊
  46. self.inputStream.delegate = self;
  47. [self.inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
  48. [self.inputStream open];
  50. self.outputStream.delegate = self;
  51. [self.outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
  52. [self.outputStream open];
  53. }
  55. #pragma mark - NSStreamDelegate
  56. - (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode
  57. {
  58. //進行讀寫操做 flag==0 寫 flag==1 讀
  59. switch (eventCode) {
  60. case NSStreamEventNone:
  61. break;
  62. case NSStreamEventOpenCompleted:
  63. break;
  64. case NSStreamEventHasBytesAvailable://讀
  65. if(flag==1 && aStream==self.inputStream){
  66. uint8_t buffer[1024] = {};
  67. if([self.inputStream hasBytesAvailable]){
  68. int len = [self.inputStream read:buffer maxLength:sizeof(buffer)];
  69. if(len>0){
  70. NSString *string = [NSString stringWithCString:(const char*)buffer encoding:NSUTF8StringEncoding];
  71. self.displayLabel.text = [@"接收到數據:" stringByAppendingString:string];
  72. }
  73. }
  74. }
  75. break;
  76. case NSStreamEventHasSpaceAvailable:
  77. if(flag==0 && aStream==self.outputStream){
  78. UInt8 buffer[] = "Hello Server.";
  79. [self.outputStream write:buffer maxLength:strlen((const char*)buffer)+1];
  80. [self.outputStream close];
  81. }
  82. break;
  83. default:
  84. break;
  85. }
  86. }
  87. @end
 

本案例中，客戶端應用中的NetServiceClient.h文件中的完整代碼以下所示：

 
  1. #import <Foundation/Foundation.h>
  2. @interface NetServiceClient : NSObject
  3. //發現的全部service
  4. @property (strong, nonatomic, readonly) NSMutableArray *services;
  5. @end
 

本案例中，客戶端應用中的NetServiceClient.m文件中的完整代碼以下所示：

 
  1. #import "NetServiceClient.h"
  2. @interface NetServiceClient () <NSNetServiceDelegate>
  3. @property (strong, nonatomic, readwrite) NSMutableArray *services;
  4. @property (strong, nonatomic) NSNetService *service;
  5. @end
  7. @implementation NetServiceClient
  8. - (instancetype)init
  9. {
  10. self = [super init];
  11. if (self) {
  12. _services = [[NSMutableArray alloc]init];
  13. _service = [[NSNetService alloc]initWithDomain:@"local." type:@"_tarenaipp._tcp." name:@"tarena"];
  14. _service.delegate = self;
  15. //設置解析超時時間
  16. [_service resolveWithTimeout:1.0];
  17. }
  18. return self;
  19. }
  21. //NSNetServiceDelegate
  22. - (void)netServiceDidResolveAddress:(NSNetService *)sender
  23. {
  24. NSLog(@"發現Bonjour服務.");
  25. [self.services addObject:sender];
  26. }
  28. //錯誤處理
  29. - (void)netService:(NSNetService *)sender didNotResolve:(NSDictionary *)errorDict
  30. {
  31. NSLog(@"%@", errorDict);
  32. }
  33. @end
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程