当前位置 博文首页 > Ruby实现邮件主动推送触发程序

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

    作者:admin 时间:2021-02-11 15:32

    邮件服务器接收到邮件后,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

    js
下一篇:没有了