1, for nodejs, 执行
$ sudo npm install dnode
2, for php, 利用composer来安装DNode php
执行穗亏下列语句下载composer
$ wget http://getcomposer.org/composer.phar
创建一个文件composer.json,然后填入如下语句,
{
"require": {
"dnode/dnode": "0.2.0"
}
}
执行猜茄神如下语句安装,
$ sudo php composer.phar install
二,利用nodejs创建简单server程序, server.js
var dnode = require('dnode')
var server = dnode({
zing: function (n, cb) { cb(n * 100) }
})
server.listen(7070)
三,利用php创建客户端程序client.php, 其中需要引用刚才安装的dnode文件夹里面的文件autoload.php
<?php
// Connect to DNode server running in port 7070 and call
// Zing with argument 33
require 'lib/vendor/autoload.php'
// This is the class we're exposing to DNode
class Temp
{
// Compute the client's temperature and stuff that value into the callback
public function temperature($cb)
{
}
}
$loop = new React\EventLoop\StreamSelectLoop()
$dnode = new DNode\DNode($loop, new Temp())
$dnode->connect(7070, function($remote, $connection) {
//纳档 Remote is a proxy object that provides us all methods
// from the server
$remote->zing(33, function($n) use ($connection) {
echo "n = {$n}\n"
// Once we have the result we can close the connection
$connection->end()
})
})
$loop->run()
?>
文件 I/O 是由简单封装的标准 POSIX 函数提供的。 通过 require('fs') 使用该模块,所有的方法都有异步和同步的形式。
异步形式始终以完成回调作为它最后一个参数,传给完成回调的参数取决于具体方法,但第一个参数总是留给异常,如果 *** 作成功完成,则第一个参数会是 null 或 undefined。
当使用同步形式时,任何异常都会被立即抛出。 可以使用 try/catch 来处理异常,或让它们往上冒泡。
异步方法不保证执行顺序。 所以下面的例子容易出错:
fs.stat 可能在 fs.rename 之前执行,正确的方法是把回调链起来。
推荐开发者使用这些函数的异步版本。 同步版本会阻塞整个进程喊银,直到它们完成(停止所有连接)。弯和
【fs.open(path, flags[, mode], callback)】参数如下:
flags可以是:
[注意]使用'rs+'模式不会使fs.open()进入同步阻塞调用。如果那是你想要的,则应该使用fs.openSync()。
文件的回调函数中的第二个参数fd代表文件标识,与定时器标识类似,用于标识文件,且随着文件的打开顺序递增。
【fs.openSync(path, flags[, mode])】
fs.open() 的同步版本。 返回一个表示文件描述符的整数。
【fs.read(fd, buffer, offset, length, position, callback)】参数如下:
由于使用read()方法,会将文件内容读取buffer对象中,所以需要提前先准备一个buffer对象。
【fs.readSync(fd, buffer, offset, length, position)】
fs.read() 的同步版本,返回 bytesRead 的数量
【fs.write(fd, buffer, offset, length[, position], callback)】参数如下:
[注意]多次对同一文件使用fs.write且不等待回调,是不安全的。对于这种情况,强烈推荐使用 fs.createWriteStream。
当我们要对打开的文件进行写 *** 作的时候,打开文件的模式应郑闹宴该是读写模式。
【fs.write(fd, data[, position[, encoding]], callback)】
该方法写入data到fd指定的文件。如果data不是一个Buffer实例,则该值将被强制转换为一个字符串。
不同于写入 buffer,该方法整个字符串必须被写入。不能指定子字符串,这是因为结果数据的字节偏移量可能与字符串的偏移量不同。
【fs.writeSync()】
fs.write() 的同步版本,返回写入的字节数。
【fs.close(fd, callback)】参数如下:
一个文件被 *** 作后,要及时将该文件关闭
【fs.closeSync(fd)】
fs.close(fd, callback)的同步版本,返回undefined
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)