написал свой класс аналогичный TelnetSession
при его использовании зависания не выявлены
ищите ошибку
Код:
public MyTelnetSession(String phost, int pport)
{
String host;
int port;
Socket socket = null;
String loginPromptSequence = ">";
BufferedInputStream is = null;
PrintStream os = null;
host = phost;
port = pport;
void connect() throws IOException, bitel.billing.server.util.telnet.OperationTimedoutException
{
log.info( "connect to"+this.host );
socket = new Socket(this.host, this.port);
socket.setSoTimeout(0);
InputStream input = this.socket.getInputStream();
OutputStream out = this.socket.getOutputStream();
is = new BufferedInputStream(input);
os = new PrintStream(out, true);
InputUntilStringFound(loginPromptSequence);
}
String doCommand(String command, String endString) throws IOException, bitel.billing.server.util.telnet.OperationTimedoutException
{
PrintWriter pw = new PrintWriter(new OutputStreamWriter(this.socket.getOutputStream()),true);
pw.print(command + "\r\n");
pw.flush();
return InputUntilStringFound(endString);
}
void doCommandAsync(String command) throws IOException, bitel.billing.server.util.telnet.OperationTimedoutException
{
PrintWriter pw = new PrintWriter(new OutputStreamWriter(this.socket.getOutputStream()),true);
pw.print(command + "\r\n");
pw.flush();
}
String doCommand(String command)
throws IOException, bitel.billing.server.util.telnet.OperationTimedoutException
{
return doCommand(command, this.loginPromptSequence);
}
String getLoginPromptSequence()
{
return this.loginPromptSequence;
}
void setLoginPromptSequence(String ploginPromptSequence)
{
loginPromptSequence = ploginPromptSequence;
}
void disconnect()
{
try
{
this.socket.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
String InputUntilStringFound(String FindString)throws IOException{
//просматриваем входную строку до нахождения в ней шаблона FindString
curwin = new StringBuffer();
retstring = new StringBuffer();
long lastTime = System.currentTimeMillis();
long now = lastTime;
int filledbuffer = 0; //флаг показывающий заполнен ли буффер
int timeout = 400000;
while (now - lastTime < timeout){
if (is.available()>0){
c = (char)is.read();
curwin.append(c);
retstring.append(c);
if (curwin.length()==FindString.length()){
//буффер полностью заполнен
filledbuffer = 1;
}
if (FindString.contentEquals(curwin)) {
//паттерн найден
return retstring.toString();
}
if (filledbuffer == 1) {
//удаляем первый символ из окна
curwin.deleteCharAt(0);
}
}else{
Thread.sleep(100);
}
now = System.currentTimeMillis();
}
log.info( "timeout!!!!!!!!!!!!!!!!!!!!");
return "";//timeout
}
return this;
}
{
String host;
int port;
Socket socket = null;
String loginPromptSequence = ">";
BufferedInputStream is = null;
PrintStream os = null;
host = phost;
port = pport;
void connect() throws IOException, bitel.billing.server.util.telnet.OperationTimedoutException
{
log.info( "connect to"+this.host );
socket = new Socket(this.host, this.port);
socket.setSoTimeout(0);
InputStream input = this.socket.getInputStream();
OutputStream out = this.socket.getOutputStream();
is = new BufferedInputStream(input);
os = new PrintStream(out, true);
InputUntilStringFound(loginPromptSequence);
}
String doCommand(String command, String endString) throws IOException, bitel.billing.server.util.telnet.OperationTimedoutException
{
PrintWriter pw = new PrintWriter(new OutputStreamWriter(this.socket.getOutputStream()),true);
pw.print(command + "\r\n");
pw.flush();
return InputUntilStringFound(endString);
}
void doCommandAsync(String command) throws IOException, bitel.billing.server.util.telnet.OperationTimedoutException
{
PrintWriter pw = new PrintWriter(new OutputStreamWriter(this.socket.getOutputStream()),true);
pw.print(command + "\r\n");
pw.flush();
}
String doCommand(String command)
throws IOException, bitel.billing.server.util.telnet.OperationTimedoutException
{
return doCommand(command, this.loginPromptSequence);
}
String getLoginPromptSequence()
{
return this.loginPromptSequence;
}
void setLoginPromptSequence(String ploginPromptSequence)
{
loginPromptSequence = ploginPromptSequence;
}
void disconnect()
{
try
{
this.socket.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
String InputUntilStringFound(String FindString)throws IOException{
//просматриваем входную строку до нахождения в ней шаблона FindString
curwin = new StringBuffer();
retstring = new StringBuffer();
long lastTime = System.currentTimeMillis();
long now = lastTime;
int filledbuffer = 0; //флаг показывающий заполнен ли буффер
int timeout = 400000;
while (now - lastTime < timeout){
if (is.available()>0){
c = (char)is.read();
curwin.append(c);
retstring.append(c);
if (curwin.length()==FindString.length()){
//буффер полностью заполнен
filledbuffer = 1;
}
if (FindString.contentEquals(curwin)) {
//паттерн найден
return retstring.toString();
}
if (filledbuffer == 1) {
//удаляем первый символ из окна
curwin.deleteCharAt(0);
}
}else{
Thread.sleep(100);
}
now = System.currentTimeMillis();
}
log.info( "timeout!!!!!!!!!!!!!!!!!!!!");
return "";//timeout
}
return this;
}