欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Ruby实现邮件主动推送触发程序

程序员文章站 2022-05-25 22:29:51
邮件服务器接收到邮件后,service push通知程序。有什么办法实现吗? 1、客户端轮询 2、服务器主动推送。 首先熟悉一下,收发邮件的协议: net::sm...

邮件服务器接收到邮件后,service push通知程序。有什么办法实现吗?

1、客户端轮询
2、服务器主动推送。

首先熟悉一下,收发邮件的协议:
net::smtp(发送邮件)
net::pop3(接收邮件)
net::imap(接收邮件)

网上很多用pop3收邮件的例子,但是用pop3收邮件只能获取收件箱里面所有邮件,邮件是否已读等标记无法获取,使用imap协议则避免了这个尴尬,imap不仅能获得一个邮件的详细信息(比如是否已读,是否回复),它还允许用户更改邮件的标记,但是目前支持imap协议的邮件服务器并不多,我知道的只有21cn和gmail,下面的例子中使用了代理 、ssl认证多个内容,请大家参考。

imap邮件,都是按需索取,也就是说,当你得到一个message的对象时,其实里面什么信息都没有,当你在这个对象里用get方法取得信息时,比如getsubject,那么message对象会重新访问邮件服务器来得到这个消息的 ,所以在得到所有所需信息之前,不可以关闭目录,更不可以断开连接。
如果实在想在关闭目录或者连接后操作message对象的话,需要使用folder对象的fetch方法得到所需信息。

一:客户端轮询

下边用pop3和imap显示一下轮询访问获取邮件的例子:

pop3轮询:

复制代码 代码如下:

loop do
require 'net/pop'
pop = net::pop3.new('emailservice')
pop.start('usename', 'password')           
if pop.mails.empty?
  puts 'no mail.'
else
  pop.each_mail do |m|
    m.pop do |chunk|  
      p chunk
    end
  end
  puts "#{pop.mails.size} mails popped."
end
pop.finish
sleep(10)
end

imap轮询:

复制代码 代码如下:

loop do
require 'net/imap'
imap = net::imap.new('emailservice')
imap.login "username", "password"
imap.examine('inbox')
imap.search(["before", "29-oct-2014", "since", "28-oct-2014"]).each do |message_id|
   envelope = imap.fetch(message_id, "envelope")[0].attr["envelope"]
   puts "#{envelope.from[0].name}: \t#{envelope.subject}"
end
sleep(10)
end

二:服务器主动推送

下边实现一种服务器主动推送方式:(imap.idle)

这是一种介于pull和persistent tcp/ip之间的技术:long polling(长轮询)。原理是客户端每次对服务的请求都被服务端hold住,等到有message返回或time out之后,会再次主动发起请求,等待message的到达。这种模式不需要保持心跳,也不需要持续tcp的占用,比较适合页面端及时消息的推送。

复制代码 代码如下:

server = 'emailservice'
username = 'username'
pw = 'password'
require 'net/imap'

# extend support for idle command. see online.
# http://www.ruby-forum.com/topic/50828
# https://gist.github.com/jem/2783772
# but that was wrong. see /opt/ruby-1.9.1-p243/lib/net/imap.rb.
class net::imap
  def idle
    cmd = "idle"
    synchronize do
      @idle_tag = generate_tag
      put_string(@idle_tag + " " + cmd)
      put_string(crlf)
    end
  end

  def say_done
    cmd = "done"
    synchronize do
      put_string(cmd)
      put_string(crlf)
    end
  end

  def await_done_confirmation
    synchronize do
      get_tagged_response(@idle_tag, nil)
      puts 'just got confirmation'
    end
  end
end

class remailer
  attr_reader :imap

  public
  def initialize
    @imap = nil
    @mailer = nil
    start_imap
  end

  def tidy
    stop_imap
  end

  def print_pust
       envelope = @imap.fetch(-1, "envelope")[0].attr["envelope"]
       puts "from:#{envelope.from[0].name}\t subject: #{envelope.subject}"
  end

  def bounce_idle
    # bounces the idle command.
    @imap.say_done
    @imap.await_done_confirmation
    # do a manual check, just in case things aren't working properly.
    @imap.idle
  end

  private
  def start_imap
    @imap = net::imap.new('pop.i-click.com')
    @imap.login username, pw
    @imap.select 'inbox'

    # add handler.
    @imap.add_response_handler do |resp|
      if resp.kind_of?(net::imap::untaggedresponse) and resp.name == "exists"
        @imap.say_done
        thread.new do
          @imap.await_done_confirmation
          print_pust
          @imap.idle
        end
      end
    end
    @imap.idle
  end

  def stop_imap
    @imap.done
  end

end

begin
  net::imap.debug = true
  r = remailer.new
  loop do
    puts 'bouncing...'
    r.bounce_idle
    sleep 15*60
    #一般设置15分钟无操作保持长链接
  end
ensure
  r.tidy
end