socketiojs11下载

『壹』 socketio 不是标准的websocket为什么java写的client端连不上

php有可用的websocket库，不需要php-fpm。
目前比较成熟的有swoole（swoole.com），和workman（workman.net）
swoole是c写的php扩展， 效率比nodejs还要高，workman是纯php实现，两者都号称可以实现并发百万TCP连接。
给你个例子：
这个要通过cmd运行的 具体带的参数有点忘记了
<?php
error_reporting(E_ALL);
set_time_limit(0);
ob_implicit_flush();

//创建一个socket连接 设置参数 绑定 监听 并且返回
$master = WebSocket("localhost",12345);

//标示是否已经进行过握手了
$is_shaked = false;

//是否已经关闭
$is_closed = true;

//将socket变为一个可用的socket

while(true){
//如果是关闭状态并且是没有握手的话 则创建一个可用的socket（貌似第二个条件可以去除）
if($is_closed && !$is_shaked){
if(($sock = socket_accept($master)) < 0){
echo "socket_accept() failed: reason: " . socket_strerror($sock) . "\n";
}

//将关闭状态修改为false
$is_closed = false;
}

//开始进行数据处理
process($sock);
}

//处理请求的函数
function process($socket){
//先从获取到全局变量
global $is_closed, $is_shaked;

//从socket中获取数据
$buffer = socket_read($socket,2048);

//如果buffer返回值为false并且已经握手的话 则断开连接
if(!$buffer && $is_shaked){
disconnect($socket);
}else{
//如果没有握手的话则握手 并且修改握手状态
if($is_shaked == false){
$return_str = dohandshake($buffer);
$is_shaked = true;
}else{
//如果已经握手的话则送入deal函数中进行相应处理
$data_str = decode($buffer); //解析出来的从前端送来的内容
console($data_str);
$return_str = encode(deal($socket, $data_str));
//$return_str = encode($data_str);
}

//将应该返回的字符串写入socket返回
socket_write($socket,$return_str,strlen($return_str));
}
}

function deal($socket, $msgObj){
$obj = json_decode($msgObj);
foreach($obj as $key=>$value){
if($key == 'close'){
disconnect($socket);
console('close success');
return 'close success';
}else if($key == 'msg'){
console($value."\n");
return $value;
}
}
}

//获取头部信息
function getheaders($req){
$r=$h=$o=null;
if(preg_match("/GET (.*) HTTP/" ,$req,$match)){ $r=$match[1]; }
if(preg_match("/Host: (.*)\r\n/" ,$req,$match)){ $h=$match[1]; }
if(preg_match("/Origin: (.*)\r\n/",$req,$match)){ $o=$match[1]; }
if(preg_match("/Sec-WebSocket-Key: (.*)\r\n/",$req,$match)){ $key=$match[1]; }
if(preg_match("/\r\n(.*?)\$/",$req,$match)){ $data=$match[1]; }
return array($r,$h,$o,$key,$data);
}

function WebSocket($address,$port){
$master=socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() failed");
socket_set_option($master, SOL_SOCKET, SO_REUSEADDR, 1) or die("socket_option() failed");
socket_bind($master, $address, $port) or die("socket_bind() failed");
socket_listen($master,20) or die("socket_listen() failed");
echo "Server Started : ".date('Y-m-d H:i:s')."\n";
echo "Master socket : ".$master."\n";
echo "Listening on : ".$address." port ".$port."\n\n";
return $master;
}

function dohandshake($buffer){
list($resource,$host,$origin,$key,$data) = getheaders($buffer);
echo "resource is $resource\n";
echo "origin is $origin\n";
echo "host is $host\n";
echo "key is $key\n\n";

$response_key = base64_encode(sha1($key.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));

$return_str = "HTTP/1.1 101 Switching Protocols\r\n".
"Upgrade: websocket\r\n".
"Connection: Upgrade\r\n".
"Sec-WebSocket-Accept: $response_key\r\n\r\n";
return $return_str;
}

