求高手指导一个“Java的功能实现与预期不符的Socket代码编程”的技术问题..
高手，您好：我在用Java做一个im系统，我的C端的登陆面板的代码为：
package c_port_packageBJTeacher;
import java.awt.Rectangle;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JPasswordField;
import javax.swing.JTextField;
public class Login extends JFrame{
/**
*
*/
static String S_PORT_SERVER = "127.0.0.1";
private static final long serialVersionUID = 1L;
/**
* @param args
*/
static JTextField jtf0 = new JTextField();
static JTextField jtf1 = new JTextField();
JLabel jl0 = new JLabel();
JLabel jl1 = new JLabel();
MyJButton jb2 = null;
MyJButtonPayForSysProduct jb3 = null;
static JPasswordField jpwf = new JPasswordField();
JPanel jp1 = new JPanel();
public static String UID = null;
static String PWD = null;
Socket so2 = null;
Socket so3 = null;
DataOutputStream dops2 = null;
DataOutputStream dops3 = null;
DataInputStream dips2 = null;
DataInputStream dips3 = null;
public static void main(String[] args) {
// TODO Auto-generated method stub
new Login();
}
public Login(){
this.setTitle("赤兔马网络学习平台，让您采用电子商务的价格，享受到当面手把手授课的学习效果");
try {
so3 = new Socket(S_PORT_SERVER,8888);
} catch (UnknownHostException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
jb2 = new MyJButton("注册","127.0.0.1",so3);
try {
dops3 = new DataOutputStream(so3.getOutputStream());
dips3 = new DataInputStream(so3.getInputStream());
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
MyJButtonLogin jb1 = new MyJButtonLogin("登陆","褚彦丽","cjcjcjcjcocococo!!",this,so3);
this.setSize(500,600);
this.setVisible(true);
this.setDefaultCloseOperation(Login.EXIT_ON_CLOSE);
jb1.setBounds(new Rectangle(30,220,80,30));
jb2.setBounds(new Rectangle(236,220,80,30));
jp1.setLayout(null);
jp1.add(jb1);
jp1.add(jb2);
jtf0.setBounds(new Rectangle(73,115,220,25));
jp1.add(jtf0);
jpwf.setBounds(new Rectangle(73,150,220,25));
jp1.add(jpwf) ;
jl0 = new JLabel("用户名");
jl1 = new JLabel("密码");
jl0.setBounds(new Rectangle(30,115,40,25));
jl1.setBounds(new Rectangle(30,150,40,25));
jp1.add(jl0);
jp1.add(jl1);
this.add(jp1);
this.setBounds(500,218,370,330);
this.setContentPane(jp1);
}
}
其中的第71行的MyJButtonLogin类的源代码如下：
package c_port_packageBJTeacher;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
public class MyJButtonLogin extends JButton {
String S_PORT_SERVER = "127.0.0.1";
static NoteUserLoginFrame cjco;
boolean isMyUser = false;
DataOutputStream Localdops3 = null;
DataOutputStream Localdops2 = null;
DataInputStream Localdips3 = null;
DataInputStream Localdips2 = null;
String MySysNum = null;
public static String MyUID = null;
public static String MyPWD = null;
String str2 = null;
public static String str3 = null;
String str4 = null;
Login log = null;
Socket so2 = null;
Socket so3 = null;
String[] buffer =null;
/**
*
*/
private static final long serialVersionUID = 1L;
/**
* @param args
*/
public MyJButtonLogin(String button, String UID, String pwd, Login login,Socket s3) {
super(button);
so3 = s3;
MyUID = UID;
MyPWD = pwd;
try {
Localdops3 = new DataOutputStream(so3.getOutputStream());
} catch (IOException e2) {
// TODO Auto-generated catch block
e2.printStackTrace();
}
InetAddress addr = null;
try {
addr = InetAddress.getLocalHost();
} catch (UnknownHostException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
str3 = addr.getHostAddress().toString();// 获得本机IP
log = login;
System.out.println("" + log.toString());
this.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent et) {
log.setVisible(false);
MyUID = Login.jtf0.getText();
MyPWD = new String(Login.jpwf.getPassword());
try {
String aa = "0#" + MyUID + "%" + MyPWD + "%"
+ "Teacher" + "%" + str3 + "#" + "C" + "#"
+ "Teacher" + "#" + "0";
System.out.println(aa);
Localdops3.writeUTF("0#" + MyUID + "%" + MyPWD + "%"
+ "Teacher" + "%" + str3 + "#" + "C" + "#"
+ "Teacher" + "#" + "0");
Localdops3.flush();
String str = Lib.readsocketUTF(so3);
Localdops3.close();
so3.close();
System.out.println("888888888888888888888888888888888888888888888888");
System.out.println(str);
buffer = str.split("[#]");
isMyUser = Boolean.parseBoolean(buffer[0]);
MySysNum = buffer[1];
try {
if(isMyUser){
System.out.println(str);
System.out.println("MyJButtonLogin_start");
cjco = new NoteUserLoginFrame(MyUID,MyPWD,so2,so3);
}
} catch (Exception e) {
e.printStackTrace();
}
}catch(Exception e){
e.printStackTrace();
}
}
});
}
}
由于篇幅的原因，我将我的S端的源代码写到了下一个帖子中，希望高手能够过目..
Java 调试 Java 异常 Java Socket Java 流 Java im --------------------编程问答-------------------- 我的S端的源代码如下：
package S_port_packageBJTeacher;
import java.io.DataOutputStream;
import java.io.File;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Arrays;
import java.util.concurrent.ArrayBlockingQueue;
import javax.swing.JFrame;
public class ChatServer extends JFrame {
/**
* ChatServer.java 2013-5-9
*
* @author cjco
*/
// 全局定义区域：定义各种成员变量；
int SysPreTeacherNum = 2000;
int SysPreCustomerNum = 2000;
static Integer MyMEMNum = 202;
static Integer MyCUSNum = 202;
static String S_PORT_SERVER = "127.0.0.1";
static String C_PORT_CLIENT = "127.0.0.1";
static String[] bufMemUID = new String[MyMEMNum];
static String[] bufMemPWD = new String[MyMEMNum];
static String[] bufCusUID = new String[MyCUSNum];
static String[] bufCusPWD = new String[MyCUSNum];
static MyArrayList MyBJMemUserAuthorizeTime = new MyArrayList();
static MyArrayList MyBJCusUserAuthorizeTime = new MyArrayList();
static MyArrayList MyYCMemUserAuthorizeTime = new MyArrayList();
static MyArrayList MyYCCusUserAuthorizeTime = new MyArrayList();
String MyMemIDPath = "D:" + File.separator + "MyDoc" + File.separator
+ "Sport" + File.separator + "registeredMemUID.txt";
String MyMemPWDPath = "D:" + File.separator + "MyDoc" + File.separator
+ "Sport" + File.separator + "registeredMemPWD.txt";
String MyCustomerIDPath = "D:" + File.separator + "MyDoc" + File.separator
+ "Sport" + File.separator + "CustomerID.txt";
String MyCustomerPWDPath = "D:" + File.separator + "MyDoc" + File.separator
+ "Sport" + File.separator + "CustomerPWD.txt";
String MyRole = null;
String MySysNum = null;
ServerSocket ss1 = null;
String buffertemp = null;
String MyInfo = null;
String[] buffer = null;
String MySysRole = null;
public static int Index = 0;
static int num = 0;
int[] a = null;
int para = -1;
int condition = -1;
private static final long serialVersionUID = 1L;
boolean started = false;
static Socket so1;
static Socket so2;
File f = null;
static int PM_linknumlog = 0;
DataOutputStream dops2 = null;
DataOutputStream dips2 = null;
public static int[] LocalTeacheronline = new int[MyMEMNum];
public int[] LocalTeacheronlineCondition = new int[MyMEMNum];
public int[] Teachercomplicatingnum = new int[MyMEMNum];
ArrayBlockingQueue<String> sportmessagelist = new ArrayBlockingQueue<String>(
100000, true);
public static MyMemHashMap mapTeacheronline = new MyMemHashMap();
public static MyCusHashMap mapCustomeronline = new MyCusHashMap();
public static ArrayBlockingQueue<String> GoalTeacherchatwordlist = null;
public static ArrayBlockingQueue<String> GoalCustomerchatwordlist = null;
public static ArrayBlockingQueue<DataOutputStream> GoalTeacherSendInfo = null;
public static ArrayBlockingQueue<DataOutputStream> GoalCustomerSendInfo = null;
public static void main(String[] args) {
new ChatServer().start();
}
// “C端用户的其他Socket请求的"交给线程处理"动作。
public void start() {
ReadTxt.read(MyMemIDPath);
int numID = ReadTxt.logData.size();
for (int i = 0; i < numID; i++) {
bufMemUID[i] = ReadTxt.logData.get(i);
}
ReadTxt.logData.clear();
ReadTxt.read(MyMemPWDPath);
int MemnumPWD = ReadTxt.logData.size();
for (int i = 0; i < MemnumPWD; i++) {
bufMemPWD[i] = ReadTxt.logData.get(i);
}
ReadTxt.logData.clear();
ReadTxt.read(MyCustomerIDPath);
numID = ReadTxt.logData.size();
System.out.println(numID);
for (int i = 0; i < numID; i++) {
bufCusUID[i] = ReadTxt.logData.get(i);
}
ReadTxt.logData.clear();
ReadTxt.read(MyCustomerPWDPath);
int CusnumPWD = ReadTxt.logData.size();
for (int i = 0; i < CusnumPWD; i++) {
bufCusPWD[i] = ReadTxt.logData.get(i);
}
GoalTeacherchatwordlist = new ArrayBlockingQueue<String>(100000, true);
GoalCustomerchatwordlist = new ArrayBlockingQueue<String>(100000, true);
GoalTeacherSendInfo = new ArrayBlockingQueue<DataOutputStream>(
SysPreTeacherNum, true);
GoalCustomerSendInfo = new ArrayBlockingQueue<DataOutputStream>(
SysPreCustomerNum, true);
ReadTxt.logData.clear();
try {
Arrays.fill(LocalTeacheronline, 0);
// TODO Auto-generated method stub
ss1 = new ServerSocket(8888, 50);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
while (true) {
// 创建绑定到端口8888的ServerSocket对象
try {
so1 = ss1.accept();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(so1 + "|||---");
System.out.println("服务器正在对8888端口进行监听");
// 服务器循环接受客户端的请求，为不同的客户端提供服务
System.out.println("进入try");
System.out.println("进入try1");
System.out.println("进入try2");
buffertemp = Lib.readsocketUTF(so1);
System.out.print(buffertemp);
System.out.println("进入try3");
System.out.println("C_port_connect" + "I'm_Teacher_From_BeiJing");
System.out.println(buffertemp);
buffer = buffertemp.split("[#]");
System.out.println("S:" + buffer);
condition = Integer.parseInt(buffer[0]);
System.out.println("S:" + condition);
MyInfo = buffer[1];
System.out.println(MyInfo);
System.out.println("MyInfo:" + MyInfo);
MySysRole = buffer[2];
MyRole = buffer[3];
MySysNum = buffer[4];
if (MySysRole.equals("D")) {
ManageTheChannel3RecvUserAccountLoopSendClientNum mb = new ManageTheChannel3RecvUserAccountLoopSendClientNum(
"Thread_3", MyInfo, this, so1);
mb.start();
} else {
if (Integer.parseInt(MySysNum) == 200) {
if (MyRole.equals("Teacher")) {
LocalTeacheronline[Integer.parseInt(MySysNum)] = 1;
LocalTeacheronlineCondition[Integer
.parseInt(MySysNum)] = 1;
}
}
switch (condition) {
case 0: {// 已对照完毕.
ManageTheChannel0ConfirmandSaveDS obj0 = new ManageTheChannel0ConfirmandSaveDS(
so1, this, MyInfo);
Thread m0 = new Thread(obj0, "MyThread1");
m0.start();
break;
}
}
}
}
}
}
上述第135行的Lib.readsocketUTF(so1);的代码，是我为了避免Socket编程中的“EOFException”异常而进行的“readUTF();方法”的重写..
他的源代码如下：
package S_port_packageBJTeacher;
import java.io.DataInputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.Socket;
public class Lib {
static String readsocketUTF(Socket s){
DataInputStream read = null;
try {
read = new DataInputStream(s.getInputStream());
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
String msg = "";
String info = "";
msg = info;
while(true){
try {
info = read.readUTF();
}catch(EOFException e){
break;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
msg = msg + info;
try {
read.close();
s.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return msg;
}
}
上述S端的“用户登陆账户”的备份中，有一个“UID：褚彦丽”，“PWD：cjcjcjcjcocococo!!”的账户。
按照逻辑来说，在进行了S端的运行后，C端连接到S端后，应该会有S端第135行输出：
ChatServer类的第135行的代码的“C端MyJButtonLogin类中第74行语句进行的”：
Localdops3.writeUTF("0#" + MyUID + "%" + MyPWD + "%"
+ "Teacher" + "%" + str3 + "#" + "C" + "#"
+ "Teacher" + "#" + "0");
中的数据：
“0#褚彦丽%cjcjcjcjcocococo!!%Teacher%192.168.1.3#C#Teacher#0”
的打印输出的内容的.
但是，经过运行测试后，出现的结果为：
请问高手：
这是怎么回事...？
一百分奉上！！
一位求知者
2013年11月3日早晨6点半 --------------------编程问答--------------------
太长了，没有看
--------------------编程问答--------------------
我这里还是看到的readUTF（）。。。
while(true){
try {
info = read.readUTF();
}catch(EOFException e){
break;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
就不能改成2进制嘛？ --------------------编程问答--------------------
withiter版主，谢谢您再次的点拨！！
如果改成二进制，是可以的..
但是弟我很希望能够知道：
弟我的上面的代码，错在什么地方..？
版主，这是弟我的“测试类”中的实验代码：
（S端主类..）
package s;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class S_port {
String str = "";
ServerSocket s =null;
Socket so = null;
S_port(){
try {
s = new ServerSocket(60000);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
while(true){
try {
so = s.accept();
break;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
SystemThread m1 = new SystemThread(so);
m1.start();
try {
s.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String[] args){
new S_port();
}
}
（S端的子线程类..）
package s;
import java.io.DataInputStream;
import java.net.Socket;
public class SystemThread extends Thread{
Socket so = null;
DataInputStream dips = null;
public SystemThread(Socket s){
so = s;
}
public void run(){
String str = Lib.readsocketUTF(so);
System.out.println(str);
}
}
（S端的Lib类..）
package S_port_packageBJTeacher;
import java.io.DataInputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.Socket;
public class Lib {
static String readsocketUTF(Socket s){
DataInputStream read = null;
try {
Object ob = s.getInputStream();
read = new DataInputStream(s.getInputStream());
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
String msg = "";
String info = "";
msg = info;
while(true){
try {
info = read.readUTF();
}catch(EOFException e){
break;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
msg = msg + info;
try {
read.close();
s.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return msg;
}
}
我的C端的测试类的代码如下：
package s;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
public class C_port {
Socket s = null;
DataOutputStream dops = null;
public C_port(){
try {
s = new Socket("127.0.0.1",60000);
dops = new DataOutputStream(s.getOutputStream());
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
dops.writeUTF("CJ必胜！！CJCO！！");
dops.close();
s.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String[] args){
new C_port();
}
}
最后打印出的结果为：
(S端console窗口的数据为：）
这个结果说明，我的这个Lib类的readsocketUTF()方法，是能够起到“代替readUTF()方法”的功能的..
希望得到withiter版主和CSDN论坛中的高手的点拨：
我的这个项目的登陆模块，他的出错原因在什么地方..
谢谢CSDN！！我的大学！！
补充：Java , Java SE
