自由鸟的BLOG

用JAVA做一个服务器，负责把用户的发过来的流式信息转发给其它用户。JAVA程序负责的工作就是一，接收；二，验证（逐个用户比较，查看是否发给该用户，如果是就转发，不是就是跳过）；三，转发。
JAVA原代码分析：
1，新建一个serverSocket,把端口号设置为9000
2，开始侦听，如果有用户发过来连接请求，就就该用户建一个socket，同时启动一个线程，负责查看该用户的情况（是否退出，是否发了信息（信息包括走棋，坐下，站起，聊天））
代码如下：
import java.net.*;
import java.io.*;
import java.util.*;
public class FiveServer
{
public static void main(String[] args)
{
ServerSocket socket = null;
Vector m_threads = new Vector();
//Vector street_info=new Vector();
System.out.println("listen....");
try{
socket = new ServerSocket(9000);
}
catch(Exception e){ System.out.println("new serversocket() failed"); return;}
try
{
int nid=0;
while(true)
{
Socket s =socket.accept();
System.out.println("accepted");

ServerThread st = new ServerThread(s,m_threads);
st.setID(nid++);
m_threads.addElement(st);
new Thread(st).start();
System.out.println("listen again.........."+m_threads.size());
if(m_threads.isEmpty()) System.out.println("no user on line");
}
}catch(Exception e)
{
System.out.println("server is down....");
}
}
}

class ServerThread extends Thread
{
Vector m_threads;
Socket m_socket = null;
DataInputStream m_in =null;
PrintStream m_out = null;
int m_nid;
String nickname;
public ServerThread(Socket s ,Vector threads)
{
m_socket= s;
m_threads=threads;


try{
m_in = new DataInputStream(m_socket.getInputStream());
m_out = new PrintStream(m_socket.getOutputStream());
}
catch(Exception e)
{
}
}
public void run()
{
String str="1";
System.out.println("thread "+m_nid+" is running........");
try{
String s=m_in.readLine();//取出该线程控制的人物呢称
int start=s.indexOf("login&");
int endpos=s.indexOf("&login");
if(start!=-1&&endpos!=-1)
{ str=s.substring(start+6,endpos);
this.nickname=str;//昵称
}
for(int i=0;i<m_threads.size();i++)
{
ServerThread st = (ServerThread)m_threads.elementAt(i);
st.write(s);
st.write("00000 ");
}
System.out.println(nickname);
while(true)//登录成功
{
//System.out.println(m_nid+"*"+streetid+" .... "+m_threads.toString());
s=m_in.readLine();//读入信息流中的信息
if(s==null||s=="") break;
if(s.indexOf("echo&")!=-1||s.indexOf("request&")!=-1||s.indexOf("chess&")!=-1)
{

for(int i=0;i<m_threads.size();i++)
{
ServerThread st = (ServerThread)m_threads.elementAt(i);
if(s.indexOf(st.nickname)!=-1)//转发给目的用户。
{
st.write(s);
st.write("00000 ");

}
}
}
else if(s.indexOf("dialog&")!=-1&&s.indexOf("all&")==-1)
{
for(int i=0;i<m_threads.size();i++)
{
ServerThread st = (ServerThread)m_threads.elementAt(i);
if(s.indexOf(st.nickname+"&")!=-1||st.nickname==nickname)//私聊，转发给与自己对棋用户和自己
{
st.write(s);
st.write("00000 ");

}
}
}
else
{
for(int i=0;i<m_threads.size();i++)
{
ServerThread st = (ServerThread)m_threads.elementAt(i);
st.write(s);
st.write("00000 ");
}
}

System.out.println(s);
}
}
catch(Exception e){ e.printStackTrace();}
m_threads.removeElement(this);//从向量表里删除该对象
try
{
str="02"+"&"+"02"+"&"+nickname+"&"+"";
for(int i=0;i<m_threads.size();i++)//向每个客户端发退出信息
{
ServerThread st = (ServerThread)m_threads.elementAt(i);

st.write(str);
st.write(str);

}
//System.out.println(str);
m_socket.close();
}
catch(Exception e){}
}

public void write(String msg) throws IOException
{
synchronized(m_out)
{
try
{
m_out.println(msg);
}
catch (Exception e){}
}
}

public int getID()
{
return m_nid;
}
public void setID(int nid)
{
m_nid=nid;
}
}


二，FLASH端的设置
由于时间有限，这里只介绍实现原理。。。。。^_^
1，用户输入昵称（中英文），按登录键
2，登录键的代码为
mySocket.connect(".......",8000)
3,客户连接上mySocket.onConnect(){}
立即发一条信息给服务器信息格式如下：
"login&dylan_xueke&login";
两个login&是用来让服务器取出中间的nickname...
会吧？？？nickname=s.substring(indexOf("login&")+5,indexOf("&login"))//自己想想啦。
服务器收到这条信息，立即转发给每个用户。
4，用户收到一个含有"Login&"的信息后，分析之后，执行一个函数
该函数功能 中最主要一条就发一条回应信息"echo&谁谁谁&我的名字&4&left"
echo&:告诉接受者，我是回应你的，
谁谁谁:就是谁发给你的，你就发给谁啦！
4:桌子号
left right) 你在桌子左边还是右边坐着
如果你还没坐下就不发后两项了，只发你也在房间内的信息就行了echo&谁谁谁&我的名字&"
5,用户收到echo信息，往在线用户数里添加一项(在线用户数组在FLASH第一帧定义onlineusers=new Array();当然，收到login信息时，也要往里面加一个啊
6,下面的代码就长了，，没时间写。。。
大致介绍一下啊。
坐下:"sit&我的名字&桌子号&left"
站起来:"stand&我的名字&桌子号&left"
请求游戏"request&对手名字"
走子："chess&对手名字&x_pos&y_pos";
每走一子，两方都要判断是否有人犯规（三三活手，四四禁手，长连禁手）
如果没有，就判断是否有人赢。如果有，就不再下了

注:此文章是转自他人之手,仅供学习讨论