-1
我有一个客户端服务器聊天程序的服务器代码,但我想当我运行它我每次只能发送一个单词例如“发送你好1”是好的,它向客户端1发送'hello',但是如果我想写一个句子,我会收到“无效消息”。我一直在尝试修复它一段时间,我不能得到正确的方式来做到这一点,所以我可以得到消息和消息应该去的客户端的号码。聊天程序服务器类不发送消息
public class Serverr implements Runnable {//server implements threading by implementing runnable interface
Socket csocket;
static HashMap<Integer,Socket>hm=new HashMap <Integer,Socket>(); //here we store each client socket in hashmap
static int k=1;
Serverr(Socket csocket){
this.csocket=csocket;//Server ser=new Server(sock); comes here and assigns it to csocket
}
public static void main(String args[])
throws Exception{
ServerSocket ssock=new ServerSocket(5000);//Socket on port 5000(same as mentioned inclient class)
System.out.println("Listening");//when connected on port 5000 we print listening
while(true){
Socket sock=ssock.accept();//accept client socket
Serverr ser=new Serverr(sock);//pass socket to constructor of server class
new Thread(ser).start();//start thread here
hm.put(k,sock);//add the socket into hashmap
System.out.println("Connected to client"+k);//print the number of connected client
k++;
}
}
@Override
public void run() {
try{
//once the thread is started we initialize necessary input & output streams here
PrintWriter out;
BufferedReader in=new BufferedReader(new InputStreamReader(csocket.getInputStream()));//used to read input from the socket
String inputLine;
String j="sending"; //follow a pattern for sending messages
String l="to";
String t="sendtoall";//used to sent message to all clients
while((inputLine=in.readLine())!=null)//if the message from connected client !=null
{
String a[]=inputLine.split(" ");//split the input line using space if a[0] is sendmsg and a[2] is to
if(a[0].equals(j) && a[2].equals(l))//we started the server
{
int id=Integer.parseInt(a[3]);//we will get the number of client here
if(hm.containsKey(id)){// we will check hashmap if it contains id
Socket ser1=hm.get(id);//here we will get that clients socket from hashmap
out=new PrintWriter(ser1.getOutputStream(),true);// we will write to that socket using output stream
out.println(a[1]);//we will get that specific message part
out.flush();// a[1] is...
}
else
{
out=new PrintWriter(csocket.getOutputStream(),true);
out.println("user offline");//we print it if hashmap doesnt contain the key value
out.flush();
}
}
else if(a[0].equals(t))//if we want to sent message to all clients at once
{
for(int h=1;h<hm.size();h++)//loop through hashmap & get those socket value
{
Socket ser1=hm.get(h);
out=new PrintWriter(ser1.getOutputStream(),true);//we will write to that socket here using outputstream
out.println(a[1]);
out.flush();
}
}
else{
out=new PrintWriter(csocket.getOutputStream(),true);
out.println("Invalid Message");//if the message format doesnt match
out.flush();
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
[为什么“有人可以帮助我?”不是一个实际的问题?](http://meta.stackoverflow.com/q/284236/18157)。请访问[帮助]并阅读[问]。 –
@JimGarrison - 利亚娜已经描述了到底发生了什么问题。我不知道这个问题如何更清楚。 –