这是我的客户端和服务器的代码。
类 Client1 { Client1(int no) { 尝试 { 字符串消息；message="你好这是客户端"+no; byte[] b =message.getBytes(); DatagramPacket dp = new DatagramPacket(b, b.length,InetAddress.getLocalHost(),3700); DatagramSocket 发送者 = new DatagramSocket(); 发件人.send(dp); }catch (Exception e) { System.out.println("client shutdown"); } } }
然后我的服务器类是
类服务器1 {
int cnt=0;
String s1;
Server1()
{
try {
byte[] buffer = new byte[65536];
DatagramPacket incoming = new DatagramPacket(buffer, buffer.length);
DatagramSocket ds = new DatagramSocket(3700);
ds.receive(incoming);
byte[] data = incoming.getData();
String s = new String(data, 0, incoming.getLength());
System.out.println("Port" + incoming.getPort() + " on " + incoming.getAddress() + " sent this message:");
System.out.println(s.toUpperCase());
}
catch (IOException e)
{
System.err.println(e);
}
}
}
然后我的可运行实现是
类 prothread 实现 Runnable {
//long time=0;
//int portno;
int flag=0; // this is to differentiate between a server and client
private String capitalizedSentence;
prothread(long l)
{
if(l==1)
{ // it is a server
flag=1;
}
else
{
flag=(int) l;
}
}
@Override
public void run(){
// TODO Auto-generated method stub
System.out.println("Starting thread");
if(flag==1)// Code for server
{
Server1 s=new Server1();
}
else // code for client
{
Client1 c=new Client1(flag);
}
}
}
最后部署这个客户端和服务器的类是
公共类 Samplepro31 {
public static void main(String[] args) {
// First i'm going to create a server and then clients for it
int i=1;
int cnt=0;
prothread[] p;
Thread[] th;
Random r =new Random();
// Array has been declared
p=new prothread[10];// Memory allocated to it
th= new Thread[1000];
p[0]=new prothread(1);
cnt=1;
//p[0].setportno(cnt);
th[0]=new Thread(p[0]);
th[0].start();
while(cnt<3)
{
p[cnt]=new prothread(cnt);
// here send the port number
th[cnt]=new Thread(p[cnt]);
//p[cnt1].setportno(cnt1);
th[cnt].start();
cnt++;
}
}
}
所以我遇到的问题是一台服务器，一次只有一个客户端在运行，而不是 2 个客户端应该运行我得到的 o/p：
开始线程 开始线程 开始线程 在 clinet 的构造函数内部 2 java.net.BindException：地址已在使用中：无法绑定 HELLO THIS IS CLIENT 2
那么有人可以告诉我我做错了什么吗？