前言
在终端中模拟群聊功能,连接 QQ服务器的终端命令: telnet命令telnet host(IP地址) port(端口号) 比如 : telnet 192.168.10.1 1688(端口号是随便写的,只要在规定的范围中即可,但是也有可能连接失败,原因是端口号已经被使用了).
1.telnet命令是连接服务器上的某个端口对应的服务首先定义一个方法用于开启QQ群聊的服务器
#import <Foundation/Foundation.h>
@interface WGServicerListener : NSObject
/** 定义一个对象方法,用于QQ开启服务器 */
- (void)startServeSocket;
@end
- 在main.m函数开启群聊服务器,并且让服务器永不停止(除非程序退出)
#import <Foundation/Foundation.h>
#import "GCDAsyncSocket.h"
#import "WGServicerListener.h"
int main(int argc, const char * argv[]) {
@autoreleasepool {
// 创建一个服务器的监听对象
WGServicerListener *serveListener = [[WGServicerListener alloc] init];
// 监听开启服务器
[serveListener startServeSocket];
// 保证服务器一直开启
[[NSRunLoop mainRunLoop] run];
}
return 0;
}
- 监听客户端和服务器的连接, 以及监听客户端是否上传可数据
#import "WGServicerListener.h"
#import "GCDAsyncSocket.h"
@interface WGServicerListener () <GCDAsyncSocketDelegate>
/** 服务器的Socket对象 */
@property(nonatomic, strong) GCDAsyncSocket *serverSocket;
/** 保存所有客户端对象 */
@property(nonatomic, strong) NSMutableArray *clientSockets;
@end
@implementation WGServicerListener
#pragma mark - 懒加载
- (NSMutableArray *)clientSockets
{
if (!_clientSockets) {
_clientSockets = [NSMutableArray array];
}
return _clientSockets;
}
- (void)startServeSocket {
// 创建一个服务器的Socket对象
GCDAsyncSocket *serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
// 绑定并监听serverSocket对象
NSError *error = nil;
[serverSocket acceptOnPort:1886 error:&error];
// 判断是否开启QQ服务器
if (!error) {
NSLog(@"QQ服务器已经开启");
} else
{
NSLog(@"QQ服务器开启失败");
}
// 保存创建的服务器Socket对象
self.serverSocket = serverSocket;
}
/**
* 只要有客户端连接服务器就会调用该代理方法. 第一个Socket表示服务器的Socket对象,第二个是客户端的Socket对象
* 在该方法中的参数中:serverSocket就是服务器端的Socket,所以需要定义一个属性强引用着它,第二个参数是服务器
* 端的clientSocket,用于读取客户端上传的数据.所以需要定义一个数组保存它.
*/
- (void)socket:(GCDAsyncSocket *)serverSocket didAcceptNewSocket:(GCDAsyncSocket *)clientSocket
{
// NSLog(@"%@",serverSocket);
// NSLog(@"%@",clientSocket);
// 保存和QQ服务器连接的客户端
[self.clientSockets addObject:clientSocket];
// 监听客户端有没有上传数据
/**
* -1 表示不要超时
*/
[clientSocket readDataWithTimeout:-1 tag:0];
NSLog(@"客户端%ld已经连接到服务器了",self.clientSockets.count);
}
/**
* 监听客户端有没有上传数据,只要和服务器连接的客户端发送了消息,那么就一定会调用该方法
* 第一个参数是客户端(因为监听的是客户端是否发送消息)
*/
- (void)socket:(GCDAsyncSocket *)clientSocket didReadData:(NSData *)data withTag:(long)tag
{
// 传进来的是一个NSData类型,需要将它转为字符串类型
NSString *responeStr = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
NSLog(@"%@",responeStr);
// 发送消息,在发送消息之前需要判断当前监听的对象(客户端)是不是自己,如果是自己那么就不要发送消息给自己了
for (GCDAsyncSocket *socket in self.clientSockets) {
if (socket != clientSocket) {
[socket writeData:data withTimeout:-1 tag:0];
}
}
// 每次发送完毕消息,都需要监听客户端是否上传了信息,如果不监听,永远发送不了下一条消息
[clientSocket readDataWithTimeout:-1 tag:0];
}
@end
-
下面是模拟QQ群聊,一个终端代表一个客户端.
消息发送的过程 : 客户端--->服务器--->另一个客户端
Snip20160309_3.png 知识拓展
端口号不一样的作用是什么: 比如说我们在电脑上同时登陆两个QQ,当QQ1发送消息给QQ3,首先是QQ1将消息发送给QQ的服务器,服务器再将数据转发给QQ3,但是同时QQ2也发送了消息给QQ3,也是首先将消息发送到QQ服务器,最后才是转发给QQ3,但是,如果QQ3想要回复信息,也同样是将信息先发送给服务器,服务器就是通过这个端口号来判定信息该发给谁.端口号是系统自己分配的.
// 箭头表示发送消息的方向
QQ1(端口号01)—> QQ服务器 —> QQ3
QQ2(端口号02)—> QQ服务器 —> QQ3
—>QQ服务器—> 根据端口号01 —> QQ1
|
QQ3 恢复消息
|
—>QQ服务器—> 根据端口号02—>QQ2
发送消息的原理 : 客户端的数据—>服务器 —> 发给好友(转发的过程)
