• 简单的MUD服务器
  • main.rb
  • MudGameServer
  • test.rb
  • GmCmd.rb
  • gmclient.rb
  • EncryStr.rb
  • gameData_0-0.json

简单的MUD服务器

main.rb

#!/usr/bin/ruby 
#encoding:UTF-8
require 'eventmachine'
require_relative 'MudGameServer'
require_relative 'GmCmd'
require 'time'
VERSION =0.01

EventMachine.run {
  $client_count=0
  $action={}
  puts "waterRbMud server V#{VERSION} start..."
  host, port,mg_port = get_server_ip_info()
  puts "[a mud server written with ruby.]"
  EventMachine.start_server host, port, MudGameServer
  EventMachine.start_server(host, mg_port, GmCmd)
  puts  DateTime.now  
  puts "waterRbMud server was running." 
  puts "接受player连接: #{host}: #{port}..."
  puts "接受GM连接: #{host}: #{mg_port}..."
}

MudGameServer

#encoding:UTF-8
#!/usr/bin/ruby

require 'json'
 

def get_server_ip_info
    main_port=2023
    manager_port=9999
	ip_info=`ifconfig -a`
	ip_info=~/inet\s+(?!127\.0\.0\.1)([0-9\.]+)/
	[$1,main_port,manager_port]
end

module MudGameServer
	def post_init
	    init_game_data
		puts "第#{$client_count}个客户端已经连接到服务器![#{DateTime.now}]"
		send_data "login 用户名  密码：\n"
		send_data "#"
	end

	def receive_data data
	        if !data || data.chomp.strip=="" 
			    send_data "#"
			    return 
	        end
	        data_utf8=data.strip.force_encoding('utf-8')
	        begin
				@received_data=data_utf8.split(/\s+/)
				client_cmd=@received_data[0]
				player_cmd(client_cmd)
			rescue  ArgumentError=>e
				@@game_client.delete(@user)
				close_connection				
			end		    		 
	end

	def unbind
	    $client_count-=1
		puts "1个客户端退出，还有#{$client_count}个客户端连接中![#{DateTime.now}]"
		if $client_count==0
			puts "当前无客户端连接！"
		end
	end

	def init_game_data
	    @@game_client={}
	    @scene_act={}
	    @current_room_id=0
	    @current_order_id=0
		$client_count+=1
	    @now_story_id="0-0"
	    $action["think"]="想："
	    $action["talk_to_myself"]="自言自语："
	    $action["plot"]=":"	   
	    #now_story_id
		File.open("gameData_#{@now_story_id}.json", "r") do |json_file|
		   	@json_obj = JSON.parse json_file.read
		end
	end
	
	def player_cmd(cmd_str)
		p_cmd=cmd_str.downcase
		if p_cmd=="now"
			send_data ">>>#{@user},#{DateTime.now}\n#"
		elsif p_cmd=="login"
			@user,@passwd=@received_data[1..2]	   
			@@game_client[@user]=self
			send_data ">>>#{@user},欢迎您光临\n#"
			out_str=get_scene_output(@current_room_id,@current_order_id)
			if out_str
				send_data "\n#{out_str}" 		
			end		   
		elsif 	p_cmd=="quit"
			@@game_client.delete(@user)
			close_connection
		elsif p_cmd=="talkto"
		 	user,message=@received_data[1..2]	
		 	send_data "#"  
		 	if   @@game_client.has_key?(user)
		     	@@game_client[user].send_data ">>>#{@user}对#{user}说：\n#{message}\n#"    
		 	end	
		elsif @scene_act.has_key?(p_cmd)
			case @scene_act[p_cmd].split[0]
			   when  "next"
					@current_order_id+=1	
					@scene_act.clear	
			   when "go_order_id"
					@current_order_id=@scene_act[p_cmd].split[1].to_i
					@scene_act.clear						
			end
			out_str=get_scene_output(@current_room_id,@current_order_id)
			if out_str
				send_data out_str 
			else
				 @current_order_id-=1
				 send_data ">>>#{@user},无效指令:#{cmd_str}\n#"  			
			end			
		else
	    	*params=@received_data[1..-1]	
			send_data ">>>#{@user},无效指令:#{cmd_str}，无效参数:#{params.join(" ")}\n#"      
		end	
	end

	def get_scene_output(c_room_id,c_order_id)
		now_scene_data=get_game_scene(c_room_id,c_order_id)
		if now_scene_data
			sel_str=""		    	    
			@scene_act={}
			now_scene_data[:action_sel].each do |sel,act|
				sel_kb=sel.split('-|')[0]
				sel_str+=sel+"\n"
				@scene_act[sel_kb]=act.strip
			end
			out_str=">>>#{@user}现在在#{now_scene_data[:room_name]}\n"
			out_str+="#{@user}#{now_scene_data[:action_name]}\n"
			out_str+="#{now_scene_data[:action_data].join("\n")}\n"
			out_str.gsub!('#player_user#',@user)
			out_str+=sel_str+"\n#"
			return out_str
		else
			return nil
		end	    
	end

	def get_game_scene(room_id,order_id)
			room_name=""
			action_type=""
			action_name=""
			action_data=""  
			action_sel={}
			sub_scene=@json_obj["data"]
			sub_scene.each do |player_info|
				if player_info["id"].to_i==room_id
					room_name=player_info["name"]
					player_info["data"].each do |player_data|
						if player_data["order_id"].to_i==order_id
							action_type=player_data["type"].strip
							action_name=$action[action_type]
							action_data= player_data["data"]
							action_sel= player_data["select"]
							return {"room_name":room_name,"action_type":action_type,"action_name":action_name,"action_data":action_data,"action_sel":action_sel}
						end
					end
				end 
			end
			return nil
	  end
