我整天都被困在这上面。我有一个由 David Heinemeier Hansson 编写的非常简单的 ActionCable 示例应用程序（聊天应用程序）工作正常（https://www.youtube.com/watch?v=n0WUjGkDFS0）。
我正在尝试使用 iPhone 应用程序连接 websocket。当我连接到 时，我能够接收到 ping ws://localhost:3000/cable，但我不太确定如何从 javascript 上下文之外订阅频道。
问问题
6945 次
3 回答
13
哦，伙计，在阅读了这个问题后，我也遇到了这个问题。
过了一会儿，我终于找到了这个神奇的 Github issue page：
https://github.com/rails/rails/issues/22675
我明白这个补丁会破坏一些测试。这对我来说并不奇怪。但我认为最初的问题仍然相关，不应关闭。
发送到服务器的以下 JSON 应该会成功：
{"command":"subscribe","identifier":{"channel":"ChangesChannel"}}
它不是！相反，您必须发送：
{"command": "subscribe","identifier":"{\"channel\":\"ChangesChannel\"}"}
根据 Github 用户关于 Rails 问题的建议，我终于让 iOS 应用订阅了房间频道。
我的设置如下：
- 目标 C
- 使用 PocketSocket 框架进行 Web 套接字连接
- 导轨 5 RC1
- 红宝石 2.2.4p230
我假设你知道如何使用 Cocoapods 来安装 PocketSocket。
相关代码如下：
视图控制器.h
#import <PocketSocket/PSWebSocket.h>
@interface ViewController : UIViewController <PSWebSocketDelegate, UITableViewDelegate, UITableViewDataSource, UITextFieldDelegate>
@property (nonatomic, strong) PSWebSocket *socket;
视图控制器.m
- (void)viewDidLoad {
[super viewDidLoad];
// Do any additional setup after loading the view, typically from a nib.
[self initViews];
[self initConstraints];
[self initSocket];
}
-(void)initSocket
{
NSURLRequest *request = [NSURLRequest requestWithURL:[NSURL URLWithString:@"ws://localhost:3000/cable"]];
self.socket = [PSWebSocket clientSocketWithRequest:request];
self.socket.delegate = self;
[self.socket open];
}
-(void)joinChannel:(NSString *)channelName
{
NSString *strChannel = @"{ \"channel\": \"RoomChannel\" }";
id data = @{
@"command": @"subscribe",
@"identifier": strChannel
};
NSData * jsonData = [NSJSONSerialization dataWithJSONObject:data options:0 error:nil];
NSString * myString = [[NSString alloc] initWithData:jsonData encoding:NSUTF8StringEncoding];
NSLog(@"myString= %@", myString);
[self.socket send:myString];
}
#pragma mark - PSWebSocketDelegate Methods -
-(void)webSocketDidOpen:(PSWebSocket *)webSocket
{
NSLog(@"The websocket handshake completed and is now open!");
[self joinChannel:@"RoomChannel"];
}
-(void)webSocket:(PSWebSocket *)webSocket didReceiveMessage:(id)message
{
NSData *data = [message dataUsingEncoding:NSUTF8StringEncoding];
id json = [NSJSONSerialization JSONObjectWithData:data options:0 error:nil];
NSString *messageType = json[@"type"];
if(![messageType isEqualToString:@"ping"] && ![messageType isEqualToString:@"welcome"])
{
NSLog(@"The websocket received a message: %@", json[@"message"]);
[self.messages addObject:json[@"message"]];
[self.tableView reloadData];
}
}
-(void)webSocket:(PSWebSocket *)webSocket didFailWithError:(NSError *)error
{
NSLog(@"The websocket handshake/connection failed with an error: %@", error);
}
-(void)webSocket:(PSWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean
{
NSLog(@"The websocket closed with code: %@, reason: %@, wasClean: %@", @(code), reason, (wasClean) ? @"YES": @"NO");
}
重要的提示：
我还深入研究了订阅类源代码：
def add(data)
id_key = data['identifier']
id_options = ActiveSupport::JSON.decode(id_key).with_indifferent_access
subscription_klass = connection.server.channel_classes[id_options[:channel]]
if subscription_klass
subscriptions[id_key] ||= subscription_klass.new(connection, id_key, id_options)
else
logger.error "Subscription class not found (#{data.inspect})"
end
end
注意这一行：
connection.server.channel_classes[id_options[:channel]]
我们需要为通道使用类的名称。
DHH youtube 视频使用“room_channel”作为房间名称，但该频道的类文件名为“RoomChannel”。
我们需要使用类名而不是通道的实例名。
发送消息
以防其他人也想知道如何发送消息，这是我向服务器发送消息的 iOS 代码：
-(void)sendMessage:(NSString *)message
{
NSString *strMessage = [[NSString alloc] initWithFormat:@"{ \"action\": \"speak\", \"message\": \"%@\" }", message];
NSString *strChannel = @"{ \"channel\": \"RoomChannel\" }";
id data = @{
@"command": @"message",
@"identifier": strChannel,
@"data": strMessage
};
NSData * jsonData = [NSJSONSerialization dataWithJSONObject:data options:0 error:nil];
NSString * myString = [[NSString alloc] initWithData:jsonData encoding:NSUTF8StringEncoding];
NSLog(@"myString= %@", myString);
[self.socket send:myString];
}
这假设您已经连接了 UITextField 以处理按下回车键或 UI 上某处的某些“发送”按钮。
整个演示应用程序是一个快速的 hack，显然，如果我要在一个真正的应用程序中完成它，我会让我的代码更清晰、更可重用并将其抽象为一个类。
从真实的 iPhone 设备连接到 Rails 服务器：
为了让 iPhone 应用程序与真实设备上的 Rails 服务器对话，而不是 iPhone 模拟器。
请执行下列操作：
- 检查计算机的 TCP/IP 地址。例如，在我的 iMac 上，有时它可能是 10.1.1.10（如果使用 DHCP，将来可以自动更改）。
编辑 Rail 的
config > environment > development.rb文件并在end关键字之前的某处输入以下行：Rails.application.config.action_cable.allowed_request_origins = ['http://10.1.1.10:3000']使用以下命令启动 Rails 服务器：
rails server -b 0.0.0.0在 iPhone 设备上构建并运行您的 iPhone 应用程序。您现在应该可以连接和发送消息了：D
我从以下链接获得了这些解决方案：
不允许请求来源：使用 Rails5 和 ActionCable 时的 http://localhost:3001
希望将来可以帮助其他人。
于 2016-05-21T08:39:11.473 回答
3
// 先打开socket连接
var ws = new WebSocket("ws://localhost:3000/cable");
// 订阅频道
// 'i' 应该是 json
var i = { 'command': 'subscribe', 'identifier': {'channel':'ProfileChannel', 'Param_1': 'Value_1',...}};
ws.send(i);
// 之后，您将在“onmessage”函数中接收数据。
干杯!
于 2016-05-12T14:26:31.230 回答
0
实际上，这是我用来连接动作电缆的代码片段。
function WebSocketTest()
{
var ws = new WebSocket("ws://localhost:3000/cable");
ws.onopen = function(data)
{
var i = JSON.stringify({"command":"subscribe" , "identifier": JSON.stringify({"channel":"CHANNEL_NAME"})});
// send data request
var j = JSON.stringify({"command":"message","identifier": JSON.stringify({"channel":"CHANNEL_NAME"}),"data": {"message":"Hello World","action": "METHOD_NAME_IN_CHANNEL","email": "abc@xyz.com", "token" : "xxxxxxxxxxxxx", "id": {"id_message" : "something", "ddd" : "something"}}})
var response = ws.send(i);
setTimeout(function()
{
var response1 = ws.send(j);
}, 1000);
};
ws.onmessage = function (evt)
{
var received_msg = evt.data;
};
}
于 2016-05-22T13:54:43.380 回答