`

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

    博客分类:
  • RUBY
阅读更多
邮件服务器接收到邮件后,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
0
0
分享到:
评论

相关推荐

    Ruby-CelluloidIO实现的Web服务器

    3. **WebSocket支持**:Reel还提供了WebSocket协议的支持,这使得它非常适合于实时应用,如聊天室、在线游戏或者推送通知服务。 4. **易于调试和测试**:由于Reel基于Celluloid,它的错误处理和日志记录都相当出色...

    Ruby-WebsocketRailsrubyonrails的即插即用websocket支持

    3. **双向通信**:WebSocket协议允许服务器和客户端双向通信,这意味着数据可以同时从服务器推送到客户端,而不仅仅是客户端发起请求。`Websocket-Rails`很好地利用了这一特性,使得实时推送成为可能。 4. **兼容性...

    ZeroMQ 云时代极速消息通信库

    - **日志收集**:将分散在各处的日志数据推送到中央日志服务器进行分析。 - **监控系统**:用于监控系统的状态变化,触发相应的报警或处理流程。 **5. 集成与实践** 集成 ZeroMQ 到项目中,通常需要选择一个绑定库...

    apple_is_dead.rb:苹果のサービスの生死をコミットします

    5. **通知系统**: `notice`可能是通知用户的机制,这可能涉及到邮件通知、推送通知或日志记录。如果涉及到JavaScript,可能是在用户浏览器端使用Web通知API或者通过WebSocket实现实时更新。 6. **API接口**: 如果...

    notify-me

    此外,对于"notify-me"这样的应用,可能还需要理解通知系统的工作原理,例如如何触发通知、通知的类型、以及如何通过邮件或推送服务发送通知等。 这个项目的源代码可能涉及到的技术点还包括AJAX(异步JavaScript和...

    cucumber:我正在 ubuntu 上测试与 git、capybara、cucumber、siteprism 和 jenkins 的集成

    配置好Git后,可以克隆项目仓库,进行提交和推送操作。 **Capybara** 是Ruby语言的一个库,用于集成测试Web应用程序。它模拟用户行为,如点击链接、填写表单等。Capybara与不同的浏览器驱动器(如Selenium)兼容,...

    realtime-server:Realtime-rails gem的实时Node.js服务器。 查看网站

    此gem利用了WebSocket技术,这是一种双向通信协议,使得服务器可以主动推送数据到客户端,而无需客户端不断地轮询请求。WebSocket极大地减少了网络延迟,提高了数据传输效率。 在标题提到的"Realtime-rails gem的...

    heroku-sf-connect:heroku SF 连接使用插件

    5. **事件驱动编程**: 利用Salesforce的事件推送机制,可以在Heroku上实时响应Salesforce中的事件,如新记录创建、更新或删除。 ### 三、安装和配置 Heroku-SF-Connect 1. **Heroku CLI**: 首先确保已安装Heroku...

    heroku-app

    - 将你的应用推送到Heroku:`git push heroku main` - 配置环境变量(如数据库连接字符串),使用`heroku config:set VAR_NAME=VALUE` - 启动应用:`heroku ps:scale web=1` **5. 数据库和存储** Heroku提供了...

    rails50:使用Rails 5进行敏捷Web开发的源代码-web development source code

    这使得开发者可以轻松地添加推送通知、实时聊天等功能到Rails应用中。 六、Rails CLI:命令行工具增强 Rails命令行工具在5.0版本中变得更加友好和强大,如`rails new`命令可以自定义更多配置选项,而`rails ...

    gitactionsAppiumPOC

    这个文件会指定何时触发工作流(例如,每次代码推送),以及工作流执行的具体步骤(如安装依赖、运行测试等)。 5. **自动化测试脚本**: 使用Appium编写测试脚本,通常会包括元素定位、模拟用户交互、断言等操作。...

    cloudconfig

    配置变更时,只需要更新代码,再将新的配置推送到服务器,即可实现自动化部署和更新。 3. 常用工具介绍: - Chef:使用Ruby语言编写,以资源为中心,强调基础设施即代码。 - Puppet:采用声明式语言,支持跨平台...

    FaaS-GraalVM-Env

    5. **功能转轮**: 在FaaS环境中,"功能转轮"可能是指一系列可复用的服务或函数,这些函数可以被调用来处理特定任务,例如数据处理、消息推送等。 6. **GraalVM构建**: 使用GraalVM来构建函数,可以利用其高效的编译...

Global site tag (gtag.js) - Google Analytics