Golang Gmail IMAP搜索冻结了。

huangapple
go评论117阅读模式
英文:

Golang Gmail imap search is freezing

问题

我正在尝试搜索特定发件人或特定标记。当我选择收件箱并在特定字符串上进行搜索时，搜索 API 会冻结。我不确定我做错了什么。我也找不到太多的示例。

  1. criteria := imap.NewSearchCriteria()
  2. criteria.WithoutFlags = []string{"\\Seen"}
  3. uids, err := c.Search(criteria)
  4. if err != nil {
  5.  log.Println(err)
  6. }
  7. seqset := new(imap.SeqSet)
  8. seqset.AddNum(uids...)
  9. section := &imap.BodySectionName{}
  10. items := []imap.FetchItem{imap.FetchEnvelope, imap.FetchFlags, imap.FetchInternalDate, section.FetchItem()}
  11. messages := make(chan *imap.Message)
  12. go func() {
  13.     done <- c.Fetch(seqset, items, messages)
  14. }()
  15. msg := <-messages // 它在这一点上被卡住了。什么都不会发生，我收不到消息。

请注意，这是一段代码，我只翻译了其中的注释部分。

英文:

I am trying to do a search for specific sender or specific flag. When I select Inbox and do a search on specific string the search api freezes. I am not sure what am I doing wrong. I am not able to find much examples too.

  1. criteria := imap.NewSearchCriteria()
  2. criteria.WithoutFlags = []string{&quot;\\Seen&quot;}
  3. uids, err := c.Search(criteria)
  4. if err != nil {
  5.  log.Println(err)
  6. }
  7. seqset := new(imap.SeqSet)
  8. seqset.AddNum(uids...)
  9. section := &amp;imap.BodySectionName{}
  10. items := []imap.FetchItem{imap.FetchEnvelope, imap.FetchFlags, imap.FetchInternalDate, section.FetchItem()}
  11. messages := make(chan *imap.Message)
  12. go func() {
  13. 	done &lt;- c.Fetch(seqset, items, messages)
  14. }()
  15. msg := &lt;-messages //its getting stuck at this point. Nothing happens i dont get messages.

答案1

得分: 2

当你的搜索可能返回多条消息时，你需要确保从messages通道中读取所有内容，否则程序将会挂起。所以，不要使用以下方式：

  1. msg := <-messages

而是使用以下方式循环遍历通道：

  1. for msg := range messages {
  2.   // 处理消息
  3. }

这是一个可以工作的示例，它从环境中获取连接详细信息。这是从emersion的imap库修改的示例：

  1. package main
  3. import (
  4. 	"crypto/tls"
  5. 	"flag"
  6. 	"fmt"
  7. 	"log"
  8. 	"os"
  9. 	"time"
  11. 	"github.com/emersion/go-imap"
  12. 	"github.com/emersion/go-imap/client"
  13. )
  15. func main() {
  16. 	hours := flag.Int("hours", 24, "look this many hours in the past for messages")
  17. 	flag.Parse()
  18. 	if *hours > 0 {
  19. 		*hours = *hours * -1
  20. 	}
  22. 	host := os.Getenv("IMAP_HOST")
  23. 	port := os.Getenv("IMAP_PORT")
  24. 	user := os.Getenv("IMAP_USER")
  25. 	pass := os.Getenv("IMAP_PASS")
  26. 	tlsn := os.Getenv("IMAP_TLS_SERVERNAME")
  27. 	if port == "" {
  28. 		port = "993"
  29. 	}
  31. 	connStr := fmt.Sprintf("%s:%s", host, port)
  33. 	tlsc := &tls.Config{}
  34. 	if tlsn != "" {
  35. 		tlsc.ServerName = tlsn
  36. 	}
  38. 	c, err := client.DialTLS(connStr, tlsc)
  39. 	if err != nil {
  40. 		log.Fatal(err)
  41. 	}
  42. 	log.Println("Connected")
  43. 	defer c.Logout()
  45. 	if err := c.Login(user, pass); err != nil {
  46. 		log.Fatal(err)
  47. 	}
  48. 	log.Println("Authenticated")
  50. 	mbox, err := c.Select("INBOX", false)
  51. 	if err != nil {
  52. 		log.Fatal(err)
  53. 	}
  54. 	log.Println("Flags for INBOX:", mbox.Flags)
  56. 	criteria := imap.NewSearchCriteria()
  57. 	//criteria.WithFlags = []string{imap.SeenFlag}
  58. 	criteria.Since = time.Now().Add(time.Duration(*hours) * time.Hour)
  59. 	uids, err := c.Search(criteria)
  60. 	if err != nil {
  61. 		log.Println(err)
  62. 	}
  63. 	seqset := new(imap.SeqSet)
  64. 	seqset.AddNum(uids...)
  65. 	log.Printf("Search complete, found %d messages", len(uids))
  67. 	section := &imap.BodySectionName{}
  68. 	items := []imap.FetchItem{imap.FetchEnvelope, imap.FetchFlags, imap.FetchInternalDate, section.FetchItem()}
  69. 	messages := make(chan *imap.Message)
  70. 	done := make(chan error, 1)
  71. 	go func() {
  72. 		done <- c.Fetch(seqset, items, messages)
  73. 		log.Println("Fetch complete")
  74. 	}()
  75. 	for msg := range messages {
  76. 		if msg != nil {
  77. 			log.Printf("got message with address %p\n", msg)
  78. 		} else {
  79. 			log.Println("no messages matched criteria")
  80. 		}
  81. 	}
  82. 	if err := <-done; err != nil {
  83. 		log.Fatal(err)
  84. 	}
  85. }