function console($msg){
$msg = transToGBK($msg);
echo "$msg\n";
return $msg;
}

function decode($msg="") {
$mask = array();
$data = "";
$msg = unpack("H*",$msg);

$head = substr($msg[1],0,2);

if (hexdec($head{1}) === 8){
$data = false;
} else if (hexdec($head{1}) === 1){
$mask[] = hexdec(substr($msg[1],4,2));
$mask[] = hexdec(substr($msg[1],6,2));
$mask[] = hexdec(substr($msg[1],8,2));
$mask[] = hexdec(substr($msg[1],10,2));

$s = 12;
$e = strlen($msg[1])-2;
$n = 0;
for ($i= $s; $i<= $e; $i+= 2){
$data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2)));
$n++;
}
}

return $data;
}

function encode($msg=""){
$frame = array();
$frame[0] = "81";
$msg .= ' is ok';
$len = strlen($msg);
$frame[1] = $len<16?"0".dechex($len):dechex($len);
$frame[2] = ord_hex($msg);
$data = implode("",$frame);
return pack("H*", $data);
}

function transToGBK($s){//UTF8->GBK
//echo $s;
return iconv("UTF-8", "GBK", $s);
return $s;
}

function ord_hex($data){
$msg = "";
$l = strlen($data);

for ($i=0; $i<$l; $i++){
//ord是返回字符串第一个字符的ascii值
//dechex把十进制转换为十六进制
$msg .= dechex(ord($data{$i}));
}

return $msg;
}

function disconnect($socket){
global $is_shaked, $is_closed;
$is_shaked = false;
$is_closed = true;
socket_close($socket);
}
?>

『贰』 如何使用Socket.IO编写聊天应用程序

我们将首先通过查看客户端代码。所有聊天互动都有HomeView处理，首先需要在 /public/js/models/main.js中定义HomeModel。

var HomeModel = Backbone.Model.extend({
defaults: {
// Backbone collection for users
onlineUsers: new UserCollection(),

// Backbone collection for user chats, 初始化一个预定义聊天模型
userChats: new ChatCollection([
new ChatModel({sender: '', message: 'Chat Server v.1'})
])
},

// 添加一个新用户到 onlineUsers collection
addUser: function(username) {
this.get('onlineUsers').add(new UserModel({name: username}));
},

// 从onlineUsers collection中移除一个用户
removeUser: function(username) {
var onlineUsers = this.get('onlineUsers');
var u = onlineUsers.find(function(item) {
return item.get('name') == username;
});

if (u) {
onlineUsers.remove(u);
}
},

// 添加一个新的聊天到 userChats collection
addChat: function(chat) {
this.get('userChats').add(new ChatModel({sender: chat.sender, message: chat.message}));
},
});

我们利用Backbone集合来侦听集合变化。这些集合的更新会直接由视图自动反映出来。接下来，需要在/public/index.html中定义home模板。

<script type="text/template" id="home-template">
<div class="row">
<div class="col-md-10">
<div class="panel panel-default">
<div class="panel-heading">Lobby</div>
<div class="panel-body">
<div class="nano">
<div class="content">
<div class="list-group" id="chatList"></div>
</div>
</div>
<form>
<input class="form-control" type="text" id="chatInput"></input>
</form>
</div>
</div>
</div>
<div class="col-md-2">
<div class="panel panel-default">
<div class="panel-heading">
<h3 class="panel-title">Online Users <span class="badge pull-right" id="userCount"></span></h3>
</div>
<div class="panel-body">
<div class="nano">
<div class="content">
<div class="list-group" id="userList"></div>
</div>
</div>
</div>
</div>
</div>
</div>
</script>

聊天客户端

接下来，让我们来定义我们的Socket.IO聊天客户端。客户端与服务器端的通信，主要通过发送消息和监听通知来完成。这些通知触发事件与所述控制器进行通信。请参阅下面/public/JS/socketclient.js的代码。