end

test.rb

require 'eventmachine'

 module MudGameServer
    @@client_count=0
	def post_init
	    @@client_count+=1
		puts "第#{@@client_count}个客户端已经连接到服务器!"
	end

	def receive_data data
	    mud_data=data.gsub(" ","").force_encoding('utf-8')
		send_data "#你发送的消息: #{mud_data}"
		close_connection if data =~ /quit/i
	end

	def unbind
	    @@client_count-=1
		puts "1个客户端退出，还有#{@@client_count}个客户端连接中!"
		if @client_count==0
			puts "当前无客户端连接！"
		end
	end

	def query_client_count
	     puts "当前#{@@client_count}个客户端连接！"
	end
end
# Note that this will block current thread.
EventMachine.run {
  EventMachine.start_server "127.0.0.1", 8081, MudGameServer
}

GmCmd.rb

#encoding:UTF-8

require_relative 'EncryStr'
module GmCmd
     @@gm_count=0
     @@gm_passwd=['a29b0@*^','z-=?2#\;','~#3-sr|l']
	def post_init
	    init_gm_command
	    @@gm_count+=1
		puts "第#{@@gm_count}个gm客户端已经连接到服务器!"
	end

	def receive_data data
	        if !data || data.chomp.strip==""
			    send_data ">>>"
			else
			    data=data.chomp
				begin
					data=decry_str(data,@@gm_passwd)
					@received_data=data.strip.force_encoding('utf-8').split(/\s+/)
					client_cmd=@received_data[0]
					game_master_cmd(client_cmd)
				rescue  ArgumentError=>e
					close_connection
				end
	        end		 
	end

	def unbind
	    @@gm_count-=1
		puts "1个gm客户端退出，还有#{@@gm_count}个gm客户端连接中![#{DateTime.now}]"
		if @@gm_count==0
			puts "当前无gm客户端连接！"
		end
	end

	def init_gm_command
	        @@gm_command={}
			@@gm_command["version"]=Proc.new do 
				send_data ">>>#{VERSION}\n###"
			end
			@@gm_command["gmlogin"]=Proc.new do 	    
				@user,@passwd=@received_data[1..2]	
				puts "gm客户端#{@user}已经登录[#{DateTime.now}]"    
				send_data ">>>#{@user},欢迎您光临\n###"   
			end
			@@gm_command["ccount"] =Proc.new do 
			   send_data ">>>当前#{$client_count}个客户端连接！[#{DateTime.now}]\n###"
			end
			@@gm_command["gcount"] =Proc.new do 
			   send_data ">>>当前#{@@gm_count}个gm客户端连接！[#{DateTime.now}]\n###"
			end
			@@gm_command["now"]=Proc.new do 
				send_data ">>>#{@user},#{DateTime.now}\n###"
			end
			@@gm_command["quit"]=Proc.new do  
				close_connection
			end
	end

	def game_master_cmd(cmd_str)
		gm_cmd=cmd_str.downcase
        if  @@gm_command.has_key?(gm_cmd)
			@@gm_command[gm_cmd].call()			
		else
	    	*params=@received_data[1..-1]	
			send_data ">>>#{@user},无效指令:#{gm_cmd}，无效参数:#{params.join(" ")}\n###s"    
		end		
	end 
