>我有来自客户端-服务器聊天程序的服务器代码,但我想当我运行它时,我每次只能发送一个单词,例如"向 1 发送 hello "是可以的,它会向客户端 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);
}
}
}
你的问题是这两行。
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
您正在检查输入的第三个和第四个单词的"to"和客户端编号。 但是如果你有一个完整的句子,那么这些不会是输入的第三个和第四个单词。 相反,您可能想分别检查倒数第二个和最后一个单词,如下所示。
if(a[0].equals(j) && a[a.length - 2].equals(l))//we started the server
{
int id=Integer.parseInt(a[a.length - 1]);//we will get the number of client here
这将允许您输入,例如
sending Hello my friend to 12345
并正确识别字段。
您还必须更改线路
out.println(a[1]);
这样它发送的不仅仅是一个单词。 也许您可以使用循环来执行此操作,例如此。
for (int word = 1; word < a.length - 2; word++ ) {
out.print(a[word]);
}
out.println();