var net = require('net');
var SmtpClient = exports.SmtpClient =function(host,port,useSecure){
this.host = host;
this.port = port||25;
this.socket = new net.Stream();
var self = this;
this.operationing = [];
this.socket.addListener('data',function(data){
var dataStr = data.toString();
console.log(dataStr);
var msg = !/([^ ]+)$/.test(dataStr)||RegExp.$1;
var code = (dataStr.match(/^\d+/g)||[""])[0];
switch(code) {
case "250":
var operation = self.operationing.pop();
if(operation == "connect") {
self.connected = true;
self.handleEvent("connect");
} else if(operation == "from") {
self.handleEvent("from");
} else if(operation == "lastrcpt") {
self.handleEvent("rcptok");
} else if(operation == 'transferdata') {
self.handleEvent("exit");
}
break;
case "334":
var operation = self.operationing.pop();
if(operation == "dataCommand") {
self.handleEvent("startData");
} else {
self.operationing.push(operation);
}
var key = new Buffer(msg,"base64").toString().toLowerCase();
self.handleEvent(key);
break;
case "235" :
self.authed = true;
self.handleEvent("authed");
break;
case "221" :
self.socket.end();
break;
}
});
if(useSecure) {
this.socket.setSecure();
}
this.listeners = {};
}
SmtpClient.prototype = {
send : function() {
this.socket.connect(this.port,this.host);
var self = this;
this.socket.addListener('connect',function() {
self.operationing.push("connect");
self.socket.write("HELO\r\n");
});
},
auth : function(username,password) {
var needAuth = !!username;
this.options = {
username:username,
password:password
};
if(needAuth) {
var self = this;
this.addListener("connect",function() {
if(!self.authed) {
self.socket.write("AUTH LOGIN\r\n");
}
});
} else {
this.authed = true;
this.handleEvent('authed');
}
},
addListener : function(eventName,listenerFunc) {
var ary = this.listeners[eventName]?this.listeners[eventName]:(this.listeners[eventName]=[]);
ary.push(listenerFunc);
this.handleEvent(eventName,listenerFunc)
},
sendTo : function(nameAry) {
var self = this;
for(var i=0;i<nameAry.length;i++) {
var name = nameAry[i];
(function(name,isLast) {
self.addListener("from",function() {
if(isLast) {
self.operationing.push("lastrcpt");
} else {
self.operationing.push("notlastrcpt");
}
self.socket.write("RCPT TO:"+name+"\r\n");
});
})(name,i==nameAry.length-1);
}
},
from : function(addr) {
var self = this;
this.addListener("authed",function() {
self.operationing.push("from");
self.socket.write("MAIL FROM:"+addr+"\r\n");
});
},
handleEvent : function(eventName,func) {
if(eventName.indexOf("username")>=0) {
this.socket.write(new Buffer(this.options.username).toString("base64")+"\r\n");
}
if(eventName.indexOf("password")>=0) {
this.socket.write(new Buffer(this.options.password).toString("base64")+"\r\n");
}
if(eventName == "exit") {
this.socket.write("QUIT\r\n");
}
if((eventName == "connect"||
eventName == "authed"||
eventName == "from"||
eventName == "rcptok"||
eventName =="startData")&&this.connected) {
if(func) {
func();
} else {
var funcs = this.listeners[eventName];
for(var i=0;funcs&&(i<funcs.length);i++) {
funcs[i]();
}
}
}
},
data : function(data) {
var self = this;
this.addListener("rcptok",function() {
self.operationing.push("dataCommand");
self.socket.write("DATA\r\n");
self.addListener("startData",function() {
self.operationing.push("transferdata");
self.socket.write(data+"\r\n.\r\n");
});
});
}
}
调用时:
var mail = require("./mail");
var sc = new mail.SmtpClient("202.108.3.190");//host[,port,ifssl]
//var sc = new mail.SmtpClient("x.x.x.x",465,true);
sc.auth("xxxxx","xxxx");
sc.sendTo(["xxx@xxx","xxx@xxx","xxx@xxx"]);
sc.from("xxx@xxx");
sc.data("From: FuLi <perfectrobin@sina.com>\r\n"+
"Subject: Smtp Client implementation\r\n"+
"To: xxx@xxx.xx\r\n"+
"Content-type: text/html\r\n"+
"Content-transfer-encoding: 8BIT\r\n<h1>This is a javascript implemented smtp client</h1>");
sc.send();
分享到:
相关推荐
1.项目代码功能经验证ok,确保稳定可靠运行。欢迎下载使用! 2.主要针对各个计算机相关专业,包括计科、信息安全、数据科学与大数据...基于Nodejs实现的客户端桌面端影音管理软件源码(服务端+客户端)-期末大作业.zip
node-websocket-client, NodeJS的Web Socket客户端 一个 Prototype Web Socket 客户端实现 node.js 。测试 miksago/node-websocket-server v1.2.00.需要 nodejs 0.1.98或者更高版本。安装按如下方式使用 np
python3和nodejs可用的OPC客户端(OPC DA)
node-whois, 用于NodeJS的简单WHOIS客户端 node node WHOIS是 Node.js.的WHOIS客户端安装全局$ npm install -g whois用法whois [options] addressOptions:
用 nodejs 语言、mqtt 协议写的客户端,通过主题发送数据并接收数据。资源描述要凑满 50 个字????????????
基于angular.js,weui和node.js重写的新闻客户端
emailjs-smtp-client, 用于 node.js 和浏览器运行时的SMTP客户端 电子邮件客户端 SMTP客户端允许你将数据连接到浏览器中的SMTP服务器并将数据流到该服务器。 API安装:npm install emailjs-smtp-client使用以下方法...
NULL 博文链接:https://21jhf.iteye.com/blog/2139906
iot-nodejs, 使用nodejs连接到IBM的客户端库和示例 node.js-客户端库node.js 客户机用于简化与Things平台的交互。 以下库包含有关使用 nodejs ibmiotf node 与组织内的设备和应用程序进行交互的说明和指导。客户端库...
一个用NodeJS实现的Ftp Servce
nodejs简易聊天室 消息推送
本篇文章主要介绍了nodejs mysql 实现分页的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
柚子节点客户端 nodejs 中的 pomelo 客户端库。
emailjs, html电子邮件和附件到任何具有nodejs的smtp服务器 emailjs 将电子邮件。html和附件( 文件,流和字符串) 从 node.js 发送到任何smtp服务器安装npm install emailjs特性使用SSL和 TLS smtp服务器支持smt
本文实例讲述了通过node.js的net模块实现nodejs socket服务端和客户端简单通信功能,可以用作客户端对服务端的端口监听以及事件回执。 server端代码 var net = require('net'); //模块引入 var listenPort = 8080;/...
nodejs构造和服务端连接的客户端,用于构造长连接,发送并且接受数据,实现数据的传递
Node.js客户端。 安装 $ npm install influxdb - nodejs 例子 查看目录以获取工作示例。 原料药 新客户 // no auth const Influx = require ( 'influxdb-nodejs' ) ; const client = new Influx ( '...
http://blog.csdn.net/gzy11/article/details/54949531 此篇文章示列代码