var ChatClient = function(options) {
// 避免冲突
var self = this;

// app event bus
self.vent = options.vent;

// server hostname replace with your server's hostname eg: http://localhost
self.hostname = 'http://chatfree.herokuapp.com';

// connects to the server
self.connect = function() {
// connect to the host
self.socket = io.connect(self.hostname);

// set responseListeners on the socket
self.setResponseListeners(self.socket);
}

// send login message
self.login = function(name) {
self.socket.emit('login', name);
}

// send chat message
self.chat = function(chat) {
self.socket.emit('chat', chat);
}

self.setResponseListeners = function(socket) {
// handle messages from the server
socket.on('welcome', function(data) {
// request server info
socket.emit('onlineUsers');

self.vent.trigger('loginDone', data);
});

socket.on('loginNameExists', function(data) {
self.vent.trigger('loginNameExists', data);
});

socket.on('loginNameBad', function(data) {
self.vent.trigger('loginNameBad', data);
});

socket.on('onlineUsers', function(data) {
console.log(data);
self.vent.trigger('usersInfo', data);
});

socket.on('userJoined', function(data) {
self.vent.trigger('userJoined', data);
});

socket.on('userLeft', function(data) {
self.vent.trigger('userLeft', data);
});

socket.on('chat', function(data) {
self.vent.trigger('chatReceived', data);
});
}
}

使用Socket.IO可以非常简单的发送和接受通信数据，上面的代码中，使用了下面的两个方法

socket.emit(message, [callback])向服务器端发送消息

socket.on(message, callback) 用于接收来自服务器的消息

让我们来看一下他们的通信协议

主控制器

客户端最后一步，主控制器，它控制了VIEW，MODEL和socket客户端，代码在/public/js/main.js中

var MainController = function() {
var self = this;

// Event Bus for socket client
self.appEventBus = _.extend({}, Backbone.Events);
// Event Bus for Backbone Views
self.viewEventBus = _.extend({}, Backbone.Events);

// initialize function
self.init = function() {
// create a chat client and connect
self.chatClient = new ChatClient({vent: self.appEventBus});
self.chatClient.connect();

// create our views, place login view inside container first.
self.loginModel = new LoginModel();
self.containerModel = new ContainerModel({
viewState: new LoginView({
vent: self.viewEventBus,
model: self.loginModel
})
});
self.containerView = new ContainerView({model: self.containerModel});
self.containerView.render();
};

// View Event Bus Message Handlers
self.viewEventBus.on('login', function(name) {
// socketio login
self.chatClient.login(name);
});

self.viewEventBus.on('chat', function(chat) {
// socketio chat
self.chatClient.chat(chat);
});

// Socket Client Event Bus Message Handlers

// triggered when login success
self.appEventBus.on('loginDone', function() {
self.homeModel = new HomeModel();
self.homeView = new HomeView({vent: self.viewEventBus, model: self.homeModel});

// set viewstate to homeview
self.containerModel.set('viewState', self.homeView);
});

// triggered when login error e to bad name
self.appEventBus.on('loginNameBad', function(name) {
self.loginModel.set('error', 'Invalid Name');
});

// triggered when login error e to already existing name
self.appEventBus.on('loginNameExists', function(name) {
self.loginModel.set('error', 'Name already exists');
});

// triggered when client requests users info
// responds with an array of online users.
self.appEventBus.on('usersInfo', function(data) {
var onlineUsers = self.homeModel.get('onlineUsers');
var users = _.map(data, function(item) {
return new UserModel({name: item});
});

onlineUsers.reset(users);
});

// triggered when a client joins the server
self.appEventBus.on('userJoined', function(username) {
self.homeModel.addUser(username);
self.homeModel.addChat({sender: '', message: username + ' joined room.'});
});

// triggered when a client leaves the server
self.appEventBus.on('userLeft', function(username) {
self.homeModel.removeUser(username);
self.homeModel.addChat({sender: '', message: username + ' left room.'});
});

// triggered when chat receieved
self.appEventBus.on('chatReceived', function(chat) {
self.homeModel.addChat(chat);
});
}

