一个server与一个client多线程异步聊天已经实现了
但是这个server只能针对1个client
我run几个相同的client和server通信,只有第一个真正发送出去了!
问题:1 如何实现一个server同时和N多client聊天?
2 一定要启动一个server端来监听,然后启动一个client这种方式才能聊天吗?是不是谁接收消息谁就充当Server?那这样的话
client之间的通信也要让client变成server才行?代码:
package myfistsocket;/*一个作为Server*/import java.io.*;
import java.net.*;class MynewServer
{
public static void main(String[] args) throws IOException
{
ServerSocket s = new ServerSocket(6666);
System.out.println("服务器端------监听中.....");
Socket socket = s.accept(); System.out.println("开始:" + socket); GetMessage gm = new GetMessage(socket);
SendMessage sm = new SendMessage(socket); Thread gt = new Thread(gm);
Thread st = new Thread(sm); gt.start();
st.start();
}
}// 接收消息
class GetMessage implements Runnable
{
BufferedReader in; public GetMessage(Socket socket)
{
try
{
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
}
catch (IOException e)
{ e.printStackTrace();
}
} public void run()
{ String str = "";
while (true)
{
try
{
str = in.readLine();
}
catch (IOException e)
{ e.printStackTrace();
}
if (str.equals("q"))
{
break;
} System.out.print("客户端回应说:" + str);
}
}}// 发送消息
class SendMessage implements Runnable
{
PrintWriter out;
BufferedReader is; public SendMessage(Socket socket) throws IOException
{
out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
is = new BufferedReader(new InputStreamReader(System.in));
} public void run()
{ String input = new String();
while (true)
{
try
{
input = is.readLine().trim();
}
catch (IOException e)
{
e.printStackTrace();
} out.println(input);
System.out.print("服务器说:");
out.flush();
}
}}package myfistsocket;/*一个作为Client*/
import java.io.*;
import java.net.*;public class MynewClient
{
public static void main(String[] args) throws IOException
{
InetAddress addr = InetAddress.getByName("127.0.0.1"); Socket socket = new Socket(addr, 6666); System.out.println("客户端发出socket=" + socket); CGetMessage gm = new CGetMessage(socket);
CSendMessage sm = new CSendMessage(socket); Thread gt = new Thread(gm);
Thread st = new Thread(sm);
gt.start();
st.start();
}
}// 接收消息
class CGetMessage implements Runnable
{ private Socket socket;
BufferedReader in; public CGetMessage(Socket socket)
{
this.socket = socket; } public void run()
{
BufferedReader in;
String str = "";
while (true)
{
try
{
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
str = in.readLine();
}
catch (IOException e)
{
e.printStackTrace();
} System.out.println("服务器回应说:" + str);
}
}}// 发送消息
class CSendMessage implements Runnable
{
PrintWriter out;
BufferedReader is; public CSendMessage(Socket socket) throws IOException
{
out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
is = new BufferedReader(new InputStreamReader(System.in));
} public void run()
{ String input = new String();
while (true)
{
try
{
input = is.readLine().trim();
}
catch (IOException e)
{
e.printStackTrace();
} out.println(input);
System.out.print("客户端说:");
out.flush();
}
}}
但是这个server只能针对1个client
我run几个相同的client和server通信,只有第一个真正发送出去了!
问题:1 如何实现一个server同时和N多client聊天?
2 一定要启动一个server端来监听,然后启动一个client这种方式才能聊天吗?是不是谁接收消息谁就充当Server?那这样的话
client之间的通信也要让client变成server才行?代码:
package myfistsocket;/*一个作为Server*/import java.io.*;
import java.net.*;class MynewServer
{
public static void main(String[] args) throws IOException
{
ServerSocket s = new ServerSocket(6666);
System.out.println("服务器端------监听中.....");
Socket socket = s.accept(); System.out.println("开始:" + socket); GetMessage gm = new GetMessage(socket);
SendMessage sm = new SendMessage(socket); Thread gt = new Thread(gm);
Thread st = new Thread(sm); gt.start();
st.start();
}
}// 接收消息
class GetMessage implements Runnable
{
BufferedReader in; public GetMessage(Socket socket)
{
try
{
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
}
catch (IOException e)
{ e.printStackTrace();
}
} public void run()
{ String str = "";
while (true)
{
try
{
str = in.readLine();
}
catch (IOException e)
{ e.printStackTrace();
}
if (str.equals("q"))
{
break;
} System.out.print("客户端回应说:" + str);
}
}}// 发送消息
class SendMessage implements Runnable
{
PrintWriter out;
BufferedReader is; public SendMessage(Socket socket) throws IOException
{
out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
is = new BufferedReader(new InputStreamReader(System.in));
} public void run()
{ String input = new String();
while (true)
{
try
{
input = is.readLine().trim();
}
catch (IOException e)
{
e.printStackTrace();
} out.println(input);
System.out.print("服务器说:");
out.flush();
}
}}package myfistsocket;/*一个作为Client*/
import java.io.*;
import java.net.*;public class MynewClient
{
public static void main(String[] args) throws IOException
{
InetAddress addr = InetAddress.getByName("127.0.0.1"); Socket socket = new Socket(addr, 6666); System.out.println("客户端发出socket=" + socket); CGetMessage gm = new CGetMessage(socket);
CSendMessage sm = new CSendMessage(socket); Thread gt = new Thread(gm);
Thread st = new Thread(sm);
gt.start();
st.start();
}
}// 接收消息
class CGetMessage implements Runnable
{ private Socket socket;
BufferedReader in; public CGetMessage(Socket socket)
{
this.socket = socket; } public void run()
{
BufferedReader in;
String str = "";
while (true)
{
try
{
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
str = in.readLine();
}
catch (IOException e)
{
e.printStackTrace();
} System.out.println("服务器回应说:" + str);
}
}}// 发送消息
class CSendMessage implements Runnable
{
PrintWriter out;
BufferedReader is; public CSendMessage(Socket socket) throws IOException
{
out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
is = new BufferedReader(new InputStreamReader(System.in));
} public void run()
{ String input = new String();
while (true)
{
try
{
input = is.readLine().trim();
}
catch (IOException e)
{
e.printStackTrace();
} out.println(input);
System.out.print("客户端说:");
out.flush();
}
}}
SendMessage sm = new SendMessage(socket); Thread gt = new Thread(gm);
Thread st = new Thread(sm); gt.start();
st.start();
修改成:
while(true){
Socket socket = s.accept(); System.out.println("开始:" + socket); GetMessage gm = new GetMessage(socket);
SendMessage sm = new SendMessage(socket); Thread gt = new Thread(gm);
Thread st = new Thread(sm); gt.start();
st.start();
}
class MynewServer
{
public static void main(String[] args) throws IOException
{
ServerSocket s = new ServerSocket(6666);
System.out.println("服务器端------监听中.....");
while(true) //这里
{
Socket socket = s.accept(); System.out.println("开始:" + socket); GetMessage gm = new GetMessage(socket);
SendMessage sm = new SendMessage(socket); Thread gt = new Thread(gm);
Thread st = new Thread(sm); gt.start();
st.start();
}
}
}
你这还是同步通讯...只是用多线程解决了阻塞
问题1:如上修改server端就可以解决.
问题2:虽然在client端可以就已经连接的socket加入接受信息的代码,但是可能会产生外网内网无法通信的问题...建议还是开个专用接受信息的socket.
网络是对等的...我们习惯上把接受信息的端叫server端
2 我发现SERVER会根据接受连接的先后顺序来向客户端发送消息,这不是我们的本意!
3 聊完了如何关闭连接?我发现要是停止控制台的话,其他client或者server连续出错,如何使双方都知道这个连接
结束了而避免报错?
2、你的本意是什么?如果群聊,那当然是遍历了,如果要发给某一人,那就找到标识发过去
要不然你也可以另外多条线程一起向临时用户表中发信息,发完就remove
3、用try来捕捉readLine()的异常就可以了
把client加到group中
直接有server端发送就行了。
java.net.MulticastSocket
关于第三个问题的回答:像QQ这种聊天(A和B聊天,不通过服务器中转)应该不是一直连着的吧?是有消息时候才连接或者使用UDP发送的吧?还有,如果没有什么UI界面,只是在控制台上来聊天,约定结束消息就是使连接结束的唯一选择了吗?
标识?说的是这个吗?以下代码打出的结果:System.out.println("开始:" + socket);上面这句的结果:开始:Socket[addr=/127.0.0.1,port=1853,localport=6666]我不懂哪个是标识,以及该如何存贮,取出来用。
public void Response(){
try {
serverSocket = new ServerSocket(8000);
boolean berunning = true;
while(berunning){
response = serverSocket.accept();
if(response.isConnected()){
reip = response.getInetAddress().toString();
report = response.getPort();
Thread thread = new Thread(new Servicer(response));
thread.start();
linknum++;
}
this.repaint();
}
serverSocket.close();
} catch (IOException ex) {
Logger.getLogger(ServerCom.class.getName()).log(Level.SEVERE, null, ex);
}
}
你引用人的所谓的标识是指唯一的符号...可以由自己定义,并不是特定的
但是ip+port可以确定一个应用程序...所以可以靠它识别来添加标识,自己看怎么方便好了
当然是一直连着好
因为你连接服务器也要花费的,如果消息发得很频繁,那么XXX....参考QQ那样,如果你一段时间没有动静,就给你断开连接以节省资源
ServerSocketChanel类
SocketChanel类然后利用线程池ExecutorService
用Selector监控连接、读、写事件的发生
堵塞在br.readLine()上面的会抛出异常,以这个界定是否结束连接就可以了
在服务端要建立监听,client 在一定时间没有消息回应,断开与其连接,节约资源。