NodeJS Request与文件上传下载流相关
本文转载自 https://segmentfault.com/a/1190000000385867
使用超简单
Request使用超简单,同时支持https和重定向。
var request = require('request');
request('http://www.google.com', function (error, response, body) {
if (!error && response.statusCode == 200) {
console.log(body) // 打印google首页
}
})
流
任何响应都可以输出到文件流。
request('http://google.com/doodle.png').pipe(fs.createWriteStream('doodle.png'))
反过来,也可以将文件传给PUT或POST请求。未提供header的情况下,会检测文件后缀名,在PUT请求中设置相应的content-type
。
fs.createReadStream('file.json').pipe(request.put('http://mysite.com/obj.json'))
请求也可以pipe
给自己。这种情况下会保留原content-type
和content-length
。
request.get('http://google.com/img.png').pipe(request.put('http://mysite.com/img.png'))
表单
request
支持application/x-www-form-urlencoded
和multipart/form-data
实现表单上传。
x-www-form-urlencoded
很简单:
request.post('http://service.com/upload', {form:{key:'value'}})
或者:
request.post('http://service.com/upload').form({key:'value'})
使用multipart/form-data
不用操心设置header之类的琐事,request
会帮你解决。
var r = request.post('http://service.com/upload')
var form = r.form()
form.append('my_field', 'my_value')
form.append('my_buffer', new Buffer([1, 2, 3]))
form.append('my_file', fs.createReadStream(path.join(__dirname, 'doodle.png'))
form.append('remote_file', request('http://google.com/doodle.png'))
HTTP认证
request.get('http://some.server.com/').auth('username', 'password', false);
或
request.get('http://some.server.com/', {
'auth': {
'user': 'username',
'pass': 'password',
'sendImmediately': false
}
});
sendImmediately
,默认为真,发送一个基本的认证header。设为false
之后,收到401
会重试(服务器的401响应必须包含WWW-Authenticate
指定认证方法)。
sendImmediately为真时支持Digest认证。
OAuth登录
// Twitter OAuth
var qs = require('querystring')
, oauth =
{ callback: 'http://mysite.com/callback/'
, consumer_key: CONSUMER_KEY
, consumer_secret: CONSUMER_SECRET
}
, url = 'https://api.twitter.com/oauth/request_token'
;
request.post({url:url, oauth:oauth}, function (e, r, body) {
// Ideally, you would take the body in the response
// and construct a URL that a user clicks on (like a sign in button).
// The verifier is only available in the response after a user has
// verified with twitter that they are authorizing your app.
var access_token = qs.parse(body)
, oauth =
{ consumer_key: CONSUMER_KEY
, consumer_secret: CONSUMER_SECRET
, token: access_token.oauth_token
, verifier: access_token.oauth_verifier
}
, url = 'https://api.twitter.com/oauth/access_token'
;
request.post({url:url, oauth:oauth}, function (e, r, body) {
var perm_token = qs.parse(body)
, oauth =
{ consumer_key: CONSUMER_KEY
, consumer_secret: CONSUMER_SECRET
, token: perm_token.oauth_token
, token_secret: perm_token.oauth_token_secret
}
, url = 'https://api.twitter.com/1/users/show.json?'
, params =
{ screen_name: perm_token.screen_name
, user_id: perm_token.user_id
}
;
url += qs.stringify(params)
request.get({url:url, oauth:oauth, json:true}, function (e, r, user) {
console.log(user)
})
})
})
定制HTTP header
User-Agent
之类可以在options
对象中设置。在下面的例子中,我们调用github API找出某仓库的收藏数和派生数。我们使用了定制的User-Agent
和https.
var request = require('request');
var options = {
url: 'https://api.github.com/repos/mikeal/request',
headers: {
'User-Agent': 'request'
}
};
function callback(error, response, body) {
if (!error && response.statusCode == 200) {
var info = JSON.parse(body);
console.log(info.stargazers_count + " Stars");
console.log(info.forks_count + " Forks");
}
}
request(options, callback);
cookies
默认情况下,cookies是禁用的。在defaults
或options
将jar
设为true
,使后续的请求都使用cookie.
var request = request.defaults({jar: true})
request('http://www.google.com', function () {
request('http://images.google.com')
})
通过创建request.jar()
的新实例,可以使用定制的cookie,而不是request
全局的cookie jar。
var j = request.jar()
var request = request.defaults({jar:j})
request('http://www.google.com', function () {
request('http://images.google.com')
})
或者
var j = request.jar()
var cookie = request.cookie('your_cookie_here')
j.setCookie(cookie, uri, function (err, cookie){})
request({url: 'http://www.google.com', jar: j}, function () {
request('http://images.google.com')
})
注意,setCookie
至少需要三个参数,最后一个是回调函数。
NodeJS request 使用方法
安装
npm install --save request
GET请求
var request = require(‘request’);
request(‘http://www.baidu.com’, function (error, response, body) {
if (!error && response.statusCode == 200) {
console.log(body) // Show the HTML for the baidu homepage.
}
})
POST application/json
request({
url: url,
method: “POST”,
json: true,
headers: {
“content-type”: “application/json”,
},
body: JSON.stringify(requestData)
}, function(error, response, body) {
if (!error && response.statusCode == 200) {
}
});
POST application/x-www-form-urlencoded
request.post({url:’http://service.com/upload’, form:{key:’value’}}, function(error, response, body) {
if (!error && response.statusCode == 200) {
}
})
POST multipart/form-data
var formData = {
// Pass a simple key-value pair
my_field: ‘my_value’,
// Pass data via Buffers
my_buffer: new Buffer([1, 2, 3]),
// Pass data via Streams
my_file: fs.createReadStream(__dirname + ‘/unicycle.jpg’),
};
request.post({url:’http://service.com/upload’, formData: formData}, function (error, response, body) {
if (!error && response.statusCode == 200) {
}
})
formData可以直接放key-value格式的数据,也可以放buffer,或者是通过流描述的文件。
Java 中使用 javascript 等脚本语言实现非编译逻辑分离
有些常改变的逻辑,或者配置性的逻辑,比如最近在项目中遇到的,开发环境与正式环境的 ip 地址,端口的不同。以及启动项、模块 Lazy loading 的部分代码,介于配置文件与代码之间的很多模糊的地方,其实可以用JRE 自带的 ScriptEngine 实现。
这部分半配置半程序的代码可以用JS 写到固定的相对目录下。用 FileReader 加载然后执行就可以了。
因为是动态语言,无需编译,在布署时可以直接修改部分参数,还可以用 require,甚至可以继承等一些高级语言语法来实现DRY(don’t repeat yourself)。
示例如下:
public class ScriptTest { public static void main(String[] args) throws Exception{ ScriptEngine engine = new ScriptEngineManager().getEngineByName("javascript"); Bindings bind = engine.createBindings(); bind.put("c", 3); engine.setBindings(bind, ScriptContext.ENGINE_SCOPE); engine.eval(jsStr); // engine.eval(new FileReader("f:/aaa.txt")); if(engine instanceof Invocable){ Invocable in = (Invocable) engine; Double result = (Double) in.invokeFunction("test", 1,2); System.out.println(result); } } static String jsStr = "function test(a,b){ return (a+b)*c;}"; }
发表于 03/09/2013 , 03:21 于分类 Java.
jQuery.getJSON 跨域问题
jQuery的 getJSON 方法可以本地或远程获取JSON 对象进行操作。
其基本格式是:
jQuery.getJSON(url,data,success(data,status,xhr))
在不跨域的情况下:只需要
$.getJSON("http://localhost/getBookInfo/100",{}, function(data){ $.each(data, function(k,v){ $("#bookinfo_" + k.replace(/\./g, '\\.') ).html(v)}) })
但是如果是跨域的,则需要加入参数 callback=?
$.getJSON("http://remotehost/getBookInfo/100?callback=?",{}, function(data){ $.each(data, function(k,v){ $("#bookinfo_" + k.replace(/\./g, '\\.') ).html(v)}) })
而服务器端需要将 data 包装一下后返回,
如原返回是 { “name” : “bookname”, “price”:”50.00″ , “sold”:”150″ }
则包装后为 request.getParam(“callback”)({ “name” : “bookname”, “price”:”50.00″ , “sold”:”150″ })
跨域时,jQuery 会自动生成一个script标签加载 远程服务器上的 JS,而 script 标签本身是可以跨域的。在script 外面包上执行某个方法,方法名由 callback 传入,则 jQuery 会自动定义一个名称类似jQuery16209379892267785707_1363072523219的方法,再将这个名称以 callback 的参数传至服务器。即
http://remotehost/getBookInfo/100?callback=jQuery16209379892267785707_1363072523219
服务器则需要将原有的 data 外加
jQuery16209379892267785707_1363072523219({ “name” : “bookname”, “price”:”50.00″ , “sold”:”150″ })
加载完该JS 后,浏览器便会执行该JS,从而实现远程的 json 调用。
说白了还是 script 标签 + 一个特定的参数,只是写法统一得像 ajax 请求而已。
导航fixed 功能,当然这是Prototype版,改天封装成JQuery版吧
(function(){
document.observe ( 'dom:loaded' , function () {
var navbar = $$(".navbar");
if(navbar.length<1)
return;
var offsetTopx = navbar[0].offsetTop;
window.onscroll = function(){
var scrollY = window.pageYOffset || document.documentElement.scrollTop;
if(scrollY>= offsetTopx)
{ navbar.invoke ( 'addClassName' , 'fixed_navbar' );}
else
{ navbar.invoke ( 'removeClassName' , 'fixed_navbar' );}
}
});
})();
css嘛就如下咯,我知道这不持低版本IE.. Ignore them : )
.fixed_navbar {
position: fixed;
top: 0;
}
转一篇, JQuery 与 Prototype 的使用异同
页面载入
// JQuery $ ( document ). ready ( function () { // Code });
// JQuery Shorthand $ ( function () { // Code });
// Prototype document . observe ( 'dom:loaded' , function () { // Code });
根据ID获取
// JQuery $ ( "#idname" );
// Prototype $ ( "idname" );
根据类名
// JQuery $ ( ".classname" );
// Prototype $$ ( '.classname' );
根据第一个符合的类名
// JQuery $ ( ".classname:first-child" );
// Prototype $$ ( '.classname' )[ 0 ];
根据ID绑定监听事件
// JQuery $ ( "#item" ). bind ( 'click' , function () { // Code }); // JQuery Shorthand $ ( "#item" ). click ( function () { // Code });
// Prototype $ ( "#item" ). observe ( 'click' , function () { // code });
根据符合的类名绑定监听事件
// JQuery $(".classname").bind('click',function(){ // code }); // JQuery Shorthand $ ( ".classname" ). click ( function () { // code });
// Prototype $$ ( ".classname" ). invoke ( 'observe' , 'click' , function () { // code });
结束终止事件
// JQuery $ ( "#id" ). click ( function () { //code return false ; });
// Prototype $ ( "id" ). observe ( 'click' , function ( e ) { //code Event . stop ( e ); });
处理观察的元素
// JQuery $ ( '#idname' ). click ( function () { this . hide (); // Hide the item clicked });
// Prototype $ ( 'idname' ). observe ( 'click' , function ( e ) { el = e . findElement ; el . hide (); // hide the item clicked });
根据ID操作类名
// JQuery $ ( '#id' ). addClass ( 'red' ); $ ( '#id' ). removeClass ( 'red' );
// Prototype $ ( 'id' ). addClassName ( 'red' ); $ ( 'id' ). removeClassName ( 'red' );
根据类名操作类名。。
// JQuery $ ( '.class' ). addClass ( 'red' ); $ ( '.class' ). removeClass ( 'red' );
// Prototype $$ ( '.class' ). invoke ( 'addClassName' , 'red' ); $$ ( '.class' ). invoke ( 'removeClassName' , 'red' );
AJAX请求和JSON应用
$.get(url,function(data){ alert(data . name ); }, 'JSON' );
// Prototype new Ajax . Request ( url , { method : 'get' , onSuccess : function ( transport , json ) { alert ( json . name ); } });
可以得出结论:jQuery和Prototype大部分是极为相似的,多用几次就都熟了。。