- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
在我的服务器端,我有套接字服务器在监听,在我自己的笔记本电脑上,我有 socket.io-client 服务,只要我打开它们,它们就会连接。
当其他人向我的服务器发出请求时,服务器通过套接字将该请求发送到我的笔记本电脑,我的笔记本电脑使用 npm-request 从本地主机获取数据并将返回的数据返回给服务器,然后服务器将该信息显示给客户端。
这是我服务器端的错误:
/*
throw er; // Unhandled 'error' event
^
**Error [ERR_STREAM_WRITE_AFTER_END]: write after end**
at write_ (_http_outgoing.js:572:17)
at ServerResponse.write (_http_outgoing.js:567:10)
at Socket.<anonymous> (/public_html/api/index.js:37:9)
at Socket.emit (events.js:187:15)
at /public_html/api/node_modules/socket.io/lib/socket.js:528:12
at process._tickCallback (internal/process/next_tick.js:61:11)
Emitted 'error' event at:
at writeAfterEndNT (_http_outgoing.js:634:7)
at process._tickCallback (internal/process/next_tick.js:63:19)
*/
服务器端代码:
var http = require('http');
var fs = require('fs');
var socket_g=null, numOfUsers=0;
var url = require('url'),qs = require('querystring');
var server = http.createServer(function(req, res) {
if(numOfUsers!=0){
var urlParts = url.parse(req.url, true),
urlParams = urlParts.query,
urlPathname = urlParts.pathname,
body = '',
reqInfo = {};
req.on('data', function (data) {
body += data;
});
req.on('end', function () {
reqInfo.urlPathname = urlPathname;
reqInfo.urlParams = urlParams;
reqInfo.body = qs.parse(body);
reqInfo.urlParts = urlParts;
console.log(reqInfo.urlPathname)
socket_g.emit('event', { "path": reqInfo.urlPathname});
});
socket_g.on('data',function(data){
console.log(data.c)
if(data.c=='application/x-httpd-php' || data.c=='/'){
res.writeHead(200, { 'Content-Type': 'text/html' });
res.write(data.data);
res.end();
}else{
res.writeHead(200, { 'Content-Type': data.c });
res.write(data.data);
res.end();
}
});
}else{
res.writeHead(200, { 'Content-Type': 'text/html' });
res.end("<h2>There is no client connected!</h2>");
}
});
var io = require('socket.io').listen(server);
io.sockets.setMaxListeners(0);
io.sockets.on('connection', function (socket) {
/*console msg*/
console.log('user connected!');
/*console msg*/
socket.setMaxListeners(0);
numOfUsers++;
socket_g=socket;
socket.on('disconnect', function(){
numOfUsers++;
/*console msg*/
console.log('user disconnected');
/*console msg*/
});
});
server.listen(3333);
And belove my client side code, which is working on my laptop
var socket = require('socket.io-client')('http://*.*.*.*:3333/');
var http=require("http");
var r = require('request');
var mime = require('mime');
var path = require('path');
socket.on('connect', function(){
console.log("connected");
});
socket.on('event', function(data){
console.log(mime.getType(path.extname(data.path).substr(1)));
var contentType=mime.getType(path.extname(data.path).substr(1));
r.get({url: "http://localhost/check"+data.path},
function(error, response, body){
//console.log(body);
if(contentType){
socket.emit('data', { "data": body,'c':contentType });
}
});
});
socket.on('disconnect', function(){
console.log("disconnected")
});
最佳答案
即使在返回响应后,您仍在收听“数据”事件。
使用 .once
为该特定请求监听一次事件。
socket_g.once("data", function(data) {
关于javascript - 错误 [ERR_STREAM_WRITE_AFTER_END] : write after end [npm-request with socket. io],我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52463577/
根本不是 SQL 人员。让顾问编写以下代码。 首先,它确保只选择了一所小学 - 然后,在 BEGIN 之后,如果变量 @Term 等于 3,我们想要在 IF 语句下执行操作。问题就在这里。当 @Ter
以下 javascript 将 bool 值呈现到每个语句的右侧: var reg = new RegExp(/^[\w\/].*result\b/); console.log(reg.test('p
有什么区别: x = 1 while x < 5 do x += 1 print x end 和: x = 1 while x < 5 x += 1 print x end 将 do
对于初学者来说,我是编程的“菜鸟”,所以只需了解事情的工作原理并向社区寻求帮助。 但是...我想知道的是: 我想要构建一个 Web 应用程序,两个主要用户界面之一实际上是日历产品。每个日历项目都有 8
我正在尝试制作带有图片上传选项的表单。我正在使用 express-http-proxy作为我的 API 代理和 multer按照建议。 app.use('/api', upload.any(), pr
根据this中的回答和 this问题,C++ 标准在 § 23.2.1 中声明 end() 对于所有 STL 容器都具有恒定的时间复杂度。 如果我理解正确的话: std::forward_list 只
当我使用 css 属性 align-items 时,我看不到 flex-end 值或 end 值有任何视觉差异>. align-items: end 和 align-items: flex-end 有
Sub RowRangeMove() Sheets.Add().Name = "CopySheet" With Sheets("BigDataSet - Copy")
假设第 1 到 5,000 列中有 25,000 到 50,000 行数据,每列可能有不同的行数。所有数据都是连续的,即列中没有空行,也没有空列。 考虑以下代码 Dim i As Long Dim W
我在 MYSQL 中有一个表,必须在 postgresql 中转换它。 我正在使用以下命令创建表格。 create table emp(COMPLETE BOOLEAN NOT NULL, END B
我正在尝试使用 Lark 为 BASIC 创建一个 LALR 解析器,而且我很难解决“END”语句和“END IF”等语句之间的冲突。这是语法的简化版本: %ignore /[ \t\f]+/ pro
试图理解this MSDN sample但我对这些行感到困惑: IAsyncResult result = Dns.BeginGetHostEntry(args[0], null, null); Co
我在 http://www.sgi.com/tech/stl/nth_element.html 阅读了 std::nth_element 的描述 template void nth_element(
为什么标准将 end() 定义为末尾,而不是实际末尾? 最佳答案 最好的论据是Dijkstra himself 提出的论据。 : 您希望范围的大小是一个简单的差异end - begin; 当序列退化为
我试图根据一些参数停止页面的其余部分加载;但不确定语法是否正确。 @if(dayRes + dayTri == 2){Sorry, etc @Response.End} 上面抛出这个错误: CS150
在二分搜索中,我们通常有 low 和 high 变量,并且通常有一个 while 循环来测试 low <= high,如以下代码所示(来自维基百科): int SortedArray[max] = {
我将 MS-Test 与 Visual Studio 2010 和 Visual Basic 结合使用。 在下面的函数中,代码覆盖率告诉我,有一个未检查的 block ,并且带有 “End Try”
所以今天我一直致力于使用 Protractor 为 Angular JS 应用程序设置端到端测试。为了编写更清晰的测试,我使用了 Protractor 网站上描述的 Page Object 模式。 测
所以 meteor js 的全部意义在于允许用户一次对整个堆栈进行编码,但是如果我正在使用像 django 这样的旧框架之一,可以借用meteor js的前端代码吗?比如前端的数据库同步,模板化,或者
我正在使用 wavesurfer.js 和 recorder.js 制作采样器。一切都很顺利,除了我无法使用 play([start[, end]]) 调整循环长度。 wavesurfer.seekT
我是一名优秀的程序员,十分优秀!