end

gmclient.rb

#!/usr/bin/ruby 
#encoding:UTF-8
require 'eventmachine'
require_relative 'EncryStr'

$gm_port=9999
$gm_server='192.168.1.105'
$gm_passwd=['a29b0@*^','z-=?2#\;','~#3-sr|l']
$user="gm"
$passwd="124321"

module GmCmdClient
  def post_init
     puts "开始连接服务器[#{$gm_server}:#{$gm_port}]...."
     login_data=encry_str("gmlogin #{$user} #{$passwd}",$gm_passwd)
     send_data login_data
  end

  def receive_data data
	 print data
	 input_data=""
	 loop do
		begin
			input_data=gets.chomp.strip
			if input_data!=""
				break
			else
				print "###"
			end
		rescue Exception=>e
		    puts "error!"
		    p e
			print "###"
		end
	 end
     input_data=encry_str(input_data,$gm_passwd)
     send_data input_data
  end

  def unbind
    EventMachine::stop_event_loop
  end
end

 EventMachine.run do
   EventMachine.connect $gm_server, $gm_port, GmCmdClient
end

EncryStr.rb

#!/usr/bin/ruby 
#encoding:UTF-8
require 'des'
def encry_str(data,passwd)
	des_encry(des_decry(des_encry(data,passwd[0]),passwd[1]),passwd[2])
end
def decry_str(data,passwd)
	des_decry(des_encry(des_decry(data,passwd[2]),passwd[1]),passwd[0])	
end
def des_encry(data,passwd)
	ec_data=""
	pad_data=""
	data_length=data.length
	for i in (0...data.length).step 8
		 s_data=data[i,8]
		 if data_length < 8
			for i in 0...8-data_length
			   pad_data+=" "
			end
			s_data+=pad_data		
		 end
		 ec_data+=DES.encrypt(s_data, passwd).to_s
		 data_length-=8
	end	
	return ec_data
end

def des_decry(data,passwd)
	dc_data=""
	for i in (0...data.length).step 8
		 s_data=data[i,8]
		 dc_data+=DES.decrypt(DES::Block.new(s_data), passwd).to_s
	end	
	dc_data.slice!(/\*+$/)
	return dc_data
end

def test
    passwd=["aqsw1234",'a-=?2##;','~#0-sr|l']
	s1=encry_str("gmlogin sss 325 ",passwd)
	s2=decry_str(s1,passwd)
	puts s1
	puts s2
end

#test

gameData_0-0.json

