最終效果隻能真機測試,是以這裡不做示範!
效果圖:
指定根視圖:
RootViewController * rootVC = [[RootViewController alloc] init];
UINavigationController * nav = [[UINavigationController alloc] initWithRootViewController:rootVC];
self.window.rootViewController= nav;
根視圖:
#import "RootViewController.h"
#import "BlueSessionManager.h"
#import "ChatCell.h"
#import "ChatItem.h"
#import <AssetsLibrary/AssetsLibrary.h>
#import <AVFoundation/AVFoundation.h>
#define kRecordAudioFile @"myRecord.caf"
// 判斷大小
#define HEIGHT [UIScreen mainScreen].bounds.size.height
#define WIDTH [UIScreen mainScreen].bounds.size.width
#define ChatHeight 45.0
@interface RootViewController ()<NSStreamDelegate,UITableViewDataSource,UITableViewDelegate,UITextViewDelegate,UIActionSheetDelegate,UIImagePickerControllerDelegate,UINavigationControllerDelegate,AVAudioRecorderDelegate,AVAudioPlayerDelegate>
{
float _sendBackViewHeight;
float _sendTextViewHeight;
UIImagePickerController * _picker;
UIView * _backRemindRecordView;
}
// DataAndBlue
@property(strong, nonatomic) BlueSessionManager *sessionManager;
@property(strong, nonatomic) NSMutableArray *datasource;
@property(strong, nonatomic) NSMutableArray * myDataArray;
@property(strong, nonatomic) NSMutableData *streamData;
@property(strong, nonatomic) NSOutputStream *outputStream;
@property(strong, nonatomic) NSInputStream *inputStream;
// UI
@property(strong, nonatomic) UITableView * tableView;
@property(strong, nonatomic) UIView * sendBackView;
@property(strong, nonatomic) UITextView * sendTextView;
@property(strong, nonatomic) UIButton * sendButton;
// 語音播放
@property (nonatomic,strong) AVAudioRecorder *audioRecorder;//音頻錄音機
//音頻播放器，用于播放錄音檔案
@property (nonatomic,strong) AVAudioPlayer *audioPlayer;
@property (nonatomic,strong) NSTimer *timer;//錄音聲波監控（注意這裡暫時不對播放進行監控）
@property (strong, nonatomic) UIProgressView *audioPower;//音頻波動
@end
@implementation RootViewController
- (void)viewDidLoad {
[super viewDidLoad];
[self makeBlueData];
[self readyUI];
[self buildVideoForWe];
// Do any additional setup after loading the view
}
#pragma mark 基本制作
- (void)readyUI
{
self.title = @"藍牙設定";
self.view.backgroundColor = [UIColor whiteColor];
self.automaticallyAdjustsScrollViewInsets = NO;
NSArray * buttonTitleArray = @[@"尋找裝置",@"打開天線"];
self.navigationItem.leftBarButtonItem = [[UIBarButtonItem alloc] initWithTitle:buttonTitleArray[] style:UIBarButtonItemStyleDone target:self action:@selector(lookOtherDevice)];
self.navigationItem.rightBarButtonItem = [[UIBarButtonItem alloc] initWithTitle:buttonTitleArray[] style:UIBarButtonItemStyleDone target:self action:@selector(showSelfAdvertiser)];
[self makeUIView];
}
- (void)lookOtherDevice
{
[self.sessionManager browseWithControllerInViewController:self connected:^{
NSLog(@"connected");
} canceled:^{
NSLog(@"cancelled");
}];
}
- (void)showSelfAdvertiser
{
[self.sessionManager advertiseForBrowserViewController];
}
#pragma mark 制作頁面UI
- (void)makeUIView
{
// NSLog(@"width === %f,height===== %f",WIDTH,HEIGHT);
self.myDataArray = [NSMutableArray arrayWithCapacity:];
self.tableView = [[UITableView alloc] initWithFrame:CGRectMake(, , WIDTH, HEIGHT - - ChatHeight - )];
self.tableView.delegate = self;
self.tableView.dataSource = self;
self.tableView.separatorStyle = UITableViewCellSelectionStyleNone;
[self.view addSubview:self.tableView];
//-------------------------------------------------------------------------//
self.sendBackView = [[UIView alloc] initWithFrame:CGRectMake(, HEIGHT - ChatHeight, WIDTH, ChatHeight)];
self.sendBackView.backgroundColor = [UIColor colorWithRed:/ green:/ blue:/ alpha:];
[self.view addSubview:self.sendBackView];
// float heightView = self.sendBackView.frame.size.height;
self.sendTextView = [[UITextView alloc] initWithFrame:CGRectMake(, , WIDTH - - , )];
// self.sendTextView.backgroundColor = [UIColor lightGrayColor];
self.sendTextView.returnKeyType = UIReturnKeySend;
self.sendTextView.font = [UIFont systemFontOfSize:];
self.sendTextView.editable = YES;
self.sendTextView.delegate = self;
[self.sendBackView addSubview:self.sendTextView];
UIButton * addButton = [UIButton buttonWithType:UIButtonTypeContactAdd];
addButton.frame = CGRectMake(WIDTH - , , , );
[addButton addTarget:self action:@selector(addNextImage) forControlEvents:UIControlEventTouchUpInside];
[self.sendBackView addSubview:addButton];
self.sendButton = [UIButton buttonWithType:UIButtonTypeCustom];
self.sendButton.frame = CGRectMake(WIDTH - , , , );
[self.sendButton setImage:[UIImage imageNamed:@"record.png"] forState:UIControlStateNormal];
[self.sendButton addTarget:self action:@selector(videoRecord) forControlEvents:UIControlEventTouchUpInside];
[self.sendBackView addSubview:self.sendButton];
// 增加通知
[self addTheNoticeForKeyDownUp];
}
#pragma mark 圖檔的傳輸---------///
- (void)addNextImage
{
UIActionSheet *chooseImageSheet = [[UIActionSheet alloc] initWithTitle:nil delegate:self cancelButtonTitle:@"取消" destructiveButtonTitle:nil otherButtonTitles:@"照相機",@"相冊", nil nil];
[chooseImageSheet showInView:self.view];
}
#pragma mark UIActionSheetDelegate Method
-(void)actionSheet:(UIActionSheet *)actionSheet clickedButtonAtIndex:(NSInteger)buttonIndex
{
_picker = [[UIImagePickerController alloc] init];
_picker.delegate = self;
switch (buttonIndex) {
case ://Take picture
if ([UIImagePickerController isSourceTypeAvailable:UIImagePickerControllerSourceTypeCamera])
{
_picker.sourceType = UIImagePickerControllerSourceTypeCamera;
}
[self presentViewController:_picker animated:NO completion:nil];
break;
case :
//From album
_picker.sourceType = UIImagePickerControllerSourceTypePhotoLibrary;
[self presentViewController:_picker animated:NO completion:^{
// 改變狀态欄的顔色 為正常 這是這個獨有的地方需要處理的
[[UIApplication sharedApplication] setStatusBarStyle:UIStatusBarStyleDefault];
}];
break;
default:
break;
}
}
// 相冊
-(void)imagePickerController:(UIImagePickerController *)picker didFinishPickingMediaWithInfo:(NSDictionary *)info
{
NSString *type = [info objectForKey:UIImagePickerControllerMediaType];
//當選擇的類型是圖檔
if ([type isEqualToString:@"public.image"])
{
//先把圖檔轉成NSData
UIImage* image = [info objectForKey:UIImagePickerControllerOriginalImage];
NSData *data;
if (UIImagePNGRepresentation(image) == nil)
{
data = UIImageJPEGRepresentation(image, );
}
else
{
data = UIImagePNGRepresentation(image);
}
//圖檔儲存的路徑
//這裡将圖檔放在沙盒的documents檔案夾中
NSString * DocumentsPath = [NSHomeDirectory() stringByAppendingPathComponent:@"Documents"];
//檔案管理器
NSFileManager *fileManager = [NSFileManager defaultManager];
//把剛剛圖檔轉換的data對象拷貝至沙盒中 并儲存為image.png
[fileManager createDirectoryAtPath:DocumentsPath withIntermediateDirectories:YES attributes:nil error:nil];
[fileManager createFileAtPath:[DocumentsPath stringByAppendingString:@"/image.png"] contents:data attributes:nil];
//得到選擇後沙盒中圖檔的完整路徑
NSString * filePath = [[NSString alloc]initWithFormat:@"%@%@",DocumentsPath, @"/image.png"];
[_picker dismissViewControllerAnimated:NO completion:^{
// 改變狀态欄的顔色 改變為白色
[[UIApplication sharedApplication] setStatusBarStyle:UIStatusBarStyleLightContent];
// 這邊是真正的發送
if(!self.sessionManager.isConnected)
{
UIAlertView *alertView = [[UIAlertView alloc]initWithTitle:@"藍牙已經斷開了，請重新連接配接！" message:nil delegate:nil cancelButtonTitle:nil otherButtonTitles:@"知道了", nil nil];
[alertView show];
return;
}
ChatItem * chatItem = [[ChatItem alloc] init];
chatItem.isSelf = YES;
chatItem.states = picStates;
chatItem.picImage = image;
[self.datasource addObject:chatItem];
[self insertTheTableToButtom];
[self sendAsResource:filePath];
}];
}
}
- (void)sendAsResource:(NSString *)path
{
NSLog(@"dispaly ====%@",self.sessionManager.firstPeer.displayName);
NSString * name = [NSString stringWithFormat:@"%@ForPic",[[UIDevice currentDevice] name]];
NSURL * url = [NSURL fileURLWithPath:path];
NSProgress *progress = [self.sessionManager sendResourceWithName:name atURL:url toPeer:self.sessionManager.firstPeer complete:^(NSError *error) {
if(!error) {
NSLog(@"finished sending resource");
}
else {
NSLog(@"%@", error);
}
}];
NSLog(@"%@", @(progress.fractionCompleted));
}
#pragma mark 普通資料的傳輸
- (void)sendWeNeedNews
{
if(!self.sessionManager.isConnected)
{
UIAlertView *alertView = [[UIAlertView alloc]initWithTitle:@"藍牙已經斷開了，請重新連接配接！" message:nil delegate:nil cancelButtonTitle:nil otherButtonTitles:@"知道了", nil nil];
[alertView show];
return;
}
if([self.sendTextView.text isEqualToString:@""])
{
return;
}
ChatItem * chatItem = [[ChatItem alloc] init];
chatItem.isSelf = YES;
chatItem.states = textStates;
chatItem.content = self.sendTextView.text;
[self.datasource addObject:chatItem];
// 加到數組裡面
// 添加行 indexPath描述位置的具體資訊
[self insertTheTableToButtom];
NSData *data = [NSKeyedArchiver archivedDataWithRootObject:self.sendTextView.text];
NSError *error = [self.sessionManager sendDataToAllPeers:data];
if(!error) {
//there was no error.
}
else {
NSLog(@"%@", error);
}
[self returnTheNewBack];
}
- (void)returnTheNewBack
{
// 歸零
self.sendTextView.text = @"";
[self.sendTextView resignFirstResponder];
self.tableView.frame = CGRectMake(, , WIDTH, HEIGHT - - ChatHeight - );
self.sendBackView.frame = CGRectMake(, HEIGHT - ChatHeight , WIDTH, ChatHeight);
}
// 這是一種很好的鍵盤下移方式
-(BOOL)textView:(UITextView *)textView shouldChangeTextInRange:(NSRange)range replacementText:(NSString *)text
{
if ([text isEqualToString:@"\n"]) {
[self sendWeNeedNews];
return NO;
}
return YES;
}
- (void)textViewDidChange:(UITextView *)textView
{
// 随機改變其高度
float textHeight = [self heightForString:textView.text fontSize: andWidth:textView.frame.size.width];
_sendTextViewHeight = textHeight;
// NSLog(@"teztheight ===== %f",textHeight);
self.sendTextView.frame = CGRectMake(, , WIDTH - - , _sendTextViewHeight);
self.sendBackView.frame = CGRectMake(, HEIGHT - _sendBackViewHeight - _sendTextViewHeight - , WIDTH, _sendTextViewHeight + );
}
- (float) heightForString:(NSString *)value fontSize:(float)fontSize andWidth:(float)width
{
UITextView *detailTextView = [[UITextView alloc]initWithFrame:CGRectMake(, , width, )];
detailTextView.font = [UIFont systemFontOfSize:fontSize];
detailTextView.text = value;
CGSize deSize = [detailTextView sizeThatFits:CGSizeMake(width,CGFLOAT_MAX)];
return deSize.height;
}
#pragma mark 以下是為了配合 鍵盤上移的變化
- (void)addTheNoticeForKeyDownUp
{
[ [NSNotificationCenter defaultCenter] addObserver:self selector:@selector(handleKeyBoardDidShow:) name:UIKeyboardDidShowNotification object:nil];
[ [NSNotificationCenter defaultCenter] addObserver:self selector:@selector(handleKeyboardWillHide:) name:UIKeyboardWillHideNotification object:nil];
}
- (void)dealloc
{
[[NSNotificationCenter defaultCenter] removeObserver:self];
}
-(void)handleKeyBoardDidShow:(NSNotification *)paramNotification
{
CGSize size = [[paramNotification.userInfo objectForKey:UIKeyboardFrameEndUserInfoKey] CGRectValue].size;
_sendBackViewHeight = size.height;
[UIView animateWithDuration: animations:^{
self.tableView.frame = CGRectMake(, , WIDTH, HEIGHT - - ChatHeight - size.height);
self.sendBackView.frame = CGRectMake(, HEIGHT - ChatHeight - size.height, WIDTH, ChatHeight);
}];
}
-(void)handleKeyboardWillHide:(NSNotification *)paramNotification
{
[UIView animateWithDuration: animations:^{
if(_sendTextViewHeight > )
{
self.tableView.frame = CGRectMake(, , WIDTH, HEIGHT - - _sendTextViewHeight + );
self.sendBackView.frame = CGRectMake(, HEIGHT - _sendTextViewHeight - , WIDTH, _sendTextViewHeight + );
}
else
{
self.tableView.frame = CGRectMake(, , WIDTH, HEIGHT - - ChatHeight - );
self.sendBackView.frame = CGRectMake(, HEIGHT - ChatHeight , WIDTH, ChatHeight);
}
}];
}
/*--------------------------------------------------------------------------------------------*/
- (void)insertTheTableToButtom
{
// 哪一組 哪一段
NSIndexPath * indexPath = [NSIndexPath indexPathForRow:self.datasource.count- inSection:];
// 添加新的一行
[self.tableView insertRowsAtIndexPaths:@[indexPath] withRowAnimation:UITableViewRowAnimationFade];
// 滑動到底部 第二個參數是滑動到底部
[self.tableView scrollToRowAtIndexPath:indexPath atScrollPosition:UITableViewScrollPositionBottom animated:YES];
}
#pragma mark tableView 代理
- (NSInteger)numberOfSectionsInTableView:(UITableView *)tableView {
return ;
}
- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {
return self.datasource.count;
}
-(CGFloat)tableView:(UITableView *)tableView heightForRowAtIndexPath:(NSIndexPath *)indexPath
{
ChatItem * chatItem = [self.datasource objectAtIndex:indexPath.row];
if(chatItem.states == picStates)
{
NSLog(@"widht====%f,height======%f",chatItem.picImage.size.width,chatItem.picImage.size.height);
return ;
}
else if(chatItem.states == textStates)
{
CGSize size = [chatItem.content boundingRectWithSize:CGSizeMake(, ) options:NSStringDrawingTruncatesLastVisibleLine | NSStringDrawingUsesLineFragmentOrigin | NSStringDrawingUsesFontLeading attributes:@{NSFontAttributeName :[UIFont systemFontOfSize:]} context:nil].size;
return size.height + + ; // 與view的距離 ＋ 與Cell的距離
}
else
{
return ;
}
}
- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath
{
static NSString * iden = @"iden";
ChatCell * cell = [tableView dequeueReusableCellWithIdentifier:iden];
if(cell == nil)
{
cell = [[ChatCell alloc] initWithStyle:UITableViewCellStyleDefault reuseIdentifier:iden];
cell.selectionStyle = UITableViewCellSelectionStyleNone;
// 讓後面選中的沒有陰影效果
}
// 模型
ChatItem * chatItem = [self.datasource objectAtIndex:indexPath.row];
CGSize size = [chatItem.content boundingRectWithSize:CGSizeMake(, ) options:NSStringDrawingTruncatesLastVisibleLine | NSStringDrawingUsesLineFragmentOrigin | NSStringDrawingUsesFontLeading attributes:@{NSFontAttributeName :[UIFont systemFontOfSize:]} context:nil].size;
//如果自己發的
if(chatItem.isSelf)
{
cell.leftHeadImage.hidden = YES;
cell.rightHeadImage.hidden = NO;
if(chatItem.states == picStates)
{
cell.lefeView.hidden = YES;
cell.rightView.hidden = YES;
cell.rightPicImage.image = chatItem.picImage;
cell.leftPicImage.hidden = YES;
cell.rightPicImage.hidden = NO;
cell.leftVideoButton.hidden = YES;
cell.rightVideoButton.hidden = YES;
NSLog(@"self send");
}
else if(chatItem.states == textStates)
{
cell.rightPicImage.hidden = YES;
cell.leftPicImage.hidden = YES;
cell.lefeView.hidden = YES;
cell.rightView.hidden = NO;
cell.leftVideoButton.hidden = YES;
cell.rightVideoButton.hidden = YES;
// 複用機制
cell.rightLabel.frame = CGRectMake(, , size.width, size.height);
cell.rightView.frame = CGRectMake(WIDTH - -size.width-, , size.width + , size.height + );
cell.rightLabel.text = chatItem.content;
}
else
{
cell.rightView.hidden = YES;
cell.lefeView.hidden = YES;
cell.rightView.hidden = YES;
cell.lefeView.hidden = YES;
cell.leftVideoButton.hidden = YES;
cell.rightVideoButton.hidden = NO;
cell.rightVideoButton.tag = + indexPath.row;
[cell.rightVideoButton addTarget:self action:@selector(cellSelectIndex:) forControlEvents:UIControlEventTouchUpInside];
[cell.rightVideoButton setImage:[UIImage imageNamed:@"record.png"] forState:UIControlStateNormal];
}
}
else // 接受得到
{
cell.leftHeadImage.hidden = NO;
cell.rightHeadImage.hidden = YES;
if(chatItem.states == picStates)
{
cell.rightView.hidden = YES;
cell.lefeView.hidden = YES;
cell.leftVideoButton.hidden = YES;
cell.rightVideoButton.hidden = YES;
cell.leftPicImage.image = chatItem.picImage;
cell.rightPicImage.hidden = YES;
cell.leftPicImage.hidden = NO;
}
else if(chatItem.states == textStates)
{
cell.rightPicImage.hidden = YES;
cell.leftPicImage.hidden = YES;
cell.rightView.hidden = YES;
cell.lefeView.hidden = NO;
cell.leftVideoButton.hidden = YES;
cell.rightVideoButton.hidden = YES;
cell.leftLabel.frame = CGRectMake(, , size.width, size.height);
cell.lefeView.frame = CGRectMake(, , size.width +, size.height + );
cell.leftLabel.text = chatItem.content;
}
else
{
cell.rightView.hidden = YES;
cell.lefeView.hidden = YES;
cell.rightView.hidden = YES;
cell.lefeView.hidden = YES;
cell.leftVideoButton.hidden = NO;
cell.rightVideoButton.hidden = YES;
cell.leftVideoButton.tag = + indexPath.row;
[cell.leftVideoButton setImage:[UIImage imageNamed:@"record.png"] forState:UIControlStateNormal];
[cell.leftVideoButton addTarget:self action:@selector(cellSelectIndex:) forControlEvents:UIControlEventTouchUpInside];
}
}
return cell;
}
- (void)cellSelectIndex:(UIButton *)cellBtn
{
ChatItem *chatIden = [self.datasource objectAtIndex:cellBtn.tag - ];
if(chatIden.states == videoStates)
{
NSLog(@"realy play");
// [self makeVideoPlayer:[self getVideoStremData]];
[self makeVideoPlayer:chatIden.recordData];
}
}
#pragma mark 下面是核心的連接配接MCSession 和 資料傳回的地方
/***************************-------**********************************************/
- (void)makeBlueData
{
// 這是為了讓 在block中弱引用
__weak typeof (self) weakSelf = self;
self.datasource = [NSMutableArray arrayWithCapacity:];
// 初始化 會議室
self.sessionManager = [[BlueSessionManager alloc]initWithDisplayName:[NSString stringWithFormat:@" %@", [[UIDevice currentDevice] name]]];
//
[self.sessionManager didReceiveInvitationFromPeer:^void(MCPeerID *peer, NSData *context) {
__strong typeof (weakSelf) strongSelf = weakSelf;
UIAlertView *alertView = [[UIAlertView alloc]initWithTitle:@"是否連接配接？" message:[NSString stringWithFormat:@"同 %@%@", peer.displayName, @" 連接配接?"] delegate:strongSelf cancelButtonTitle:@"取消" otherButtonTitles:@"确定", nil nil];
[alertView show];
}];
[self.sessionManager peerConnectionStatusOnMainQueue:YES block:^(MCPeerID *peer, MCSessionState state) {
if(state == MCSessionStateConnected) {
UIAlertView *alertView = [[UIAlertView alloc]initWithTitle:@"已經連接配接" message:[NSString stringWithFormat:@"現在連接配接 %@了！", peer.displayName] delegate:nil cancelButtonTitle:nil otherButtonTitles:@"知道了", nil nil];
[alertView show];
}
}];
// 發正常資料的傳回
[self.sessionManager receiveDataOnMainQueue:YES block:^(NSData *data, MCPeerID *peer) {
__strong typeof (weakSelf) strongSelf = weakSelf;
NSString *string = [NSKeyedUnarchiver unarchiveObjectWithData:data];
ChatItem * chatItem = [[ChatItem alloc] init];
chatItem.isSelf = NO;
chatItem.states = textStates;
chatItem.content = string;
[strongSelf.datasource addObject:chatItem];
// 加到數組裡面
[strongSelf insertTheTableToButtom];
}];
// 發圖檔之後的傳回
[self.sessionManager receiveFinalResourceOnMainQueue:YES complete:^(NSString *name, MCPeerID *peer, NSURL *url, NSError *error) {
__strong typeof (weakSelf) strongSelf = weakSelf;
NSData *data = [NSData dataWithContentsOfURL:url];
ChatItem * chatItem = [[ChatItem alloc] init];
chatItem.isSelf = NO;
chatItem.states = picStates;
chatItem.content = name;
chatItem.picImage = [UIImage imageWithData:data];
[strongSelf.datasource addObject:chatItem];
[strongSelf insertTheTableToButtom];
}];
// 流
[self.sessionManager didReceiveStreamFromPeer:^(NSInputStream *stream, MCPeerID *peer, NSString *streamName) {
__strong typeof (weakSelf) strongSelf = weakSelf;
strongSelf.inputStream = stream;
strongSelf.inputStream.delegate = self;
[strongSelf.inputStream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
[strongSelf.inputStream open];
NSLog(@"we need");
}];
}
- (void)alertView:(UIAlertView *)alertView clickedButtonAtIndex:(NSInteger)buttonIndex
{
[self.sessionManager connectToPeer:buttonIndex == ];
}
#pragma mark 下面是流的傳輸
/***********--------------------- 下面是流的傳輸 ------------------------***********************************/
- (void)videoRecord
{
// 播放錄音
[self SetTempRecordView];
}
- (void)sendAsStream
{
if(!self.sessionManager.isConnected)
{
UIAlertView *alertView = [[UIAlertView alloc]initWithTitle:@"藍牙已經斷開了，請重新連接配接！" message:nil delegate:nil cancelButtonTitle:nil otherButtonTitles:@"知道了", nil nil];
[alertView show];
return;
}
NSError *err;
self.outputStream = [self.sessionManager streamWithName:@"super stream" toPeer:self.sessionManager.firstPeer error:&err];
self.outputStream.delegate = self;
[self.outputStream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
if(err || !self.outputStream) {
NSLog(@"%@", err);
}
else
{
[self.outputStream open];
}
}
// 下面是一個代理
- (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode
{
if(eventCode == NSStreamEventHasBytesAvailable)
{
// 有可讀的位元組，接收到了資料
NSInputStream *input = (NSInputStream *)aStream;
uint8_t buffer[];
NSInteger length = [input read:buffer maxLength:];
[self.streamData appendBytes:(const voidvoid *)buffer length:(NSUInteger)length];
// 記住這邊的資料陸陸續續的
}
else if(eventCode == NSStreamEventHasSpaceAvailable)
{
// 可以使用輸出流的空間，此時可以發送資料給伺服器
// 發送資料的
NSData *data = [self getVideoStremData];
ChatItem * chatItem = [[ChatItem alloc] init];
chatItem.isSelf = YES;
chatItem.states = videoStates;
chatItem.recordData = data;
[self.datasource addObject:chatItem];
[self insertTheTableToButtom];
NSOutputStream *output = (NSOutputStream *)aStream;
[output write:data.bytes maxLength:data.length];
[output close];
}
if(eventCode == NSStreamEventEndEncountered)
{
// 流結束事件，在此事件中負責做銷毀工作
// 同時也是獲得最終資料的好地方
ChatItem * chatItem = [[ChatItem alloc] init];
chatItem.isSelf = NO;
chatItem.states = videoStates;
chatItem.recordData = self.streamData;
[self.datasource addObject:chatItem];
[self insertTheTableToButtom];
[aStream close];
[aStream removeFromRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
if([aStream isKindOfClass:[NSInputStream class]])
{
self.streamData = nil;
}
}
if(eventCode == NSStreamEventErrorOccurred)
{
// 發生錯誤
NSLog(@"error");
}
}
- (NSMutableData *)streamData
{
if(!_streamData) {
_streamData = [NSMutableData data];
}
return _streamData;
}
/***********----------------------- 公用的資料 --------------------***********************************/
- (NSData *)imageData
{
return [NSData dataWithContentsOfURL:[self imageURL]];
}
- (NSURL *)imageURL {
NSString *path = [[NSBundle mainBundle]pathForResource:@"[email protected]" ofType:@"png"];
// 這兒有個技術點
// 那個如何将 image轉化成 路徑
NSURL *url = [NSURL fileURLWithPath:path];
return url;
}
/***********----------------------------------------------***********************************/
#pragma mark 嘗試空白處的連接配接
- (void)touchesBegan:(NSSet *)touches withEvent:(UIEvent *)event
{
UITouch * touch = [[event allTouches] anyObject];
if(touch.tapCount >= )
{
[self.sendTextView resignFirstResponder];
}
}
/***********-------------------語音---------------------------***********************************/
#pragma mark 嘗試語音的錄制和播出
- (void)buildVideoForWe
{
// 設定錄音會話
[self setAudioSession];
}
- (void)SetTempRecordView
{
_backRemindRecordView = [[UIView alloc] initWithFrame:CGRectMake(, , WIDTH, )];
_backRemindRecordView.center = self.view.center;
_backRemindRecordView.backgroundColor = [UIColor lightGrayColor];
[self.view addSubview:_backRemindRecordView];
UILabel * beginLabel = [[UILabel alloc] initWithFrame:CGRectMake(, , WIDTH -, )];
beginLabel.backgroundColor = [UIColor greenColor];
beginLabel.text = @"長按錄音開始···";
beginLabel.tag = ;
beginLabel.textAlignment = NSTextAlignmentCenter;
beginLabel.userInteractionEnabled = YES;
[_backRemindRecordView addSubview:beginLabel];
UILongPressGestureRecognizer * longPress = [[UILongPressGestureRecognizer alloc] initWithTarget:self action:@selector(longPressNextDo:)];
[beginLabel addGestureRecognizer:longPress];
}
- (void)longPressNextDo:(UILongPressGestureRecognizer * )longPress
{
if(longPress.state == UIGestureRecognizerStateBegan)
{
NSLog(@"begin");
UILabel * label = (UILabel *)[_backRemindRecordView viewWithTag:];
label.text = @"錄音正在進行中···";
label.backgroundColor = [UIColor orangeColor];
[self BeginRecordClick];
}
if(longPress.state == UIGestureRecognizerStateEnded)
{
[self OkStopClick];
[_backRemindRecordView removeFromSuperview];
[self sendAsStream];
NSLog(@"stop");
}
}
#pragma mark - 私有方法
/**
* 設定音頻會話
*/
-(void)setAudioSession
{
AVAudioSession *audioSession=[AVAudioSession sharedInstance];
//設定為播放和錄音狀态，以便可以在錄制完之後播放錄音
[audioSession setCategory:AVAudioSessionCategoryPlayAndRecord error:nil];
[audioSession setActive:YES error:nil];
}
/**
* 取得錄音檔案儲存路徑
*
* @return 錄音檔案路徑
*/
-(NSURL *)getSavePath
{
NSString *urlStr=[NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) lastObject];
urlStr=[urlStr stringByAppendingPathComponent:kRecordAudioFile];
NSLog(@"file path:%@",urlStr);
NSURL *url=[NSURL fileURLWithPath:urlStr];
return url;
}
- (NSData *)getVideoStremData
{
return [NSData dataWithContentsOfURL:[self getSavePath]];
}
/**
* 取得錄音檔案設定
*
* @return 錄音設定
*/
-(NSDictionary *)getAudioSetting{
NSMutableDictionary *dicM=[NSMutableDictionary dictionary];
//設定錄音格式
[dicM setObject:@(kAudioFormatLinearPCM) forKey:AVFormatIDKey];
//設定錄音采樣率，8000是電話采樣率，對于一般錄音已經夠了
[dicM setObject:@() forKey:AVSampleRateKey];
//設定通道,這裡采用單聲道
[dicM setObject:@() forKey:AVNumberOfChannelsKey];
//每個采樣點位數,分為8、16、24、32
[dicM setObject:@() forKey:AVLinearPCMBitDepthKey];
//是否使用浮點數采樣
[dicM setObject:@(YES) forKey:AVLinearPCMIsFloatKey];
//....其他設定等
return dicM;
}
/**
* 獲得錄音機對象
*
* @return 錄音機對象
*/
-(AVAudioRecorder *)audioRecorder
{
if (!_audioRecorder) {
//建立錄音檔案儲存路徑
NSURL *url=[self getSavePath];
//建立錄音格式設定
NSDictionary *setting=[self getAudioSetting];
//建立錄音機
NSError *error=nil;
_audioRecorder=[[AVAudioRecorder alloc]initWithURL:url settings:setting error:&error];
_audioRecorder.delegate=self;
_audioRecorder.meteringEnabled=YES;//如果要監控聲波則必須設定為YES
if (error) {
NSLog(@"建立錄音機對象時發生錯誤，錯誤資訊：%@",error.localizedDescription);
return nil;
}
}
return _audioRecorder;
}
/**
* 建立播放器
*
* @return 播放器
*/
- (void)makeVideoPlayer:(NSData *)data
{
NSError *error=nil;
self.audioPlayer=[[AVAudioPlayer alloc]initWithData:data error:&error];
self.audioPlayer.delegate = self;
self.audioPlayer.numberOfLoops=;
[self.audioPlayer prepareToPlay];
if (error)
{
NSLog(@"建立播放器過程中發生錯誤，錯誤資訊：%@",error.localizedDescription);
}
else
{
if (![self.audioPlayer isPlaying]) {
NSLog(@"play");
[self.audioPlayer play];
}
}
}
/**
* 錄音聲波監控定制器
*
* @return 定時器
*/
-(NSTimer *)timer{
if (!_timer) {
_timer=[NSTimer scheduledTimerWithTimeInterval:f target:self selector:@selector(audioPowerChange) userInfo:nil repeats:YES];
}
return _timer;
}
/**
* 錄音聲波狀态設定
*/
-(void)audioPowerChange{
[self.audioRecorder updateMeters];//更新測量值
float power= [self.audioRecorder averagePowerForChannel:];//取得第一個通道的音頻，注意音頻強度範圍時-160到0
CGFloat progress=(/)*(power+);
[self.audioPower setProgress:progress];
}
#pragma mark - UI事件
/**
* 點選錄音按鈕
*
* @param sender 錄音按鈕
*/
- (void)BeginRecordClick
{
if (![self.audioRecorder isRecording])
{
[self.audioRecorder record];//首次使用應用時如果調用record方法會詢問使用者是否允許使用麥克風
self.timer.fireDate=[NSDate distantPast];
}
}
/**
* 點選暫定按鈕
*
* @param sender 暫停按鈕
*/
- (void)StopPauseClick
{
if ([self.audioRecorder isRecording]) {
[self.audioRecorder pause];
self.timer.fireDate=[NSDate distantFuture];
}
}
/**
* 點選停止按鈕
*
* @param sender 停止按鈕
*/
- (void)OkStopClick
{
[self.audioRecorder stop];
self.timer.fireDate=[NSDate distantFuture];
self.audioPower.progress=;
}
#pragma mark - 錄音機代理方法
/**
* 錄音完成，錄音完成後播放錄音
*
* @param recorder 錄音機對象
* @param flag 是否成功
*/
-(void)audioRecorderDidFinishRecording:(AVAudioRecorder *)recorder successfully:(BOOL)flag
{
// if (![self.audioPlayer isPlaying]) {
// [self.audioPlayer play];
// }
NSLog(@"錄音完成!");
}
- (void)audioPlayerDidFinishPlaying:(AVAudioPlayer *)player successfully:(BOOL)flag
{
// 每次完成後都将這個對象釋放
player =nil;
}
建一個model類:
.h
#import <UIKit/UIKit.h>
//@protocol CellSelectIndex <NSObject>
//
//- (void)cellSelectIndex;
//
//@end
@interface ChatCell : UITableViewCell
@property(nonatomic,strong)UIImageView * lefeView;
@property(nonatomic,strong)UIImageView * rightView;
@property(nonatomic,strong)UILabel * leftLabel;
@property(nonatomic,strong)UILabel * rightLabel;
@property(nonatomic,strong)UIImageView * leftHeadImage;
@property(nonatomic,strong)UIImageView * rightHeadImage;
@property(nonatomic,strong)UIImageView * leftPicImage;
@property(nonatomic,strong)UIImageView * rightPicImage;
@property(nonatomic ,strong)UIButton * leftVideoButton;
@property(nonatomic, strong)UIButton * rightVideoButton;
//@property(nonatomic,weak)id <CellSelectIndex> delegate;
// 不能用名字相同的屬性
// 記住自動的時候，講一下 weak and strong
@end
.m
#import "ChatCell.h"
@implementation ChatCell
- (id)initWithStyle:(UITableViewCellStyle)style reuseIdentifier:(NSString *)reuseIdentifier
{
self = [super initWithStyle:style reuseIdentifier:reuseIdentifier];
if (self) {
// Initialization code
[self makeView];
}
return self;
}
-(void)makeView
{
UIImage * leftImgae = [UIImage imageNamed:@"ReceiverTextNodeBkg.png"];
UIImage * rightImage = [UIImage imageNamed:@"SenderTextNodeBkg.png"];
//這裡設定一行一像素 當圖檔拉伸的時候，隻放大兩個像素
leftImgae = [leftImgae stretchableImageWithLeftCapWidth: topCapHeight:];
// 找一行一列的像素
rightImage = [rightImage stretchableImageWithLeftCapWidth: topCapHeight:];
// 設定完了後生成了一個新的image;
//----------------------------------------------------------------------------------------//
// 左邊頭像
self.leftHeadImage = [[UIImageView alloc] initWithFrame:CGRectMake(, , , )];
self.leftHeadImage.layer.masksToBounds = YES;
self.leftHeadImage.layer.cornerRadius = ;
self.leftHeadImage.image = [UIImage imageNamed:@"f-pCert.png"];
[self.contentView addSubview:self.leftHeadImage];
//左邊氣泡
self.leftVideoButton = [UIButton buttonWithType:UIButtonTypeCustom];
self.leftVideoButton.frame = CGRectMake(, , , );
// [self.leftVideoButton addTarget:self action:@selector(recordTheVoice) forControlEvents:UIControlEventTouchUpInside];
[self.contentView addSubview:self.leftVideoButton];
self.leftPicImage = [[UIImageView alloc] initWithFrame:CGRectMake(, , , )];
[self.contentView addSubview:self.leftPicImage];
self.lefeView = [[UIImageView alloc] initWithFrame:CGRectMake(, , , )];
self.lefeView.image = leftImgae;
// 這裡不是一個小像素的圖檔？？
[self.contentView addSubview:self.lefeView];
self.leftLabel = [[UILabel alloc] initWithFrame:CGRectMake(, , , )];
self.leftLabel.font = [UIFont systemFontOfSize:];
self.leftLabel.numberOfLines = ; // 換行
self.leftLabel.backgroundColor = [UIColor clearColor];// 設定透明的
[self.lefeView addSubview:self.leftLabel];
//----------------------------------------------------------------------------------------//
self.rightHeadImage = [[UIImageView alloc] initWithFrame:CGRectMake(self.frame.size.width - , , , )];
self.rightHeadImage.layer.masksToBounds = YES;
self.rightHeadImage.layer.cornerRadius = ;
self.rightHeadImage.image = [UIImage imageNamed:@"f-plove.png"];
[self.contentView addSubview:self.rightHeadImage];
self.rightVideoButton = [UIButton buttonWithType:UIButtonTypeCustom];
self.rightVideoButton.frame = CGRectMake(self.frame.size.width - - , , , );
// [self.rightVideoButton addTarget:self action:@selector(recordTheVoice) forControlEvents:UIControlEventTouchUpInside];
[self.contentView addSubview:self.rightVideoButton];
self.rightPicImage = [[UIImageView alloc] initWithFrame:CGRectMake(self.frame.size.width - - , , , )];
[self.contentView addSubview:self.rightPicImage];
// 右邊
self.rightView = [[UIImageView alloc] initWithFrame:CGRectMake(self.frame.size.width - (+), , , )];
self.rightView.image = rightImage;
[self.contentView addSubview:self.rightView];
self.rightLabel = [[UILabel alloc] initWithFrame:CGRectMake(, , , )];
self.rightLabel.font = [UIFont systemFontOfSize:];
self.rightLabel.backgroundColor = [UIColor clearColor];
self.rightLabel.numberOfLines = ;
[self.rightView addSubview:self.rightLabel];
}
//- (void)recordTheVoice
//{
// [self.delegate cellSelectIndex];
//}
基本知識必須了解的
MCAdvertiserAssistant //可以接收，并處理使用者請求連接配接的響應。沒有回調，會彈出預設的提示框，并處理連接配接。
MCNearbyServiceAdvertiser //可以接收，并處理使用者請求連接配接的響應。但是，這個類會有回調，告知有使用者要與您的裝置連接配接，然後可以自定義提示框，以及自定義連接配接處理。
MCNearbyServiceBrowser //用于搜尋附近的使用者，并可以對搜尋到的使用者發出邀請加入某個會話中。
MCPeerID //這表明是一個使用者
MCSession //啟用和管理Multipeer連接配接會話中的所有人之間的溝通。 通過Sesion，給别人發送資料。
建一個類用來寫所有方法:
.h
#import <Foundation/Foundation.h>
@import MultipeerConnectivity;
@interface BlueSessionManager : NSObject
@property(strong, nonatomic, readonly) NSArray *connectedPeers;
@property(strong, nonatomic, readonly) MCSession *session;
@property(nonatomic, readonly, getter = isConnected) BOOL connected;
@property(strong, nonatomic) NSDictionary *discoveryInfo; // 發現裝置的特征
@property(strong, nonatomic, readonly) MCPeerID *firstPeer; // 第一個連接配接的 使用者
/**
* The service type provided for browsing and advertising.
* This should be a short text string that describes the
* app's networking protocol. Should be something
* in the form of `tjl_appname`.
*/
@property(strong, nonatomic) NSString *serviceType;
/*
初始化一個 假設的使用者名字
*/
- (instancetype)__attribute__((nonnull()))initWithDisplayName:(NSString *)displayName;
- (void)browseForProgrammaticDiscovery;
- (void)advertiseForBrowserViewController;
- (void)advertiseForProgrammaticDiscovery;
- (void)didReceiveInvitationFromPeer:(void (^)(MCPeerID *peer, NSData *context))invite;
- (NSError *)sendDataToAllPeers:(NSData *)data;
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers;
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers withMode:(MCSessionSendDataMode)mode;
- (void)receiveDataOnMainQueue:(BOOL)mainQueue block:(void (^)(NSData *data, MCPeerID *peer))dataBlock;
- (NSProgress *)sendResourceWithName:(NSString *)name atURL:(NSURL *)url toPeer:(MCPeerID *)peer complete:(void (^)(NSError *error))compelete;
- (void)receiveFinalResourceOnMainQueue:(BOOL)mainQueue complete:(void (^)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error))block;
- (void)startReceivingResourceOnMainQueue:(BOOL)mainQueue block:(void (^)(NSString *name, MCPeerID *peer, NSProgress *progress))block;
- (NSOutputStream *)streamWithName:(NSString *)name toPeer:(MCPeerID *)peerID error:(NSError * __autoreleasing *)error;
- (void)didReceiveStreamFromPeer:(void (^)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName))streamBlock;
- (void)peerConnectionStatusOnMainQueue:(BOOL)mainQueue block:(void (^)(MCPeerID *peer, MCSessionState state))status;
- (void)browseWithControllerInViewController:(UIViewController *)controller connected:(void (^)(void))connected canceled:(void (^)(void))cancelled;
- (void)didFindPeerWithInfo:(void (^)(MCPeerID *peer, NSDictionary *info))found;
- (void)connectToPeer:(BOOL)connect;
// 邀請其他裝置連接配接
- (void)invitePeerToConnect:(MCPeerID *)peer connected:(void (^)(void))connected;
- (void)disconnectSession;
// 停止打開自己
- (void)stopAdvertising;
// 停止掃描
- (void)stopBrowsing;
@end
.m
#import "BlueSessionManager.h"
#define ServiceType @"MyService"
/*
MCAdvertiserAssistant //可以接收，并處理使用者請求連接配接的響應。沒有回調，會彈出預設的提示框，并處理連接配接。
MCNearbyServiceAdvertiser //可以接收，并處理使用者請求連接配接的響應。但是，這個類會有回調，告知有使用者要與您的裝置連接配接，然後可以自定義提示框，以及自定義連接配接處理。
MCNearbyServiceBrowser //用于搜尋附近的使用者，并可以對搜尋到的使用者發出邀請加入某個會話中。
MCPeerID //這表明是一個使用者
MCSession //啟用和管理Multipeer連接配接會話中的所有人之間的溝通。 通過Sesion，給别人發送資料。
*/
@interface BlueSessionManager ()<MCAdvertiserAssistantDelegate, MCNearbyServiceBrowserDelegate, MCSessionDelegate, MCBrowserViewControllerDelegate, MCNearbyServiceAdvertiserDelegate, UIAlertViewDelegate>
@property(strong, nonatomic) MCSession *currentSession; // 目前會議
@property(strong, nonatomic) MCAdvertiserAssistant *advertisingAssistant; // 宣傳助手
@property(strong, nonatomic) MCNearbyServiceAdvertiser *advertiser; // 服務助手
@property(strong, nonatomic) MCNearbyServiceBrowser *browser; // 搜尋藍牙者
@property(strong, nonatomic) MCPeerID *peerID; // 使用者
// 以下都是用到的block
@property(nonatomic, copy) void(^receiveDataBlock)(NSData *data, MCPeerID *peer);
@property(nonatomic, copy) void(^receiveResourceBlock)(MCPeerID *peer, NSURL *url);
@property(nonatomic, copy) void(^connectionStatus)(MCPeerID *peer, MCSessionState state);
@property(nonatomic, copy) void(^browserConnected)(void);
@property(nonatomic, copy) void(^browserCancelled)(void);
@property(nonatomic, copy) void(^didFindPeer)(MCPeerID *peer, NSDictionary *info);
@property(nonatomic, copy) void(^invitationHandler)(BOOL connect, MCSession *session);
@property(nonatomic, copy) void(^inviteBlock)(MCPeerID *peer, NSData *context);
@property(nonatomic, copy) void(^didStartReceivingResource)(NSString *name, MCPeerID *peer, NSProgress *progress);
@property(nonatomic, copy) void(^finalResource)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error);
@property(nonatomic, copy) void(^streamBlock)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName);
// 各種判斷
@property(nonatomic, assign) BOOL receiveOnMainQueue;
@property(nonatomic, assign) BOOL statusOnMainQueue;
@property(nonatomic, assign) BOOL resourceFinalOnMainQueue;
@property(nonatomic, assign) BOOL resourceStart;
@end
@implementation BlueSessionManager
#pragma mark 初始化自己
- (instancetype)initWithDisplayName:(NSString *)displayName
{
return [self initWithDisplayName:displayName securityIdentity:nil encryptionPreferences:MCEncryptionNone serviceType:ServiceType];
}
// 為上面自定義 使用者
- (instancetype)initWithDisplayName:(NSString *)displayName securityIdentity:(NSArray *)security encryptionPreferences:(MCEncryptionPreference)preference serviceType:(NSString *)type
{
self = [super init];
if(!self) {
return nil;
}
self.peerID = [[MCPeerID alloc]initWithDisplayName:displayName];
self.currentSession = [[MCSession alloc]initWithPeer:self.peerID securityIdentity:security encryptionPreference:preference];
self.session.delegate = self;
self.serviceType = type;
return self;
}
#pragma mark 宣傳自己
- (void)advertiseForBrowserViewController
{
[self advertiseForBrowserViewControllerWithDiscoveryInfo:nil];
}
- (void)advertiseForBrowserViewControllerWithDiscoveryInfo:(NSDictionary *)info
{
//
self.advertiser = [[MCNearbyServiceAdvertiser alloc]initWithPeer:self.peerID discoveryInfo:info serviceType:self.serviceType];
self.advertiser.delegate = self;
[self.advertiser startAdvertisingPeer];
}
- (void)advertiseForProgrammaticDiscovery
{
[self advertiseForProgrammaticDiscoveryWithDiscoveryInfo:nil];
}
- (void)advertiseForProgrammaticDiscoveryWithDiscoveryInfo:(NSDictionary *)info
{
//自定義自己，為了讓其他裝置搜尋到自己
self.advertisingAssistant = [[MCAdvertiserAssistant alloc]initWithServiceType:self.serviceType discoveryInfo:info session:self.session];
self.advertisingAssistant.delegate = self;
[self.advertisingAssistant start];
}
- (void)advertiser:(MCNearbyServiceAdvertiser *)advertiser didReceiveInvitationFromPeer:(MCPeerID *)peerID withContext:(NSData *)context invitationHandler:(void (^)(BOOL, MCSession *))invitationHandler {
self.invitationHandler = [invitationHandler copy];
if(self.inviteBlock) self.inviteBlock(peerID, context);
}
#pragma mark 下面是MCAdvertiserAssistant的兩個代理
- (void)advertiserAssistantDidDismissInvitation:(MCAdvertiserAssistant *)advertiserAssistant
{
//TODO implement
}
- (void)advertiserAssitantWillPresentInvitation:(MCAdvertiserAssistant *)advertiserAssistant {
//TODO implement
}
#pragma mark 掃描其他的裝置
- (void)browseForProgrammaticDiscovery
{
self.browser = [[MCNearbyServiceBrowser alloc]initWithPeer:self.peerID serviceType:self.serviceType];
self.browser.delegate = self;
[self.browser startBrowsingForPeers];
}
#pragma mark MCNearbyServiceBrowserDelegate
- (void)browser:(MCNearbyServiceBrowser *)browser lostPeer:(MCPeerID *)peerID
{
//TODO implement
}
- (void)browser:(MCNearbyServiceBrowser *)browser foundPeer:(MCPeerID *)peerID withDiscoveryInfo:(NSDictionary *)info
{
if(self.didFindPeer)
{
self.didFindPeer(peerID, info);
}
}
- (void)browser:(MCNearbyServiceBrowser *)browser didNotStartBrowsingForPeers:(NSError *)error
{
//TODO implement
}
#pragma mark 參加會議 也是會議的代理
// 也是 ----- MCSessionDelegate
// 這是完成會議的結果···
- (void)session:(MCSession *)session didFinishReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID atURL:(NSURL *)localURL withError:(NSError *)error
{
if(self.resourceFinalOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.finalResource)
{
self.finalResource(resourceName, peerID, localURL, error);
}
}];
}
else
{
if(self.finalResource)
{
self.finalResource(resourceName, peerID, localURL, error);
}
}
}
// 這是參加 普通資料的會議
- (void)session:(MCSession *)session didReceiveData:(NSData *)data fromPeer:(MCPeerID *)peerID
{
if(self.receiveOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.receiveDataBlock){
self.receiveDataBlock(data, peerID);
}
}];
}
else
{
if(self.receiveDataBlock)
{
self.receiveDataBlock(data, peerID);
}
}
}
// 這是參加普通流的會議
- (void)session:(MCSession *)session didReceiveStream:(NSInputStream *)stream withName:(NSString *)streamName fromPeer:(MCPeerID *)peerID
{
if(self.streamBlock)
{
self.streamBlock(stream, peerID, streamName);
}
}
// 這是參加圖檔資源的會議
- (void)session:(MCSession *)session didStartReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID withProgress:(NSProgress *)progress
{
if(self.resourceStart)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.didStartReceivingResource)
{
self.didStartReceivingResource(resourceName, peerID, progress);
}
}];
}
else
{
if(self.didStartReceivingResource)
{
self.didStartReceivingResource(resourceName, peerID, progress);
}
}
}
// 這是不同資料，系那是不同會議時候的狀态
- (void)session:(MCSession *)session peer:(MCPeerID *)peerID didChangeState:(MCSessionState)state
{
// 這個地方是當兩個藍牙裝置一旦連接配接起來，就會形成的一個會議
if(self.statusOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.connectionStatus)
{
self.connectionStatus(peerID, state);
}
}];
}
else
{
if(self.connectionStatus)
{
self.connectionStatus(peerID, state);
}
}
}
#pragma mark send And receive
//--------------------------------------------------------------------------------------------//
// 發送消息
// 使用者多個
- (NSError *)sendDataToAllPeers:(NSData *)data
{
// 普通資料的發送
return [self sendDataToAllPeers:data withMode:MCSessionSendDataReliable];
}
- (NSError *)sendDataToAllPeers:(NSData *)data withMode:(MCSessionSendDataMode)mode
{
// 确實進入會議
NSError *error;
[self.session sendData:data toPeers:self.session.connectedPeers withMode:mode error:&error];
return error;
}
// 使用者确定一個
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers
{
return [self sendData:data toPeers:peers withMode:MCSessionSendDataReliable];
}
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers withMode:(MCSessionSendDataMode)mode
{
NSError *error;
[self.session sendData:data toPeers:peers withMode:mode error:&error];
return error;
}
// 接收消息
- (void)receiveDataOnMainQueue:(BOOL)mainQueue block:(void (^)(NSData *data, MCPeerID *peer))dataBlock
{
self.receiveDataBlock = [dataBlock copy];
self.receiveOnMainQueue = mainQueue;
}
//--------------------------------------------------------------------------------------------//
- (NSProgress *)sendResourceWithName:(NSString *)name atURL:(NSURL *)url toPeer:(MCPeerID *)peer complete:(void (^)(NSError *error))compelete
{
// 圖檔資源資料的發送
return [self.session sendResourceAtURL:url withName:name toPeer:peer withCompletionHandler:compelete];
}
// 使用者連接配接确定
- (void)peerConnectionStatusOnMainQueue:(BOOL)mainQueue block:(void (^)(MCPeerID *peer, MCSessionState state))status
{
self.connectionStatus = [status copy];
self.statusOnMainQueue = mainQueue;
}
#pragma mark 自帶的MCBrowserViewController類
- (void)browserViewControllerDidFinish:(MCBrowserViewController *)browserViewController
{
[browserViewController dismissViewControllerAnimated:YES completion:^{
if(self.browserConnected) self.browserConnected();
}];
}
- (void)browserViewControllerWasCancelled:(MCBrowserViewController *)browserViewController
{
[browserViewController dismissViewControllerAnimated:YES completion:^{
if(self.browserCancelled) self.browserCancelled();
}];
}
- (void)browseWithControllerInViewController:(UIViewController *)controller connected:(void (^)(void))connected canceled:(void (^)(void))cancelled
{
self.browserConnected = [connected copy];
self.browserCancelled = [cancelled copy];
// 注意這個自帶的類
MCBrowserViewController *browser = [[MCBrowserViewController alloc]initWithServiceType:self.serviceType session:self.session];
browser.delegate = self;
[controller presentViewController:browser animated:YES completion:nil];
}
- (NSArray *)connectedPeers
{
return self.session.connectedPeers;
}
// 邀請某某連接配接
- (void)didReceiveInvitationFromPeer:(void (^)(MCPeerID *peer, NSData *context))invite;
{
self.inviteBlock = [invite copy];
}
- (void)invitePeerToConnect:(MCPeerID *)peer connected:(void (^)(void))connected
{
[self.browser invitePeer:peer toSession:self.session withContext:nil timeout:];
}
- (void)startReceivingResourceOnMainQueue:(BOOL)mainQueue block:(void (^)(NSString *name, MCPeerID *peer, NSProgress *progress))block
{
self.didStartReceivingResource = [block copy];
self.resourceStart = mainQueue;
}
// 接收某某資源
- (void)receiveFinalResourceOnMainQueue:(BOOL)mainQueue complete:(void (^)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error))block
{
self.finalResource = [block copy];
self.resourceFinalOnMainQueue = mainQueue;
}
- (NSOutputStream *)streamWithName:(NSString *)name toPeer:(MCPeerID *)peerID error:(NSError * __autoreleasing *)error
{
return [self.session startStreamWithName:name toPeer:peerID error:error];
}
// 開始轉化為流
- (void)didReceiveStreamFromPeer:(void (^)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName))streamBlock
{
self.streamBlock = [streamBlock copy];
}
- (void)didFindPeerWithInfo:(void (^)(MCPeerID *peer, NSDictionary *info))found
{
self.didFindPeer = [found copy];
}
#pragma mark 一些斷開的情況
- (void)disconnectSession
{
[self.session disconnect];
}
- (void)stopAdvertising
{
[self.advertiser stopAdvertisingPeer];
[self.advertisingAssistant stop];
}
- (void)stopBrowsing
{
[self.browser stopBrowsingForPeers];
}
- (BOOL)isConnected {
return self.session.connectedPeers && self.session.connectedPeers.count > ;
}
// 是否連接配接 它
- (void)connectToPeer:(BOOL)connect {
self.invitationHandler(connect, self.session);
}
- (MCSession *)session {
return self.currentSession;
}
- (MCPeerID *)firstPeer {
return self.session.connectedPeers.firstObject;
}
@end
#import "BlueSessionManager.h"
#define ServiceType @"MyService"
/*
MCAdvertiserAssistant //可以接收，并處理使用者請求連接配接的響應。沒有回調，會彈出預設的提示框，并處理連接配接。
MCNearbyServiceAdvertiser //可以接收，并處理使用者請求連接配接的響應。但是，這個類會有回調，告知有使用者要與您的裝置連接配接，然後可以自定義提示框，以及自定義連接配接處理。
MCNearbyServiceBrowser //用于搜尋附近的使用者，并可以對搜尋到的使用者發出邀請加入某個會話中。
MCPeerID //這表明是一個使用者
MCSession //啟用和管理Multipeer連接配接會話中的所有人之間的溝通。 通過Sesion，給别人發送資料。
*/
@interface BlueSessionManager ()<MCAdvertiserAssistantDelegate, MCNearbyServiceBrowserDelegate, MCSessionDelegate, MCBrowserViewControllerDelegate, MCNearbyServiceAdvertiserDelegate, UIAlertViewDelegate>
@property(strong, nonatomic) MCSession *currentSession; // 目前會議
@property(strong, nonatomic) MCAdvertiserAssistant *advertisingAssistant; // 宣傳助手
@property(strong, nonatomic) MCNearbyServiceAdvertiser *advertiser; // 服務助手
@property(strong, nonatomic) MCNearbyServiceBrowser *browser; // 搜尋藍牙者
@property(strong, nonatomic) MCPeerID *peerID; // 使用者
// 以下都是用到的block
@property(nonatomic, copy) void(^receiveDataBlock)(NSData *data, MCPeerID *peer);
@property(nonatomic, copy) void(^receiveResourceBlock)(MCPeerID *peer, NSURL *url);
@property(nonatomic, copy) void(^connectionStatus)(MCPeerID *peer, MCSessionState state);
@property(nonatomic, copy) void(^browserConnected)(void);
@property(nonatomic, copy) void(^browserCancelled)(void);
@property(nonatomic, copy) void(^didFindPeer)(MCPeerID *peer, NSDictionary *info);
@property(nonatomic, copy) void(^invitationHandler)(BOOL connect, MCSession *session);
@property(nonatomic, copy) void(^inviteBlock)(MCPeerID *peer, NSData *context);
@property(nonatomic, copy) void(^didStartReceivingResource)(NSString *name, MCPeerID *peer, NSProgress *progress);
@property(nonatomic, copy) void(^finalResource)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error);
@property(nonatomic, copy) void(^streamBlock)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName);
// 各種判斷
@property(nonatomic, assign) BOOL receiveOnMainQueue;
@property(nonatomic, assign) BOOL statusOnMainQueue;
@property(nonatomic, assign) BOOL resourceFinalOnMainQueue;
@property(nonatomic, assign) BOOL resourceStart;
@end
@implementation BlueSessionManager
#pragma mark 初始化自己
- (instancetype)initWithDisplayName:(NSString *)displayName
{
return [self initWithDisplayName:displayName securityIdentity:nil encryptionPreferences:MCEncryptionNone serviceType:ServiceType];
}
// 為上面自定義 使用者
- (instancetype)initWithDisplayName:(NSString *)displayName securityIdentity:(NSArray *)security encryptionPreferences:(MCEncryptionPreference)preference serviceType:(NSString *)type
{
self = [super init];
if(!self) {
return nil;
}
self.peerID = [[MCPeerID alloc]initWithDisplayName:displayName];
self.currentSession = [[MCSession alloc]initWithPeer:self.peerID securityIdentity:security encryptionPreference:preference];
self.session.delegate = self;
self.serviceType = type;
return self;
}
#pragma mark 宣傳自己
- (void)advertiseForBrowserViewController
{
[self advertiseForBrowserViewControllerWithDiscoveryInfo:nil];
}
- (void)advertiseForBrowserViewControllerWithDiscoveryInfo:(NSDictionary *)info
{
//
self.advertiser = [[MCNearbyServiceAdvertiser alloc]initWithPeer:self.peerID discoveryInfo:info serviceType:self.serviceType];
self.advertiser.delegate = self;
[self.advertiser startAdvertisingPeer];
}
- (void)advertiseForProgrammaticDiscovery
{
[self advertiseForProgrammaticDiscoveryWithDiscoveryInfo:nil];
}
- (void)advertiseForProgrammaticDiscoveryWithDiscoveryInfo:(NSDictionary *)info
{
//自定義自己，為了讓其他裝置搜尋到自己
self.advertisingAssistant = [[MCAdvertiserAssistant alloc]initWithServiceType:self.serviceType discoveryInfo:info session:self.session];
self.advertisingAssistant.delegate = self;
[self.advertisingAssistant start];
}
- (void)advertiser:(MCNearbyServiceAdvertiser *)advertiser didReceiveInvitationFromPeer:(MCPeerID *)peerID withContext:(NSData *)context invitationHandler:(void (^)(BOOL, MCSession *))invitationHandler {
self.invitationHandler = [invitationHandler copy];
if(self.inviteBlock) self.inviteBlock(peerID, context);
}
#pragma mark 下面是MCAdvertiserAssistant的兩個代理
- (void)advertiserAssistantDidDismissInvitation:(MCAdvertiserAssistant *)advertiserAssistant
{
//TODO implement
}
- (void)advertiserAssitantWillPresentInvitation:(MCAdvertiserAssistant *)advertiserAssistant {
//TODO implement
}
#pragma mark 掃描其他的裝置
- (void)browseForProgrammaticDiscovery
{
self.browser = [[MCNearbyServiceBrowser alloc]initWithPeer:self.peerID serviceType:self.serviceType];
self.browser.delegate = self;
[self.browser startBrowsingForPeers];
}
#pragma mark MCNearbyServiceBrowserDelegate
- (void)browser:(MCNearbyServiceBrowser *)browser lostPeer:(MCPeerID *)peerID
{
//TODO implement
}
- (void)browser:(MCNearbyServiceBrowser *)browser foundPeer:(MCPeerID *)peerID withDiscoveryInfo:(NSDictionary *)info
{
if(self.didFindPeer)
{
self.didFindPeer(peerID, info);
}
}
- (void)browser:(MCNearbyServiceBrowser *)browser didNotStartBrowsingForPeers:(NSError *)error
{
//TODO implement
}
#pragma mark 參加會議 也是會議的代理
// 也是 ----- MCSessionDelegate
// 這是完成會議的結果···
- (void)session:(MCSession *)session didFinishReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID atURL:(NSURL *)localURL withError:(NSError *)error
{
if(self.resourceFinalOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.finalResource)
{
self.finalResource(resourceName, peerID, localURL, error);
}
}];
}
else
{
if(self.finalResource)
{
self.finalResource(resourceName, peerID, localURL, error);
}
}
}
// 這是參加 普通資料的會議
- (void)session:(MCSession *)session didReceiveData:(NSData *)data fromPeer:(MCPeerID *)peerID
{
if(self.receiveOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.receiveDataBlock){
self.receiveDataBlock(data, peerID);
}
}];
}
else
{
if(self.receiveDataBlock)
{
self.receiveDataBlock(data, peerID);
}
}
}
// 這是參加普通流的會議
- (void)session:(MCSession *)session didReceiveStream:(NSInputStream *)stream withName:(NSString *)streamName fromPeer:(MCPeerID *)peerID
{
if(self.streamBlock)
{
self.streamBlock(stream, peerID, streamName);
}
}
// 這是參加圖檔資源的會議
- (void)session:(MCSession *)session didStartReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID withProgress:(NSProgress *)progress
{
if(self.resourceStart)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.didStartReceivingResource)
{
self.didStartReceivingResource(resourceName, peerID, progress);
}
}];
}
else
{
if(self.didStartReceivingResource)
{
self.didStartReceivingResource(resourceName, peerID, progress);
}
}
}
// 這是不同資料，系那是不同會議時候的狀态
- (void)session:(MCSession *)session peer:(MCPeerID *)peerID didChangeState:(MCSessionState)state
{
// 這個地方是當兩個藍牙裝置一旦連接配接起來，就會形成的一個會議
if(self.statusOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.connectionStatus)
{
self.connectionStatus(peerID, state);
}
}];
}
else
{
if(self.connectionStatus)
{
self.connectionStatus(peerID, state);
}
}
}
#pragma mark send And receive
//--------------------------------------------------------------------------------------------//
// 發送消息
// 使用者多個
- (NSError *)sendDataToAllPeers:(NSData *)data
{
// 普通資料的發送
return [self sendDataToAllPeers:data withMode:MCSessionSendDataReliable];
}
- (NSError *)sendDataToAllPeers:(NSData *)data withMode:(MCSessionSendDataMode)mode
{
// 确實進入會議
NSError *error;
[self.session sendData:data toPeers:self.session.connectedPeers withMode:mode error:&error];
return error;
}
// 使用者确定一個
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers
{
return [self sendData:data toPeers:peers withMode:MCSessionSendDataReliable];
}
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers withMode:(MCSessionSendDataMode)mode
{
NSError *error;
[self.session sendData:data toPeers:peers withMode:mode error:&error];
return error;
}
// 接收消息
- (void)receiveDataOnMainQueue:(BOOL)mainQueue block:(void (^)(NSData *data, MCPeerID *peer))dataBlock
{
self.receiveDataBlock = [dataBlock copy];
self.receiveOnMainQueue = mainQueue;
}
//--------------------------------------------------------------------------------------------//
- (NSProgress *)sendResourceWithName:(NSString *)name atURL:(NSURL *)url toPeer:(MCPeerID *)peer complete:(void (^)(NSError *error))compelete
{
// 圖檔資源資料的發送
return [self.session sendResourceAtURL:url withName:name toPeer:peer withCompletionHandler:compelete];
}
// 使用者連接配接确定
- (void)peerConnectionStatusOnMainQueue:(BOOL)mainQueue block:(void (^)(MCPeerID *peer, MCSessionState state))status
{
self.connectionStatus = [status copy];
self.statusOnMainQueue = mainQueue;
}
#pragma mark 自帶的MCBrowserViewController類
- (void)browserViewControllerDidFinish:(MCBrowserViewController *)browserViewController
{
[browserViewController dismissViewControllerAnimated:YES completion:^{
if(self.browserConnected) self.browserConnected();
}];
}
- (void)browserViewControllerWasCancelled:(MCBrowserViewController *)browserViewController
{
[browserViewController dismissViewControllerAnimated:YES completion:^{
if(self.browserCancelled) self.browserCancelled();
}];
}
- (void)browseWithControllerInViewController:(UIViewController *)controller connected:(void (^)(void))connected canceled:(void (^)(void))cancelled
{
self.browserConnected = [connected copy];
self.browserCancelled = [cancelled copy];
// 注意這個自帶的類
MCBrowserViewController *browser = [[MCBrowserViewController alloc]initWithServiceType:self.serviceType session:self.session];
browser.delegate = self;
[controller presentViewController:browser animated:YES completion:nil];
}
- (NSArray *)connectedPeers
{
return self.session.connectedPeers;
}
// 邀請某某連接配接
- (void)didReceiveInvitationFromPeer:(void (^)(MCPeerID *peer, NSData *context))invite;
{
self.inviteBlock = [invite copy];
}
- (void)invitePeerToConnect:(MCPeerID *)peer connected:(void (^)(void))connected
{
[self.browser invitePeer:peer toSession:self.session withContext:nil timeout:];
}
- (void)startReceivingResourceOnMainQueue:(BOOL)mainQueue block:(void (^)(NSString *name, MCPeerID *peer, NSProgress *progress))block
{
self.didStartReceivingResource = [block copy];
self.resourceStart = mainQueue;
}
// 接收某某資源
- (void)receiveFinalResourceOnMainQueue:(BOOL)mainQueue complete:(void (^)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error))block
{
self.finalResource = [block copy];
self.resourceFinalOnMainQueue = mainQueue;
}
- (NSOutputStream *)streamWithName:(NSString *)name toPeer:(MCPeerID *)peerID error:(NSError * __autoreleasing *)error
{
return [self.session startStreamWithName:name toPeer:peerID error:error];
}
// 開始轉化為流
- (void)didReceiveStreamFromPeer:(void (^)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName))streamBlock
{
self.streamBlock = [streamBlock copy];
}
- (void)didFindPeerWithInfo:(void (^)(MCPeerID *peer, NSDictionary *info))found
{
self.didFindPeer = [found copy];
}
#pragma mark 一些斷開的情況
- (void)disconnectSession
{
[self.session disconnect];
}
- (void)stopAdvertising
{
[self.advertiser stopAdvertisingPeer];
[self.advertisingAssistant stop];
}
- (void)stopBrowsing
{
[self.browser stopBrowsingForPeers];
}
- (BOOL)isConnected {
return self.session.connectedPeers && self.session.connectedPeers.count > ;
}
// 是否連接配接 它
- (void)connectToPeer:(BOOL)connect {
self.invitationHandler(connect, self.session);
}
- (MCSession *)session {
return self.currentSession;
}
- (MCPeerID *)firstPeer {
return self.session.connectedPeers.firstObject;
}
@end
#import "BlueSessionManager.h"
#define ServiceType @"MyService"
/*
MCAdvertiserAssistant //可以接收，并處理使用者請求連接配接的響應。沒有回調，會彈出預設的提示框，并處理連接配接。
MCNearbyServiceAdvertiser //可以接收，并處理使用者請求連接配接的響應。但是，這個類會有回調，告知有使用者要與您的裝置連接配接，然後可以自定義提示框，以及自定義連接配接處理。
MCNearbyServiceBrowser //用于搜尋附近的使用者，并可以對搜尋到的使用者發出邀請加入某個會話中。
MCPeerID //這表明是一個使用者
MCSession //啟用和管理Multipeer連接配接會話中的所有人之間的溝通。 通過Sesion，給别人發送資料。
*/
@interface BlueSessionManager ()<MCAdvertiserAssistantDelegate, MCNearbyServiceBrowserDelegate, MCSessionDelegate, MCBrowserViewControllerDelegate, MCNearbyServiceAdvertiserDelegate, UIAlertViewDelegate>
@property(strong, nonatomic) MCSession *currentSession; // 目前會議
@property(strong, nonatomic) MCAdvertiserAssistant *advertisingAssistant; // 宣傳助手
@property(strong, nonatomic) MCNearbyServiceAdvertiser *advertiser; // 服務助手
@property(strong, nonatomic) MCNearbyServiceBrowser *browser; // 搜尋藍牙者
@property(strong, nonatomic) MCPeerID *peerID; // 使用者
// 以下都是用到的block
@property(nonatomic, copy) void(^receiveDataBlock)(NSData *data, MCPeerID *peer);
@property(nonatomic, copy) void(^receiveResourceBlock)(MCPeerID *peer, NSURL *url);
@property(nonatomic, copy) void(^connectionStatus)(MCPeerID *peer, MCSessionState state);
@property(nonatomic, copy) void(^browserConnected)(void);
@property(nonatomic, copy) void(^browserCancelled)(void);
@property(nonatomic, copy) void(^didFindPeer)(MCPeerID *peer, NSDictionary *info);
@property(nonatomic, copy) void(^invitationHandler)(BOOL connect, MCSession *session);
@property(nonatomic, copy) void(^inviteBlock)(MCPeerID *peer, NSData *context);
@property(nonatomic, copy) void(^didStartReceivingResource)(NSString *name, MCPeerID *peer, NSProgress *progress);
@property(nonatomic, copy) void(^finalResource)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error);
@property(nonatomic, copy) void(^streamBlock)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName);
// 各種判斷
@property(nonatomic, assign) BOOL receiveOnMainQueue;
@property(nonatomic, assign) BOOL statusOnMainQueue;
@property(nonatomic, assign) BOOL resourceFinalOnMainQueue;
@property(nonatomic, assign) BOOL resourceStart;
@end
@implementation BlueSessionManager
#pragma mark 初始化自己
- (instancetype)initWithDisplayName:(NSString *)displayName
{
return [self initWithDisplayName:displayName securityIdentity:nil encryptionPreferences:MCEncryptionNone serviceType:ServiceType];
}
// 為上面自定義 使用者
- (instancetype)initWithDisplayName:(NSString *)displayName securityIdentity:(NSArray *)security encryptionPreferences:(MCEncryptionPreference)preference serviceType:(NSString *)type
{
self = [super init];
if(!self) {
return nil;
}
self.peerID = [[MCPeerID alloc]initWithDisplayName:displayName];
self.currentSession = [[MCSession alloc]initWithPeer:self.peerID securityIdentity:security encryptionPreference:preference];
self.session.delegate = self;
self.serviceType = type;
return self;
}
#pragma mark 宣傳自己
- (void)advertiseForBrowserViewController
{
[self advertiseForBrowserViewControllerWithDiscoveryInfo:nil];
}
- (void)advertiseForBrowserViewControllerWithDiscoveryInfo:(NSDictionary *)info
{
//
self.advertiser = [[MCNearbyServiceAdvertiser alloc]initWithPeer:self.peerID discoveryInfo:info serviceType:self.serviceType];
self.advertiser.delegate = self;
[self.advertiser startAdvertisingPeer];
}
- (void)advertiseForProgrammaticDiscovery
{
[self advertiseForProgrammaticDiscoveryWithDiscoveryInfo:nil];
}
- (void)advertiseForProgrammaticDiscoveryWithDiscoveryInfo:(NSDictionary *)info
{
//自定義自己，為了讓其他裝置搜尋到自己
self.advertisingAssistant = [[MCAdvertiserAssistant alloc]initWithServiceType:self.serviceType discoveryInfo:info session:self.session];
self.advertisingAssistant.delegate = self;
[self.advertisingAssistant start];
}
- (void)advertiser:(MCNearbyServiceAdvertiser *)advertiser didReceiveInvitationFromPeer:(MCPeerID *)peerID withContext:(NSData *)context invitationHandler:(void (^)(BOOL, MCSession *))invitationHandler {
self.invitationHandler = [invitationHandler copy];
if(self.inviteBlock) self.inviteBlock(peerID, context);
}
#pragma mark 下面是MCAdvertiserAssistant的兩個代理
- (void)advertiserAssistantDidDismissInvitation:(MCAdvertiserAssistant *)advertiserAssistant
{
//TODO implement
}
- (void)advertiserAssitantWillPresentInvitation:(MCAdvertiserAssistant *)advertiserAssistant {
//TODO implement
}
#pragma mark 掃描其他的裝置
- (void)browseForProgrammaticDiscovery
{
self.browser = [[MCNearbyServiceBrowser alloc]initWithPeer:self.peerID serviceType:self.serviceType];
self.browser.delegate = self;
[self.browser startBrowsingForPeers];
}
#pragma mark MCNearbyServiceBrowserDelegate
- (void)browser:(MCNearbyServiceBrowser *)browser lostPeer:(MCPeerID *)peerID
{
//TODO implement
}
- (void)browser:(MCNearbyServiceBrowser *)browser foundPeer:(MCPeerID *)peerID withDiscoveryInfo:(NSDictionary *)info
{
if(self.didFindPeer)
{
self.didFindPeer(peerID, info);
}
}
- (void)browser:(MCNearbyServiceBrowser *)browser didNotStartBrowsingForPeers:(NSError *)error
{
//TODO implement
}
#pragma mark 參加會議 也是會議的代理
// 也是 ----- MCSessionDelegate
// 這是完成會議的結果···
- (void)session:(MCSession *)session didFinishReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID atURL:(NSURL *)localURL withError:(NSError *)error
{
if(self.resourceFinalOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.finalResource)
{
self.finalResource(resourceName, peerID, localURL, error);
}
}];
}
else
{
if(self.finalResource)
{
self.finalResource(resourceName, peerID, localURL, error);
}
}
}
// 這是參加 普通資料的會議
- (void)session:(MCSession *)session didReceiveData:(NSData *)data fromPeer:(MCPeerID *)peerID
{
if(self.receiveOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.receiveDataBlock){
self.receiveDataBlock(data, peerID);
}
}];
}
else
{
if(self.receiveDataBlock)
{
self.receiveDataBlock(data, peerID);
}
}
}
// 這是參加普通流的會議
- (void)session:(MCSession *)session didReceiveStream:(NSInputStream *)stream withName:(NSString *)streamName fromPeer:(MCPeerID *)peerID
{
if(self.streamBlock)
{
self.streamBlock(stream, peerID, streamName);
}
}
// 這是參加圖檔資源的會議
- (void)session:(MCSession *)session didStartReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID withProgress:(NSProgress *)progress
{
if(self.resourceStart)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.didStartReceivingResource)
{
self.didStartReceivingResource(resourceName, peerID, progress);
}
}];
}
else
{
if(self.didStartReceivingResource)
{
self.didStartReceivingResource(resourceName, peerID, progress);
}
}
}
// 這是不同資料，系那是不同會議時候的狀态
- (void)session:(MCSession *)session peer:(MCPeerID *)peerID didChangeState:(MCSessionState)state
{
// 這個地方是當兩個藍牙裝置一旦連接配接起來，就會形成的一個會議
if(self.statusOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.connectionStatus)
{
self.connectionStatus(peerID, state);
}
}];
}
else
{
if(self.connectionStatus)
{
self.connectionStatus(peerID, state);
}
}
}
#pragma mark send And receive
//--------------------------------------------------------------------------------------------//
// 發送消息
// 使用者多個
- (NSError *)sendDataToAllPeers:(NSData *)data
{
// 普通資料的發送
return [self sendDataToAllPeers:data withMode:MCSessionSendDataReliable];
}
- (NSError *)sendDataToAllPeers:(NSData *)data withMode:(MCSessionSendDataMode)mode
{
// 确實進入會議
NSError *error;
[self.session sendData:data toPeers:self.session.connectedPeers withMode:mode error:&error];
return error;
}
// 使用者确定一個
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers
{
return [self sendData:data toPeers:peers withMode:MCSessionSendDataReliable];
}
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers withMode:(MCSessionSendDataMode)mode
{
NSError *error;
[self.session sendData:data toPeers:peers withMode:mode error:&error];
return error;
}
// 接收消息
- (void)receiveDataOnMainQueue:(BOOL)mainQueue block:(void (^)(NSData *data, MCPeerID *peer))dataBlock
{
self.receiveDataBlock = [dataBlock copy];
self.receiveOnMainQueue = mainQueue;
}
//--------------------------------------------------------------------------------------------//
- (NSProgress *)sendResourceWithName:(NSString *)name atURL:(NSURL *)url toPeer:(MCPeerID *)peer complete:(void (^)(NSError *error))compelete
{
// 圖檔資源資料的發送
return [self.session sendResourceAtURL:url withName:name toPeer:peer withCompletionHandler:compelete];
}
// 使用者連接配接确定
- (void)peerConnectionStatusOnMainQueue:(BOOL)mainQueue block:(void (^)(MCPeerID *peer, MCSessionState state))status
{
self.connectionStatus = [status copy];
self.statusOnMainQueue = mainQueue;
}
#pragma mark 自帶的MCBrowserViewController類
- (void)browserViewControllerDidFinish:(MCBrowserViewController *)browserViewController
{
[browserViewController dismissViewControllerAnimated:YES completion:^{
if(self.browserConnected) self.browserConnected();
}];
}
- (void)browserViewControllerWasCancelled:(MCBrowserViewController *)browserViewController
{
[browserViewController dismissViewControllerAnimated:YES completion:^{
if(self.browserCancelled) self.browserCancelled();
}];
}
- (void)browseWithControllerInViewController:(UIViewController *)controller connected:(void (^)(void))connected canceled:(void (^)(void))cancelled
{
self.browserConnected = [connected copy];
self.browserCancelled = [cancelled copy];
// 注意這個自帶的類
MCBrowserViewController *browser = [[MCBrowserViewController alloc]initWithServiceType:self.serviceType session:self.session];
browser.delegate = self;
[controller presentViewController:browser animated:YES completion:nil];
}
- (NSArray *)connectedPeers
{
return self.session.connectedPeers;
}
// 邀請某某連接配接
- (void)didReceiveInvitationFromPeer:(void (^)(MCPeerID *peer, NSData *context))invite;
{
self.inviteBlock = [invite copy];
}
- (void)invitePeerToConnect:(MCPeerID *)peer connected:(void (^)(void))connected
{
[self.browser invitePeer:peer toSession:self.session withContext:nil timeout:];
}
- (void)startReceivingResourceOnMainQueue:(BOOL)mainQueue block:(void (^)(NSString *name, MCPeerID *peer, NSProgress *progress))block
{
self.didStartReceivingResource = [block copy];
self.resourceStart = mainQueue;
}
// 接收某某資源
- (void)receiveFinalResourceOnMainQueue:(BOOL)mainQueue complete:(void (^)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error))block
{
self.finalResource = [block copy];
self.resourceFinalOnMainQueue = mainQueue;
}
- (NSOutputStream *)streamWithName:(NSString *)name toPeer:(MCPeerID *)peerID error:(NSError * __autoreleasing *)error
{
return [self.session startStreamWithName:name toPeer:peerID error:error];
}
// 開始轉化為流
- (void)didReceiveStreamFromPeer:(void (^)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName))streamBlock
{
self.streamBlock = [streamBlock copy];
}
- (void)didFindPeerWithInfo:(void (^)(MCPeerID *peer, NSDictionary *info))found
{
self.didFindPeer = [found copy];
}
#pragma mark 一些斷開的情況
- (void)disconnectSession
{
[self.session disconnect];
}
- (void)stopAdvertising
{
[self.advertiser stopAdvertisingPeer];
[self.advertisingAssistant stop];
}
- (void)stopBrowsing
{
[self.browser stopBrowsingForPeers];
}
- (BOOL)isConnected {
return self.session.connectedPeers && self.session.connectedPeers.count > ;
}
// 是否連接配接 它
- (void)connectToPeer:(BOOL)connect {
self.invitationHandler(connect, self.session);
}
- (MCSession *)session {
return self.currentSession;
}
- (MCPeerID *)firstPeer {
return self.session.connectedPeers.firstObject;
}
@end
.m
#import "BlueSessionManager.h"
#define ServiceType @"MyService"
/*
MCAdvertiserAssistant //可以接收，并處理使用者請求連接配接的響應。沒有回調，會彈出預設的提示框，并處理連接配接。
MCNearbyServiceAdvertiser //可以接收，并處理使用者請求連接配接的響應。但是，這個類會有回調，告知有使用者要與您的裝置連接配接，然後可以自定義提示框，以及自定義連接配接處理。
MCNearbyServiceBrowser //用于搜尋附近的使用者，并可以對搜尋到的使用者發出邀請加入某個會話中。
MCPeerID //這表明是一個使用者
MCSession //啟用和管理Multipeer連接配接會話中的所有人之間的溝通。 通過Sesion，給别人發送資料。
*/
@interface BlueSessionManager ()<MCAdvertiserAssistantDelegate, MCNearbyServiceBrowserDelegate, MCSessionDelegate, MCBrowserViewControllerDelegate, MCNearbyServiceAdvertiserDelegate, UIAlertViewDelegate>
@property(strong, nonatomic) MCSession *currentSession; // 目前會議
@property(strong, nonatomic) MCAdvertiserAssistant *advertisingAssistant; // 宣傳助手
@property(strong, nonatomic) MCNearbyServiceAdvertiser *advertiser; // 服務助手
@property(strong, nonatomic) MCNearbyServiceBrowser *browser; // 搜尋藍牙者
@property(strong, nonatomic) MCPeerID *peerID; // 使用者
// 以下都是用到的block
@property(nonatomic, copy) void(^receiveDataBlock)(NSData *data, MCPeerID *peer);
@property(nonatomic, copy) void(^receiveResourceBlock)(MCPeerID *peer, NSURL *url);
@property(nonatomic, copy) void(^connectionStatus)(MCPeerID *peer, MCSessionState state);
@property(nonatomic, copy) void(^browserConnected)(void);
@property(nonatomic, copy) void(^browserCancelled)(void);
@property(nonatomic, copy) void(^didFindPeer)(MCPeerID *peer, NSDictionary *info);
@property(nonatomic, copy) void(^invitationHandler)(BOOL connect, MCSession *session);
@property(nonatomic, copy) void(^inviteBlock)(MCPeerID *peer, NSData *context);
@property(nonatomic, copy) void(^didStartReceivingResource)(NSString *name, MCPeerID *peer, NSProgress *progress);
@property(nonatomic, copy) void(^finalResource)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error);
@property(nonatomic, copy) void(^streamBlock)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName);
// 各種判斷
@property(nonatomic, assign) BOOL receiveOnMainQueue;
@property(nonatomic, assign) BOOL statusOnMainQueue;
@property(nonatomic, assign) BOOL resourceFinalOnMainQueue;
@property(nonatomic, assign) BOOL resourceStart;
@end
@implementation BlueSessionManager
#pragma mark 初始化自己
- (instancetype)initWithDisplayName:(NSString *)displayName
{
return [self initWithDisplayName:displayName securityIdentity:nil encryptionPreferences:MCEncryptionNone serviceType:ServiceType];
}
// 為上面自定義 使用者
- (instancetype)initWithDisplayName:(NSString *)displayName securityIdentity:(NSArray *)security encryptionPreferences:(MCEncryptionPreference)preference serviceType:(NSString *)type
{
self = [super init];
if(!self) {
return nil;
}
self.peerID = [[MCPeerID alloc]initWithDisplayName:displayName];
self.currentSession = [[MCSession alloc]initWithPeer:self.peerID securityIdentity:security encryptionPreference:preference];
self.session.delegate = self;
self.serviceType = type;
return self;
}
#pragma mark 宣傳自己
- (void)advertiseForBrowserViewController
{
[self advertiseForBrowserViewControllerWithDiscoveryInfo:nil];
}
- (void)advertiseForBrowserViewControllerWithDiscoveryInfo:(NSDictionary *)info
{
//
self.advertiser = [[MCNearbyServiceAdvertiser alloc]initWithPeer:self.peerID discoveryInfo:info serviceType:self.serviceType];
self.advertiser.delegate = self;
[self.advertiser startAdvertisingPeer];
}
- (void)advertiseForProgrammaticDiscovery
{
[self advertiseForProgrammaticDiscoveryWithDiscoveryInfo:nil];
}
- (void)advertiseForProgrammaticDiscoveryWithDiscoveryInfo:(NSDictionary *)info
{
//自定義自己，為了讓其他裝置搜尋到自己
self.advertisingAssistant = [[MCAdvertiserAssistant alloc]initWithServiceType:self.serviceType discoveryInfo:info session:self.session];
self.advertisingAssistant.delegate = self;
[self.advertisingAssistant start];
}
- (void)advertiser:(MCNearbyServiceAdvertiser *)advertiser didReceiveInvitationFromPeer:(MCPeerID *)peerID withContext:(NSData *)context invitationHandler:(void (^)(BOOL, MCSession *))invitationHandler {
self.invitationHandler = [invitationHandler copy];
if(self.inviteBlock) self.inviteBlock(peerID, context);
}
#pragma mark 下面是MCAdvertiserAssistant的兩個代理
- (void)advertiserAssistantDidDismissInvitation:(MCAdvertiserAssistant *)advertiserAssistant
{
//TODO implement
}
- (void)advertiserAssitantWillPresentInvitation:(MCAdvertiserAssistant *)advertiserAssistant {
//TODO implement
}
#pragma mark 掃描其他的裝置
- (void)browseForProgrammaticDiscovery
{
self.browser = [[MCNearbyServiceBrowser alloc]initWithPeer:self.peerID serviceType:self.serviceType];
self.browser.delegate = self;
[self.browser startBrowsingForPeers];
}
#pragma mark MCNearbyServiceBrowserDelegate
- (void)browser:(MCNearbyServiceBrowser *)browser lostPeer:(MCPeerID *)peerID
{
//TODO implement
}
- (void)browser:(MCNearbyServiceBrowser *)browser foundPeer:(MCPeerID *)peerID withDiscoveryInfo:(NSDictionary *)info
{
if(self.didFindPeer)
{
self.didFindPeer(peerID, info);
}
}
- (void)browser:(MCNearbyServiceBrowser *)browser didNotStartBrowsingForPeers:(NSError *)error
{
//TODO implement
}
#pragma mark 參加會議 也是會議的代理
// 也是 ----- MCSessionDelegate
// 這是完成會議的結果···
- (void)session:(MCSession *)session didFinishReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID atURL:(NSURL *)localURL withError:(NSError *)error
{
if(self.resourceFinalOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.finalResource)
{
self.finalResource(resourceName, peerID, localURL, error);
}
}];
}
else
{
if(self.finalResource)
{
self.finalResource(resourceName, peerID, localURL, error);
}
}
}
// 這是參加 普通資料的會議
- (void)session:(MCSession *)session didReceiveData:(NSData *)data fromPeer:(MCPeerID *)peerID
{
if(self.receiveOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.receiveDataBlock){
self.receiveDataBlock(data, peerID);
}
}];
}
else
{
if(self.receiveDataBlock)
{
self.receiveDataBlock(data, peerID);
}
}
}
// 這是參加普通流的會議
- (void)session:(MCSession *)session didReceiveStream:(NSInputStream *)stream withName:(NSString *)streamName fromPeer:(MCPeerID *)peerID
{
if(self.streamBlock)
{
self.streamBlock(stream, peerID, streamName);
}
}
// 這是參加圖檔資源的會議
- (void)session:(MCSession *)session didStartReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID withProgress:(NSProgress *)progress
{
if(self.resourceStart)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.didStartReceivingResource)
{
self.didStartReceivingResource(resourceName, peerID, progress);
}
}];
}
else
{
if(self.didStartReceivingResource)
{
self.didStartReceivingResource(resourceName, peerID, progress);
}
}
}
// 這是不同資料，系那是不同會議時候的狀态
- (void)session:(MCSession *)session peer:(MCPeerID *)peerID didChangeState:(MCSessionState)state
{
// 這個地方是當兩個藍牙裝置一旦連接配接起來，就會形成的一個會議
if(self.statusOnMainQueue)
{
[[NSOperationQueue mainQueue]addOperationWithBlock:^{
if(self.connectionStatus)
{
self.connectionStatus(peerID, state);
}
}];
}
else
{
if(self.connectionStatus)
{
self.connectionStatus(peerID, state);
}
}
}
#pragma mark send And receive
//--------------------------------------------------------------------------------------------//
// 發送消息
// 使用者多個
- (NSError *)sendDataToAllPeers:(NSData *)data
{
// 普通資料的發送
return [self sendDataToAllPeers:data withMode:MCSessionSendDataReliable];
}
- (NSError *)sendDataToAllPeers:(NSData *)data withMode:(MCSessionSendDataMode)mode
{
// 确實進入會議
NSError *error;
[self.session sendData:data toPeers:self.session.connectedPeers withMode:mode error:&error];
return error;
}
// 使用者确定一個
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers
{
return [self sendData:data toPeers:peers withMode:MCSessionSendDataReliable];
}
- (NSError *)sendData:(NSData *)data toPeers:(NSArray *)peers withMode:(MCSessionSendDataMode)mode
{
NSError *error;
[self.session sendData:data toPeers:peers withMode:mode error:&error];
return error;
}
// 接收消息
- (void)receiveDataOnMainQueue:(BOOL)mainQueue block:(void (^)(NSData *data, MCPeerID *peer))dataBlock
{
self.receiveDataBlock = [dataBlock copy];
self.receiveOnMainQueue = mainQueue;
}
//--------------------------------------------------------------------------------------------//
- (NSProgress *)sendResourceWithName:(NSString *)name atURL:(NSURL *)url toPeer:(MCPeerID *)peer complete:(void (^)(NSError *error))compelete
{
// 圖檔資源資料的發送
return [self.session sendResourceAtURL:url withName:name toPeer:peer withCompletionHandler:compelete];
}
// 使用者連接配接确定
- (void)peerConnectionStatusOnMainQueue:(BOOL)mainQueue block:(void (^)(MCPeerID *peer, MCSessionState state))status
{
self.connectionStatus = [status copy];
self.statusOnMainQueue = mainQueue;
}
#pragma mark 自帶的MCBrowserViewController類
- (void)browserViewControllerDidFinish:(MCBrowserViewController *)browserViewController
{
[browserViewController dismissViewControllerAnimated:YES completion:^{
if(self.browserConnected) self.browserConnected();
}];
}
- (void)browserViewControllerWasCancelled:(MCBrowserViewController *)browserViewController
{
[browserViewController dismissViewControllerAnimated:YES completion:^{
if(self.browserCancelled) self.browserCancelled();
}];
}
- (void)browseWithControllerInViewController:(UIViewController *)controller connected:(void (^)(void))connected canceled:(void (^)(void))cancelled
{
self.browserConnected = [connected copy];
self.browserCancelled = [cancelled copy];
// 注意這個自帶的類
MCBrowserViewController *browser = [[MCBrowserViewController alloc]initWithServiceType:self.serviceType session:self.session];
browser.delegate = self;
[controller presentViewController:browser animated:YES completion:nil];
}
- (NSArray *)connectedPeers
{
return self.session.connectedPeers;
}
// 邀請某某連接配接
- (void)didReceiveInvitationFromPeer:(void (^)(MCPeerID *peer, NSData *context))invite;
{
self.inviteBlock = [invite copy];
}
- (void)invitePeerToConnect:(MCPeerID *)peer connected:(void (^)(void))connected
{
[self.browser invitePeer:peer toSession:self.session withContext:nil timeout:];
}
- (void)startReceivingResourceOnMainQueue:(BOOL)mainQueue block:(void (^)(NSString *name, MCPeerID *peer, NSProgress *progress))block
{
self.didStartReceivingResource = [block copy];
self.resourceStart = mainQueue;
}
// 接收某某資源
- (void)receiveFinalResourceOnMainQueue:(BOOL)mainQueue complete:(void (^)(NSString *name, MCPeerID *peer, NSURL *url, NSError *error))block
{
self.finalResource = [block copy];
self.resourceFinalOnMainQueue = mainQueue;
}
- (NSOutputStream *)streamWithName:(NSString *)name toPeer:(MCPeerID *)peerID error:(NSError * __autoreleasing *)error
{
return [self.session startStreamWithName:name toPeer:peerID error:error];
}
// 開始轉化為流
- (void)didReceiveStreamFromPeer:(void (^)(NSInputStream *inputStream, MCPeerID *peer, NSString *streamName))streamBlock
{
self.streamBlock = [streamBlock copy];
}
- (void)didFindPeerWithInfo:(void (^)(MCPeerID *peer, NSDictionary *info))found
{
self.didFindPeer = [found copy];
}
#pragma mark 一些斷開的情況
- (void)disconnectSession
{
[self.session disconnect];
}
- (void)stopAdvertising
{
[self.advertiser stopAdvertisingPeer];
[self.advertisingAssistant stop];
}
- (void)stopBrowsing
{
[self.browser stopBrowsingForPeers];
}
- (BOOL)isConnected {
return self.session.connectedPeers && self.session.connectedPeers.count > ;
}
// 是否連接配接 它
- (void)connectToPeer:(BOOL)connect {
self.invitationHandler(connect, self.session);
}
- (MCSession *)session {
return self.currentSession;
}
- (MCPeerID *)firstPeer {
return self.session.connectedPeers.firstObject;
}
@end