public MConnect(){ dbPool = new SQLServerConnectionPool(); dbPool.initPool(); mgPool = new MGThreadPool(); mgPool.initThreadPool(); socket = new SocketConnector(2226,mgPool,"command"); // 2226是端口号 }
public static Connection getCon() { return dbPool.getCon(); } public static void main(String[] args) { new MConnect(); System.out.println ("服务器成功开启!"); }} package com;import java.io.DataInputStream; import java.io.DataOutputStream;import MG.Engin.MGLogicInterface;public class command1 implements MGLogicInterface{ public void processLogic(DataInputStream dis, DataOutputStream dos) { // TODO Auto-generated method stub System.out.println("命令1被调用"); }}
package com;
import java.sql.*;
import MG.Connector.SocketConnector;
import MG.DBConnection.SQLServerConnectionPool;
import MG.ThreadPool.MGThreadPool;public class MConnect {
private static MG.DBConnection.SQLServerConnectionPool dbPool = null;
private MG.ThreadPool.MGThreadPool mgPool = null;
protected MG.Connector.SocketConnector socket = null;
public MConnect(){
dbPool = new SQLServerConnectionPool();
dbPool.initPool();
mgPool = new MGThreadPool();
mgPool.initThreadPool();
socket = new SocketConnector(2226,mgPool,"command");
// 2226是端口号
}
public static Connection getCon() {
return dbPool.getCon();
} public static void main(String[] args) {
new MConnect();
System.out.println ("服务器成功开启!");
}}
package com;import java.io.DataInputStream;
import java.io.DataOutputStream;import MG.Engin.MGLogicInterface;public class command1 implements MGLogicInterface{ public void processLogic(DataInputStream dis, DataOutputStream dos) {
// TODO Auto-generated method stub
System.out.println("命令1被调用");
}}
我看你的开启服务用的main方法,你尝试用一个servlet来开启,不关闭了,然后再用另外那个客户端去调用没有你的其它几个类
import MG.Connector.SocketConnector;
import MG.DBConnection.SQLServerConnectionPool;
import MG.ThreadPool.MGThreadPool;别人也无法测试