我正在使用 xmpp4r 并尝试掌握我希望稍后在我的 Rails 应用程序中实现的基本聊天功能。我在 Ruby Threads 上的基础知识仍然有点不稳定,因此我将不胜感激。
虽然我注册了回调,但我的 gmail 帐户没有收到回复。我可以发送消息,但我的 ruby 程序终止。为了防止它终止,我试图停止程序中的线程,但我似乎无法让它工作。
require 'rubygems'
require "xmpp4r/client"
require "xmpp4r/roster"
include Jabber
def connect
client = Client.new(JID::new("test@gmail.com"))
client.connect
client.auth("test")
client.send(Presence.new.set_type(:available))
client
end
def create_message(message, to_email)
msg = Jabber::Message::new(to_email, message)
msg.type = :chat
msg
end
def subscribe(email_id)
pres = Presence.new.set_type(:subscribe).set_to(email_id)
pres
end
client = connect
roster = Roster::Helper.new(client)
roster.add_subscription_request_callback do |item,pres|
roster.accept_subscription(pres.from)
end
def create_callback(client)
$t4= Thread.new do
client.add_message_callback do |m|
puts m.body
puts "................................Callback working"
end
end
end
puts "Client has connected"
msg = create_message("Welcome to the winter of my discontent", "test@tech.com")
client.send(msg)
create_callback(client)
def check(client)
$t3 = Thread.new do
loop do
puts "t3 still running........."
Thread.current.stop
$t4.join
end
end
end
check(client)