{ 
    "id":"0-0",
    "type":"scene",
	"data":
	[
		{"id":0	,
		 "type":"room",
		 "name":"自己家里",
		 "data":
			[ 
				{
				   "order_id":0,
				   "type":"think",
				   "data": [
					   "我这是在哪呢？\n原来是在自己家里，又是平静的一个周日。",
						"快盛夏了，昨天天气预报，今天气温38度，天气就这么热了。",
						"现在几点了?\n还只有9点。"
					],
					"select":{"1-|继续":"next"}
				},  
				{
					"order_id":1,
					"type":"talk_to_myself",
					"data": ["再睡会觉，时间还早呢！",
					          "外面怎么这么吵！又是那些跳广场舞的大妈。",
					          "唉！还让不让我睡觉了！"],
					 "select":{"1-|继续":"next"}
				},
				{
					"order_id":2,
					"type":"plot",
					"data": [
					"我拉开窗帘，外面的阳光比以前更加耀眼，天上好像有两个太阳，这咋回事？",
					"跳广场舞的音乐继续放着，可是外面那些的大妈也没有在跳广场舞，都在指着天上的太阳，好像在议论着什么。"],
					"select":{"1-|继续":"next"}
				},
				{
					"order_id":3,
					"type":"think",
					"data": [
					"这咋回事，可能真的两太阳？",
					"这个天文自然现象百年不遇，不管它了，实在太困了。",
					"对，先睡觉，起床后，再看看怎么回事！"],
					"select":{"1-|继续":"next"}
				},
				{
					"order_id":4,
					"type":"plot",
					"data": [
					"我拉上窗帘，睡了不知道多久，被外面的敲门声吵醒",
					"这谁呀？一般没有人周日这时候来到我家找我？",
					"我大学毕业后，就来这个城市打工也有好几年了，这个曾经陌生的城市，现在已经很熟悉了。",
					"现在我一个住在这租来的房子里，小区位置偏远了一些，但环境不错，租金也不贵。"
					],
					"select":{"1-|继续":"next"}
				},
				{
					"order_id":5,
					"type":"think",
	                "data": 
	                ["同事一般来我家玩，都要和我预约时间，这谁呢？！",
	                "这么早来打扰我的美梦。敲门声还在继续，而且越敲越重。",
	                "要不要打开门看看呢？"],
	                "select":{"1-|不开门":"next","2-|开门":"go_order_id 7"}
				},
				{
					"order_id":6,
					"type":"plot",
	                "data": 
	                ["一个厚重的男声说：‘开门，我们有要事找您，您不开门会后悔一辈子的。’",
	                "一个清脆的女声说：‘先生，我们是好人，请您打开门。这样吧，我们把信放在门口，请您一定要看。’"
	                ],
	                "select":{"1-|开门":"next"}
				},
				{
					"order_id":7,
					"type":"plot",
	                "data": 
	                ["我迟疑了许久，才打开门。",
	                "门外已经没有人了，那些敲门的人肯定离开了。",
	                "我捡起门口的信封，回到家里。"
	                ],
	                "select":{"1-|阅信":"next"}
				},
				{
					"order_id":8,
					"type":"plot",
	                "data": 
	                ["我打开信封，里面有一张卡片，上面写着：",
	                "尊敬的#player_user#，请您于今天下午4点，到本市的白蛋酒店集合，晚上参加会餐", 
	                "会议重要，请勿缺席，会后您将参加一个长期旅行团，请您携带可以长期生活的一切必要行李", 
	                "此次旅行将很漫长，请做好充足的准备，感谢您的参加",
	                "卡片下面画了一个红色的小球，外面包围着很多银色的小球。"
	                ],
	                "select":{"1-|继续":"next"}
				},	
				{
					"order_id":9,
					"type":"think",
	                "data": 
	                ["这是个什么样的会议，很奇怪？！",
	                "卡片下面绘制的图案很精美，只是不知道代表了什么特殊的含义。",
	                "参加会议免费，还可以有晚餐，还可以免费旅行。",
	                "只是不知道这次旅行好玩不，去哪此地方玩",
	                "还要带上长期生活的行李，如果参加会议，肯定暂时回来不了，去不去呢？",
	                "反正吃喝玩乐免费，万一有危险，我离开酒店就可以了，这个酒店我去过，是一个大型正规酒店。",
	                "还是去吧！就这么决定了，现在就开始清理行李，随便做个中饭就出发",
	                "走之前，我还得把房间处理好，暂时回不来了，把水电和天然气都关好。"
	                ],
	                "select":{"1-|吃完中饭":"next"}
				}										
			]
		}
	]
}