该楼层疑似违规已被系统折叠 隐藏此楼查看此楼

这是我写的服务器端：

package jiaohu; import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket; public class Serverj implements Runnable{

ServerSocket server=null;

Socket play1=null;

Socket play2=null;

DataInputStream pI1=null;

DataOutputStream pO1=null;

DataInputStream pI2=null;

DataOutputStream pO2=null;

public Serverj(){

try{

server=new ServerSocket(6669);

System.out.println("创建连接");

play1=server.accept();

System.out.println("第一个用户连接上了");

pI1=new DataInputStream(play1.getInputStream());

pO1=new DataOutputStream(play1.getOutputStream());

play2=server.accept();

System.out.println("第二个用户连接上了");

pI2=new DataInputStream(play2.getInputStream());

pO2=new DataOutputStream(play2.getOutputStream());

}catch(Exception e){

System.out.println("创建失败");

}

}

public void run(){

while(true){

try {

int a=pI1.readInt();

int b=pI1.readInt();

int c=pI1.readInt();

System.out.println("接收结束");

pO2.writeInt(a);

pO2.writeInt(b);

pO2.writeInt(c);

int a1=pI2.readInt();

int b1=pI2.readInt();

System.out.println("接收结束");

pO1.writeInt(a1);

pO1.writeInt(b1);

} catch (IOException e) {

// TODO Auto-generated catch block

System.out.println("没有输入");

e.printStackTrace();

}

}

}

public static void main(String[] args){

new Serverj();

new Thread(new Serverj()).start();

} }

这是我写的用户端

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.Socket;

import java.net.UnknownHostException;

import java.util.Scanner; public class Clientj implements Runnable {

Socket play=null;

DataInputStream in=null;

DataOutputStream out=null;

Clientj(){

try {

play=new Socket("192.168.1.13",6669);

in=new DataInputStream(play.getInputStream());

out=new DataOutputStream(play.getOutputStream());

} catch (UnknownHostException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public void run(){

while(true){

try {

if(in.readInt()==1){//表示接收数据

System.out.println("接收数据");

int a=in.readInt();

int b=in.readInt();

System.out.println(a+"+"+b);

}

//输出数据

System.out.println("请输入2个数据");

Scanner a1=new Scanner(System.in);

int a11=a1.nextInt();

int a12=a1.nextInt();

int a10=a1.nextInt();

out.writeInt(a10);

out.writeInt(a11);

out.writeInt(a12);

} catch (IOException e) {

// TODO Auto-generated catch block

System.out.println("有错");

e.printStackTrace();

}

}

}

public static void main(String[] args){

new Clientj();

new Thread(new Clientj()).start();

} }

我就是想一个用户端发送两个数据，而在另一个客户端能接收到，并且在另一个客户端发送的数据，在这个客户端也能接收，我该怎么改，请高手指点一二，小弟感激不尽！