最后，我们需要定义一个MainController入口，调用init方法，代码位于/public/js/main.js中

聊天服务器端

应用程序的最后一部分是聊天服务器。它主要负责维护在线用户列表，广播聊天消息。比如，首先，服务器会给一个新的客户的连接请求命名，然后通过刚刚建立的socket，连接事件handlers。socket handler处理如下事件： socket.on(message, callback) - 在收到新邮件时回调函数被调用。消息可以是任何类型的数据，这取决于发送的消息。 socket.on('disconnect', callback) - 当socket断开连接时候，回调函数被调用。 socket.emit(message, args) - 通过socket发送消息。 socket.broadcast.send(message, args) - 广播信息到除发送者之外的所有socket。现在，我们已经看到了handler socket是如何工作的。首先，需要在/scripts/chatserver.js中定义一个用户模型 ：

总结

我们已经看到了如何使用Backbone和Socket.IO构建一个简单的聊天应用程序。还有很多没有在本文中涉及的Socket.IO性能，例如rooms和namespaces。通过这篇文章，我们可以看出使用Socket.IO很容易的在客户端和服务器端交换消息。

『叁』 Socket.io中怎么知道emit有没有执行成功

页面JS：
……
socket.emit('nickname','张三',function(data){
if(data){
console.log('Nicknamesetsuccessfully');
}
});
服务端：
……
socket.on('nickname',function(data,callback){
callback(data);
});

『肆』 前台h5 Socket.Io.js做客户端，服务器用Tomcat，java后台怎么实现通讯。也是用socketio吗上详细代码。

socket.io封装了websocket，同时包含了其它的连接方式，比如Ajax。原因在于不是所有的浏览器都支持websocket，通过socket.io的封装，你不用关心里面用了什么连接方式。
你在任何浏览器里都可以使用socket.io来建立异步的连接。socket.io包含了服务端和客户端的库，如果在浏览器中使用了socket.io的js，服务端也必须同样适用。如果你很清楚你需要的就是websocket，那可以直接使用websocket

『伍』 cocos2d-js中的socketio部分是不是只适合native部分，不适合web

Cocos2d-JS为纯Web开发者提供了特别定制的一套更友好的工作流，对于这些开发者来说，如果Cocos2d-JS可以像其他Web框架一样用单个文件被引入到用户页面中并可以直接使用的话，会更符合他们的开发习惯。而Cocos2d-JS引擎包看上去对于Web开发者来说实在是太庞大和复杂了，对于Web开发者来说，就好像被扔进了一个巨大的迷宫，完全不知道从哪下手。这甚至会给开发者一种错误的认知："Cocos2d-JS是一个非常重的引擎，不适合做Web游戏开发。"

实际上，在Cocos2d-JS的Web引擎实现模块化之后，可以非常优美得做到既强大又轻量。也正是以上原因，促使我们推出了Lite Version以及专为Lite Version定制的工作流供纯Web开发者使用。

『陆』 nodejs socketio的问题

估计是前端代码没有触发。贴一下前端的关键代码。

『柒』 不用nodejs可以用socketio吗

方法/步骤 点击右上部，打开配置界面 选择调试Node.js 配置需要调试的Node.js程序的入口app.js 开始设置断点和调试 5 也可以在程序中使用console.log，在控制台中输出

『捌』 不用nodejs可以用socketio吗

socketio是nodejs的一个库，相当于别人利用nodejs的函数封装了一些功能给你使用，依赖与nodejs的一些api，所以只能在nodejs下用。
其它语言可以搜索相应语言的库

『玖』 nodejs 怎么手动触发socketio disconnection事件

socketio是nodejs的一个库，相当于别人利用nodejs的函数封装了一些功能给你使用，依赖与nodejs的一些api，所以只能在nodejs下用。 其它语言可以搜索相应语言的库