看这个演示，可能细心的小伙伴发现，他跟我前面写的那个聊天室的区别在于它有世界和帮派两个窗口，两个窗口接收的服务器信息是不同的，像不像梦幻西游的聊天窗体呢（当时我就是想山寨一个这样的组件），它是怎么做的呢，我们来看看，

<?php
class flash_guest {
public function flash_guest() {mysql_connect("localhost", "root", "root")or die("没找到数据库");mysql_select_db("airdb")or die("连接数据库失败");
}
function addtobase($username, $userqq, $useremail, $usermessage) {
$addto="INSERT INTO `airdb`.`guest` (
`id` ,
`username` ,
`qq` ,
`useremail` ,
`usermessage`
)
VALUES (
'', '".$username."', '".$userqq."', '".$useremail."', '".$usermessage."'
)
";
mysql_query($addto);
return null;
}
function showmessage() {return mysql_query("SELECT *
FROM `guest` ORDER BY `guest`.`id` DESC
LIMIT 0 , 30");}
}?>

这是服务器的php源码，过后我会跟amfphp1.9一起打包给大家，省的大家去网上找了，上面连接数据库的部分记得要自己改下，改成小伙伴自己本地的数据库登录，然后我们看看sql

-- phpMyAdmin SQL Dump
-- version 3.1.3
-- http://www.phpmyadmin.net
--
-- 主机: localhost
-- 生成日期: 2009 年 10 月 17 日 20:55
-- 服务器版本: 5.1.32
-- PHP 版本: 5.2.9-1SET SQL_MODE="NO_AUTO_VALUE_ON_ZERO";/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;
/*!40101 SET NAMES utf8 */;--
-- 数据库: `mydatabase`
---- ----------------------------------------------------------
-- 表的结构 `guest`
--CREATE TABLE IF NOT EXISTS `guest` (`id` int(10) NOT NULL AUTO_INCREMENT,`username` varchar(20) NOT NULL,`qq` int(20) NOT NULL,`useremail` varchar(25) NOT NULL,`usermessage` text NOT NULL,PRIMARY KEY (`id`)
) ENGINE=MyISAM  DEFAULT CHARSET=utf8 AUTO_INCREMENT=41 ;--
-- 导出表中的数据 `guest`
--INSERT INTO `guest` (`id`, `username`, `qq`, `useremail`, `usermessage`) VALUES
(1, 'swordfishx82', 95766154, 'swordfishx@163.com', 'godness me');

把sql文件导入到数据库中，我们先在Mysql里面定义一个名为airdb的空库，然后导入

导入之后是这样的，然后我们看看amfphp1.9什么样子，

amfphp1.9之所以一直被国内开发者喜爱是因为，这个版本带了一个flash的可视化窗口工具，在2.0之后不知为啥，这个工具没有了，调试起来反而麻烦了，而且2.0版本之后链接取消了原来的gateway.php文件，直接连接index.php这个文件，我们看下客户端如何写的

左边代码注释的地方是我以前国外空间的地址，现在没用了，所以改成了下面的本地，工具的目录结构如右边，这里注意蓝色的lib，flcs4Component.swc是flash4的可视化组件库，因为as3里面缺少这些东西，所以我在flash5里面把可视化组件打成了swc包方便在as3里面使用，

看代码，

package
{import flash.display.Sprite;import flash.events.Event;import TalkTip.TalkTip;/*** ...* @author swordfishx*/public class Main extends Sprite {public function Main():void {if (stage) init();else addEventListener(Event.ADDED_TO_STAGE, init);}private function init(e:Event = null):void {removeEventListener(Event.ADDED_TO_STAGE, init);// entry pointaddChild(new TalkTip());}}}

文档类，这个是我的习惯，因为为了方便整合到其他地方，我总是喜欢，把做好的组件单提出来，让他可以直接new出来使用，所以文档类里面一直都会很干净，

package TalkTip
{import fl.controls.Label;import flash.display.Bitmap;import flash.display.Sprite;import fl.controls.TextArea;import fl.controls.TextInput;import fl.controls.Button;import flash.events.MouseEvent;import flash.net.NetConnection;import flash.net.Responder;import flash.events.Event;/*** ...* @author swordfishx*/public class TalkTip extends Sprite{[Embed(source="../../lib/TaikTipRes/xs.jpg")]private var TalkTipResxs:Class;[Embed(source="../../lib/TaikTipRes/xx.jpg")]private var TalkTipResxx:Class;private var htmstr:String = "<font color='#ff0000' size='25' face='宋体'>" + "健康游戏，抵制外挂" + "</font>"private var textareaheight:int = 150;//-------------------通讯-----------//private var mylocalhost:String = "http://swordfishx.freevar.com/amfphp/gateway.php";private var mylocalhost:String ="http://localhost/amfphp1.9/gateway.php";private var myconn:NetConnection;private var myresponder:Responder;//-------------------------------------private var imgxs:Bitmap = new TalkTipResxs();private var imgxx:Bitmap = new TalkTipResxx();private var button:Button = new Button();private var btnworld:Button = new Button();private var btnprivate:Button = new Button();private var textarea:TextArea = new TextArea();private var inputtxt:TextInput = new TextInput();private var nameinput:TextInput = new TextInput();private var emailinput:TextInput = new TextInput();private var qqinput:TextInput = new TextInput();private var qqname:Label = new Label();private var namelb:Label = new Label();//---------------------------------------------初始化private var TalkState:int = 0;//---------------------------------------public function TalkTip(){init();}private function init():void{textarea.x = 1;textarea.width = 300;textarea.height = textareaheight;textarea.htmlText = htmstr;textarea.alpha = 1;//-------------------------显示区域btnworld.width = 50;btnworld.label = "世界";btnworld.x = 1;btnworld.y = textarea.height + 1;btnprivate.width = 50;btnprivate.label = "帮派";btnprivate.x = btnworld.width + 1;btnprivate.y = textarea.height + 1;//-----------------------------连接切换imgxs.x = 250;imgxx.x = 250 + imgxs.width;imgxs.y = textarea.height + 1;imgxx.y = textarea.height + 3;//----------------------------布局inputtxt.x = 1;inputtxt.width = 250;inputtxt.y = textarea.height + 1 + btnprivate.height;button.width = 50;button.label = "发送";button.x = inputtxt.width + 1;button.y = textarea.height + 1 + btnprivate.height;//------------------------------------------------btnworld.addEventListener(MouseEvent.CLICK, btworldstate);btnprivate.addEventListener(MouseEvent.CLICK, btnprivatestate);button.addEventListener(MouseEvent.CLICK, onsub);//---------------------------qqname.text = "qq号码:";namelb.text = "名称:";qqname.x = 300;qqname.y = 1;namelb.x = 300;namelb.y = 100;nameinput.x = 300+qqname.width;nameinput.y = 100;qqinput.x = 300+qqname.width;qqinput.y = 1;//--------------------------addChild(button);addChild(textarea);addChild(btnworld);addChild(btnprivate);addChild(imgxs);addChild(imgxx);addChild(inputtxt);addChild(nameinput);addChild(qqinput);addChild(namelb);addChild(qqname);//addChild(emailinput);}private function btworldstate(evt:MouseEvent):void{TalkState = 0;onshow();trace("0");}private function btnprivatestate(evt:MouseEvent):void{TalkState = 1;onshow();trace("1");}private function onsub(evt:MouseEvent):void{myresponder = new Responder(onsubresult);myconn = new NetConnection();myconn.connect(mylocalhost);if (TalkState == 0){myconn.call("flash_guest.addtobase", myresponder, nameinput.text, int(qqinput.text), emailinput.text, inputtxt.text);}else if (TalkState == 1){myconn.call("flash_guest.addtobase", myresponder, nameinput.text, int(qqinput.text), inputtxt.text, inputtxt.text);}cleartext();}private function onshow():void{if (TalkState == 0){myresponder = new Responder(onshowresult, onshowstatus);}else if (TalkState == 1){myresponder = new Responder(onprivateshowresult, onshowstatus);}myconn = new NetConnection();myconn.connect(mylocalhost);myconn.call("flash_guest.showmessage", myresponder);}private function onshowresult(p:Object):void{textarea.text = "";var showarray:Array = new Array();showarray = p["serverInfo"]["initialData"];for (var i:uint; i < showarray.length; i++){//showmessage.text += "\n QQ："+showarray[i][2];if (showarray[i][3] != ""){textarea.text += String("\n 昵称：" + showarray[i][1]);textarea.text += "\n 帮派：" + showarray[i][3];}else{textarea.text += String("\n 昵称：" + showarray[i][1]);textarea.text += "\n 世界：" + showarray[i][4];}textarea.text += "\n===================================";}}private function onprivateshowresult(p:Object):void{textarea.text = "";trace("帮派");var showarray:Array = new Array();showarray = p["serverInfo"]["initialData"];for (var i:uint; i < showarray.length; i++){if (showarray[i][3] != ""){textarea.text += String("\n 昵称：" + showarray[i][1]);textarea.text += "\n 帮派：" + showarray[i][3];textarea.text += "\n===================================";}}}private function onsubresult(p:Object):void{inputtxt.text = "提交成功！";onshow();}private function onshowstatus(p:Object):void{inputtxt.text = "连接出错";}private function cleartext():void{nameinput.text = "";qqinput.text = "";emailinput.text = "";inputtxt.text = "";}}}

代码并不多，我讲讲，amfphp是怎么工作的，首先

private var mylocalhost:String ="http://localhost/amfphp1.9/gateway.php";

这句连接amfphp，通知amfphp工作，然后我们以按钮为例看看他是如何通信的，

button.addEventListener(MouseEvent.CLICK, onsub);

这里鼠标监听onsub，

   private function onsub(evt:MouseEvent):void{myresponder = new Responder(onsubresult);myconn = new NetConnection();myconn.connect(mylocalhost);if (TalkState == 0){myconn.call("flash_guest.addtobase", myresponder, nameinput.text, int(qqinput.text), emailinput.text, inputtxt.text);}else if (TalkState == 1){myconn.call("flash_guest.addtobase", myresponder, nameinput.text, int(qqinput.text), inputtxt.text, inputtxt.text);}cleartext();}

上面的call方法中这里调用了myresponder,它是amfphp核心responder类的一个实例

   private function onsubresult(p:Object):void{inputtxt.text = "提交成功！";onshow();}

结果方法，在这个方法中有一个onshow()，

private function onshow():void{if (TalkState == 0){myresponder = new Responder(onshowresult, onshowstatus);}else if (TalkState == 1){myresponder = new Responder(onprivateshowresult, onshowstatus);}myconn = new NetConnection();myconn.connect(mylocalhost);myconn.call("flash_guest.showmessage", myresponder);}

这里把接收到数据分开，世界和帮派的数据不同就是因为这里，

myresponder = new Responder(onshowresult, onshowstatus);

这里有两个方法，前面的是有数据成功时的调用，后面是失败时的调用，

private function onshowresult(p:Object):void{textarea.text = "";var showarray:Array = new Array();showarray = p["serverInfo"]["initialData"];for (var i:uint; i < showarray.length; i++){//showmessage.text += "\n QQ："+showarray[i][2];if (showarray[i][3] != ""){textarea.text += String("\n 昵称：" + showarray[i][1]);textarea.text += "\n 帮派：" + showarray[i][3];}else{textarea.text += String("\n 昵称：" + showarray[i][1]);textarea.text += "\n 世界：" + showarray[i][4];}textarea.text += "\n===================================";}}

private function onshowstatus(p:Object):void{inputtxt.text = "连接出错";}

如果看过烽烟ol客户端源码的小伙伴会发现，烽烟ol的源码是严格按这种模式来写的，甚至方法名都一样，不过烽烟ol用的是sokect连接，不要弄混了，

代码下载在这里
好了，最后我们说说，如何连接redis，memcached前面的博客有提到如何简单使用，go语言的话，因为它直接集成了memcached（不能叫集成，因为memcached作者是Go语言开发团队的一员，所以go语言直接包括了memcached的功能）

以c#为例，连接

RedisClient client=new RedisClient("localhost",6379)；

Set<string>(client,"username","swordfishx");

Set<int>(client,"pwd","123456");

client.Save();
Console.Ready();

这就是大概的redis保存流程，好了，我们下一篇再见。