JAVA Socket(多个客户同时连接，信息共享) client (java/ruby) - JAVA

ream(),true);
in = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF8"));

String readline;
readline=line.readLine();

while(!readline.equals("bye")){
out.println(readline);
out.flush();
System.out.println("Client:"+readline);
System.out.println("Server:"+in.readLine());
readline=line.readLine();
}

line.close();
out.close();
in.close();
socket.close();
}catch (IOException e){}
}
public static void main(String[] args){
new Client();
}
}

//这个客户端连接到地址为xxx.xxx.xxx.xxx的服务器，端口为10000，并从键盘输入一行信息，发送到服务器，然后接受服务器的返回信息，最后结束会话。

ruby:

某jar包有多个classw文件包含了main 函数,
需要在外部用java命令的bat文件来执行这个jar包的某个class文件的main函数.

java -classpath jar名字.jar 包名.类名
2.ruby

require 'socket'
class Client

s = TCPSocket.new '127.0.0.1', 10000

1.upto(10) do |n|
s.send("hello #{n}\n",0)
s.flush
end

while line = s.gets # Read lines from socket
puts line # and print them
end
s.close

end

第三步实现信息共享:在Socket上的实时交流

网络的伟大之一也是信息共享，Server可以主动向所有Client广播消息，同时Client也可以向其它Client发布消息。下面看看如何开发一个可以实时传递消息的程序。

设计原理：

服务器端接受客户端的连接请求，同时启动一个线程处理这个连接，线程不停的读取客户端输入，然后把输入加入队列中，等候处理。在线程启动的同时将线程加入队列中，以便在需要的时候定位和取出。

import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.LinkedList;
public class Server1 extends ServerSocket{

private static ArrayList User_List = new ArrayList();
private static ArrayList Threader = new ArrayList();
private static LinkedList Message_Array = new LinkedList();
private static int Thread_Counter = 0;
private static boolean isClear = true;
protected static final int SERVER_PORT = 10000;
protected FileOutputStream LOG_FILE = new FileOutputStream("d:/connect.log", true);

public Server1() throws FileNotFoundException, IOException{
super(SERVER_PORT);

new Broadcast();

//append connection log
Calendar now = Calendar.getInstance();
String str = "[" + now.getTime().toString() + "] Accepted a connection1512";
byte[] tmp = str.getBytes();
LOG_FILE.write(tmp);
try{
while (true){
Socket socket = accept();
new CreateServerThread(socket);
}
}finally{
close();
}
}

public static void main(String[] args) throws IOException{
new Server1();
}

//--- Broadcast
class Broadcast extends Thread{

public Broadcast(){
start();
}
public void run(){
while (true){
if (!isClear){
String tmp = (String)Message_Array.getFirst();
for (int i = 0; i < Threader.size(); i++){
CreateServerThread client = (CreateServerThread)Threader.get(i);
client.sendMessage(tmp);
}
Message_Ar

JAVA Socket(多个客户同时连接，信息共享) client (java/ruby) (二)