复制代码代码如下:
var memcache = require ('memcache')
، http = طلب ('http')
، url = طلب ('url')
، qs = طلب ('QueryString')
، memsettings = {المنفذ: 2000 ، المضيف: '10 .6.0.6 '}
، httpsettings = {port: 3000}
، cacheObject = {}
، httpserver
، عميل
، requestHandler ؛
العميل = جديد memcache.client (memsettings.port ، memsettings.host) ؛
// ...
client.on ('connect' ، function () {
client.connected = true ؛
}) ؛
client.on ('Close' ، function () {
// لم يتم إغلاق الاتصال - تم إغلاق الاتصال
client.connected = false ؛
}) ؛
وظيفة getData (المفتاح ، الغلاف ، الدقة) {
client.get (مفتاح ، وظيفة (خطأ ، نتيجة) {
// جميع عمليات الاسترجاعات لها وسيطتين.
// قد تحتوي "النتيجة" على أشياء ليست رائعة ، ولكن
// ليست أخطاء حقًا ، مثل "not_stored"
إذا (! خطأ) {
إذا (النتيجة) {
cacheObject [key] = النتيجة ؛
Res.Write (Wrapper + '(' + result + ')') ؛
} آخر {
Res.Write ('no data') ؛
}
res.end () ؛
}
}) ؛
/*if (cacheObject [key]) {
استجابة. write (cacheObject [key]) ؛
استجابة.
} آخر {
client.get (مفتاح ، وظيفة (خطأ ، نتيجة) {
// جميع عمليات الاسترجاعات لها وسيطتين.
// قد تحتوي "النتيجة" على أشياء ليست رائعة ، ولكن
// ليست أخطاء حقًا ، مثل "not_stored"
إذا (! خطأ) {
cacheObject [key] = النتيجة ؛
cacheObject [KEY] ['timeoutid'] = setTimeOut (function () {
client.get (مفتاح ، وظيفة (خطأ ، نتيجة) {
إذا (! خطأ) {
cacheObject [key] = النتيجة ؛
}
}) ؛
}) ؛
استجابة. write (نتيجة) ؛
استجابة.
}
}) ؛
}*/
}
httpserver = http.createserver (function (req ، res) {
var urlobj ، QueryObj ؛
urlobj = url.parse (req.url) ؛
Res.Writehead (200 ، {"content-type": "text/javaScript ؛ charset = utf-8"}) ؛
QueryObj = qs.parse (urlobj.query) ؛
path = QueryObj.PathName ؛
if (QueryObj.gid) {
getData (queryobj.gid ، queryobj.callback || 'callback' ، res) ؛
} آخر {
Res.Write ("لا مدخلات") ؛
res.end () ؛
}
/*
التبديل (urlobj.pathname) {
القضية "/باي":
Res.Write (urlobj.pathname) ؛
استراحة؛
حالة "/تشيانغ":
Res.Write (urlobj.pathname) ؛
استراحة؛
تقصير:
Res.Write ('Default') ؛
استراحة؛
}
res.end () ؛
*/
}) ؛
client.connect () ؛
httpserver.listen (httpsettings.port) ؛
console.log ('http server الاستماع على' + httpsettings.port) ؛