使用java socket怎么能够实现将一个客户端发送到服务端的消息转发到另一个客户端?

public class TCPlient {
public static void main(String[] args) {
String str = null;
Socket clientSocket; // 创建客户端套接字
DataInputStream in = null; // 创建DataInputStream对象
DataOutputStream out = null; // 创建DataOutputStream对象
try {
clientSocket = new Socket("127001", 4331); // 实例化Socket对象
//clientSocket = new Socket("192168152139", 6379);
in = new DataInputStream(clientSocketgetInputStream()); // 实例化DataInputStream对象
// 实例化DataOutputStream对象
out = new DataOutputStream(clientSocketgetOutputStream());
outwriteUTF("你好！！"); // 写数据
while (true) {
str = inreadUTF(); // 读取流中数据
outwriteUTF(((int) (Mathrandom() 10) + 1) + ""); // 向流中写入0到10之间的随机数
Systemoutprintln("客户端收到：" + str); // 输出信息
Threadsleep(1000); // 线程休眠
}
} catch (Exception e) {
eprintStackTrace();
}
}
}
public class TCPServer {
public static void main(String[] args) {
ServerSocket serverSocket = null; // 创建服务器端套接字
Socket clientSocket = null; // 创建客户端套接字
String str = null;
DataOutputStream out = null; // 创建DataOutputStream类对象
DataInputStream in = null; // 创建DataInputStream类对象
try {
serverSocket = new ServerSocket(4331); // 实例化ServerSocket对象
clientSocket = serverSocketaccept(); // 接收客户的套接字连接呼叫
in = new DataInputStream(clientSocketgetInputStream()); // 实例化DataInputStream对象
out = new DataOutputStream(clientSocketgetOutputStream()); // 实例化DataOutputStream对象
while (true) {
str = inreadUTF(); // 读取客户放入连接中的信息
outwriteUTF("hello，我是服务器"); // 通过输出流向线路中写信息
outwriteUTF(str);
Systemoutprintln("服务器收到：" + str);
Threadsleep(1000); // 线程休眠
}
} catch (Exception e) {
eprintStackTrace();
}
}
}
//要发到另一个client，就让server转发消息就行。

socket服务器的工作方式是这样的，不间断地运行以等待客户端的连接。一旦客户端连接上了，服务器就会将它添加到客户名单中，然后开始等待来自客户端的消息。

不要走开，下面是完整的源代码：

// Set time limit to indefinite execution  set_time_limit (0);     // Set the ip and port we will listen on  $address = 'localhost';  $port = 10000;  $max_clients = 10;     // Array that will hold client information  $client = Array();     // Create a TCP Stream socket  $sock = socket_create(AF_INET, SOCK_STREAM, 0);  // Bind the socket to an address/port  socket_bind($sock, $address, $port) or die('Could not bind to address');  // Start listening for connections  socket_listen($sock);     echo "Waiting for connections\r\n";     // Loop continuously  while (true) {  // Setup clients listen socket for reading  $read[0] = $sock;  for ($i = 0; $i < $max_clients; $i++) {   if (isset($client[$i]['sock']))    $read[$i + 1] = $client[$i]['sock'];  }  // Set up a blocking call to socket_select()  if (socket_select($read, $write = NULL, $except = NULL, $tv_sec = 5) < 1)   continue;  / if a new connection is being made add it to the client array / if (in_array($sock, $read)) {   for ($i = 0; $i < $max_clients; $i++) {    if (empty($client[$i]['sock'])) {    $client[$i]['sock'] = socket_accept($sock);    echo "New client connected $i\r\n";    break;    }    elseif ($i == $max_clients - 1)    echo "Too many clients\r\n";   }  } // end if in_array     // If a client is trying to write - handle it now  for ($i = 0; $i < $max_clients; $i++) { // for each client   if (isset($client[$i]['sock'])) {    if (in_array($client[$i]['sock'], $read)) {    $input = socket_read($client[$i]['sock'], 1024);    if ($input == null) {     echo "Client disconnecting $i\r\n";     // Zero length string meaning disconnected     unset($client[$i]);    } else {     echo "New input received $i\r\n";     // send it to the other clients     for ($j = 0; $j < $max_clients; $j++) {     if (isset($client[$j]['sock']) && $j != $i) {      echo "Writing '$input' to client $j\r\n";      socket_write($client[$j]['sock'], $input, strlen($input));     }     }     if ($input == 'exit') {     // requested disconnect     socket_close($client[$i]['sock']);     }    }    } else {    echo "Client disconnected $i\r\n";    // Close the socket    socket_close($client[$i]['sock']);    unset($client[$i]);    }   }  }  } // end while  // Close the master sockets  socket_close($sock);