英文:

When your search can return more than one message, you need to make sure to read everything from the messages channel, otherwise the program will hang. So instead of:

  1. msg := &lt;-messages

loop over the channel like so:

  1. for msg := range messages {
  2.   // process msg
  3. }

Here's my working sample, which pulls connection details from the environment. It's a modified version of the example from emersion's imap lib:

  1. package main
  3. import (
  4. 	&quot;crypto/tls&quot;
  5. 	&quot;flag&quot;
  6. 	&quot;fmt&quot;
  7. 	&quot;log&quot;
  8. 	&quot;os&quot;
  9. 	&quot;time&quot;
  11. 	&quot;github.com/emersion/go-imap&quot;
  12. 	&quot;github.com/emersion/go-imap/client&quot;
  13. )
  15. func main() {
  16. 	hours := flag.Int(&quot;hours&quot;, 24, &quot;look this many hours in the past for messages&quot;)
  17. 	flag.Parse()
  18. 	if *hours &gt; 0 {
  19. 		*hours = *hours * -1
  20. 	}
  22. 	host := os.Getenv(&quot;IMAP_HOST&quot;)
  23. 	port := os.Getenv(&quot;IMAP_PORT&quot;)
  24. 	user := os.Getenv(&quot;IMAP_USER&quot;)
  25. 	pass := os.Getenv(&quot;IMAP_PASS&quot;)
  26. 	tlsn := os.Getenv(&quot;IMAP_TLS_SERVERNAME&quot;)
  27. 	if port == &quot;&quot; {
  28. 		port = &quot;993&quot;
  29. 	}
  31. 	connStr := fmt.Sprintf(&quot;%s:%s&quot;, host, port)
  33. 	tlsc := &amp;tls.Config{}
  34. 	if tlsn != &quot;&quot; {
  35. 		tlsc.ServerName = tlsn
  36. 	}
  38. 	c, err := client.DialTLS(connStr, tlsc)
  39. 	if err != nil {
  40. 		log.Fatal(err)
  41. 	}
  42. 	log.Println(&quot;Connected&quot;)
  43. 	defer c.Logout()
  45. 	if err := c.Login(user, pass); err != nil {
  46. 		log.Fatal(err)
  47. 	}
  48. 	log.Println(&quot;Authenticated&quot;)
  50. 	mbox, err := c.Select(&quot;INBOX&quot;, false)
  51. 	if err != nil {
  52. 		log.Fatal(err)
  53. 	}
  54. 	log.Println(&quot;Flags for INBOX:&quot;, mbox.Flags)
  56. 	criteria := imap.NewSearchCriteria()
  57. 	//criteria.WithFlags = []string{imap.SeenFlag}
  58. 	criteria.Since = time.Now().Add(time.Duration(*hours) * time.Hour)
  59. 	uids, err := c.Search(criteria)
  60. 	if err != nil {
  61. 		log.Println(err)
  62. 	}
  63. 	seqset := new(imap.SeqSet)
  64. 	seqset.AddNum(uids...)
  65. 	log.Printf(&quot;Search complete, found %d messages&quot;, len(uids))
  67. 	section := &amp;imap.BodySectionName{}
  68. 	items := []imap.FetchItem{imap.FetchEnvelope, imap.FetchFlags, imap.FetchInternalDate, section.FetchItem()}
  69. 	messages := make(chan *imap.Message)
  70. 	done := make(chan error, 1)
  71. 	go func() {
  72. 		done &lt;- c.Fetch(seqset, items, messages)
  73. 		log.Println(&quot;Fetch complete&quot;)
  74. 	}()
  75. 	for msg := range messages {
  76. 		if msg != nil {
  77. 			log.Printf(&quot;got message with address %p\n&quot;, msg)
  78. 		} else {
  79. 			log.Println(&quot;no messages matched criteria&quot;)
  80. 		}
  81. 	}
  82. 	if err := &lt;-done; err != nil {
  83. 		log.Fatal(err)
  84. 	}
  85. }

huangapple
  • 本文由 发表于 2018年6月15日 01:27:13
  • 转载请务必保留本文链接：https://go.coder-hub.com/50862938.html
  • gmail
  • go
  • imap
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定