哎呀，乍一看这似乎是一个大工程，但是我们可以先将它分解为几个较小的部分。

第一部分是创建服务器。Lines：2至20。

这部分代码设置了变量、地址、端口、最大客户端和客户端数组。接下来创建socket并将其绑定到我们指定的地址和端口上。

下面我们要做的事情就是执行一个死循环（实际上我们是故意的！）。Lines：22至32。

在这部分代码中我们做的第一步是设置 $read 数组。此数
组包含所有客户端的套接字和我们主服务器的套接字。这个变量稍后会用于select语句：告诉PHP监听来自这些客户端的每一条消息。

socket_select()的最后一个参数告诉我们的服务器在返回值之前最多等待5秒钟。如果它的返回值小于1，那么就表示没有收到任何数据，所以只需要返回循环顶部，继续等待。

脚本的下一个部分，是增加新的客户端到数组中。Lines：33至44。

将新的客户端放置在列表的末尾。检查以确保客户端的数量没有超过我们想要服务器处理的数量。

下面要介绍的代码块相当大，也是服务器的主要部分。当客户端将消息发送到服务器时，就需要这块代码挺身而出来处理。消息可以是各种各样的，断开消息、实际断开——只要是服务器需要处理的消息。Lines：46至末尾。

代码循环通过每个客户端并检查是否收到来自于它们的消息。如果是，获取输入的内容。根据输入来检查这是否是一个断开消息，如果是那就从数组中删除它们，反之，那它就是一个正常的消息，那我们的服务器再次通过所有客户端，并一个一个写信息给他们，跳过发送者。

好了，下面试试创造你自己的聊天服务器吧！

你这消息头、消息体的结构格式都定下来了，总长度就是固定的啊？消息体的长度不是一共2+2+4+1=9个字节么？消息格式肯定要按照服务端的要求进行发送，明显服务端不是java的程序。。但是java里是没有Unsigned Integer这种数据类型的（java的stream *** 作里提供了一些unsigned的方法，或者自己写方法来生成对应的字节格式），你可以按照他的要求，使用字节数组封装好，然后发送。
针对这个示例消息，你可以：
创建一个长度为9的字节数组。把“9”变成byte放入前两个字节（前两个字节数据应该为：0x00, 0x09。这是第一个字段，长度），后面的字段数据以此类推。一个字段一个字段处理成服务器要求的格式。
然后把字节流发送给服务端。

说个伪代码吧，程序还是要动手的。
首先SOCKET JAVA的东西都有例子，客户端程序和服务器程序，网上很多例子，随便找来调试下。
链接成功后，在服务器端写IO流，记得有追加到文件末尾的方法，看下API吧。
多线程的问题：尽量在方法内定义局部变量，用线程约束关键字，同时只能 *** 作一个写 *** 作关闭后做下一个写入

这个类似于聊天室的信息转发，建议建立一个数据结构，如
[SerializableAttribute]
[ComVisibleAttribute(true)]
public class SendType
{
public string SendName {get;set;}
public string RecName {get;set;}
public string Data {get;set;}
}
新建一个结构变量，public SendType SendData = new SendType();
SendDataSendName = "A";
SendDataRecName = "B";
SendDataData = "Hello";
如此初始化后，将变量序列化后，提取byte[]数组直接发送，服务器再接收后再反序列化，转发。
[SerializableAttribute]
[ComVisibleAttribute(true)]
两个标记就是标记SendType类为可序列化，否则会造成不能序列化的编译错误。

---