`
rayloo
  • 浏览: 84409 次
  • 性别: Icon_minigender_1
  • 来自: 南京
社区版块
存档分类
最新评论

Socket连接技术

阅读更多

使用Socket 是连接两台计算机最简单的方法,另外由于Socket 使用的是TCP 协议,所以
也就保证了传输的质量。但在这里要注意的是,并不是所有的MIDP 设备都支持Socket 网络。
在这部分中我们主要涉及到的两个接口是SocketConnection 和ServerSocketConnection。这
个两个接口的使用方法其实和J2SE 中的Socket 和ServerSocket 类的使用方法很相似。不同的是
ServerSocketConnection 中打开一个SocketConnection 作为监听者的方法是acceptAndOpen()。同
时你可以用getLocalAddress()和getLocalPort()两个方法获得本地的绑定IP 地址和所打开的端口
号,这样你就可以告诉另外一台MIDP 设备你所使用的IP 和端口,使得另一台MIDP 设备可以
连接到你的设备上。
在这里我们除了强调使用acceptAndOpen()从一个ServerSocketConnection 对象中打开一个
SocketConnection 作为监听者外,还要说明的是作为套接字我们是可以设置一些属性的,这些属
性的设置是通过SocketConnection.setSocketOption()方法来设置

packagesocketText;

importjava.io.IOException;
importjava.io.InputStream;
importjava.io.OutputStream;

importjavax.microedition.io.Connector;
importjavax.microedition.io.ServerSocketConnection;
importjavax.microedition.io.SocketConnection;
importjavax.microedition.lcdui.Alert;
importjavax.microedition.lcdui.AlertType;
importjavax.microedition.lcdui.Command;
importjavax.microedition.lcdui.CommandListener;
importjavax.microedition.lcdui.Display;
importjavax.microedition.lcdui.Displayable;
importjavax.microedition.lcdui.Form;
importjavax.microedition.lcdui.StringItem;
importjavax.microedition.lcdui.TextField;
importjavax.microedition.midlet.MIDlet;
importjavax.microedition.midlet.MIDletStateChangeException;

/***//**
*
*
@authorleilu服务器端代码
*/

publicclassSocketServerextendsMIDletimplementsCommandListener,Runnable
...{
privateDisplaydisplay;

privateFormf;

privateStringItemsi;

privateTextFieldtf;

privatebooleanstop;

//创建Command对象
privateCommandsendCommand=newCommand("send",Command.ITEM,1);

privateCommandexitCommand=newCommand("Exit",Command.EXIT,1);

//输入流
InputStreamis;

//输出流
OutputStreamos;

//Socket连接
SocketConnectionsc;

//Socket服务器连接
ServerSocketConnectionscn;

publicSocketServer()
...{
display
=Display.getDisplay(this);
f
=newForm("SocketServer");
si
=newStringItem("Status:","");
//显示发送消息的控件
tf=newTextField("Send:","",30,TextField.ANY);
f.append(si);
f.append(tf);
f.addCommand(exitCommand);
//f.addCommand(sendCommand);
f.setCommandListener(this);
display.setCurrent(f);
//启动线程
Threadt=newThread(this);
t.start();

}


protectedvoidstartApp()throwsMIDletStateChangeException
...{
//TODOAuto-generatedmethodstub

}


protectedvoidpauseApp()
...{
//TODOAuto-generatedmethodstub

}


protectedvoiddestroyApp(booleanarg0)throwsMIDletStateChangeException
...{
//TODOAuto-generatedmethodstub

}


publicvoidcommandAction(Commandc,Displayabled)
...{
if(sendCommand==c)
...{
try
...{
os.write(tf.getString().getBytes());
os.write(
" ".getBytes());
}

catch(IOExceptione)
...{
//TODOAuto-generatedcatchblock
e.printStackTrace();
}

}

elseif(exitCommand==c)
...{
try
...{
destroyApp(
false);
this.notifyDestroyed();
}

catch(MIDletStateChangeExceptione)
...{
//TODOAuto-generatedcatchblock
e.printStackTrace();
}

}


}


publicvoidrun()
...{
si.setText(
"Waitingforconnection");
//创建一个服务器的ServerSocketConnection连接

try
...{
scn
=(ServerSocketConnection)Connector.open("socket://:5000");
//等待一个连接
sc=(SocketConnection)scn.acceptAndOpen();
//设置提示信息
si.setText("Connectionaccepted");
is
=sc.openInputStream();
os
=sc.openOutputStream();
//连接完成后允许发送
f.addCommand(sendCommand);
//读取客户端发来的消息

while(true)
...{
StringBuffersb
=newStringBuffer();
intc=0;
//读取数据
while(((c=is.read())!=' ')&&(c!=-1))
...{
sb.append((
char)c);
}

//如果读取数据失败
if(c==-1)
...{
break;
}

//显示客户端反发送过来的消息
si.setText("Messagereceved-"+sb.toString());
}

si.setText(
"Connectionisclosed");
//连接结束,则不实现发送按钮
f.removeCommand(sendCommand);

}

catch(IOExceptionioe)
...{
if(ioe.getMessage().equals("ServerSocketOpen"))
...{
//提示端口己经被占用
Alerta=newAlert("Server","Port5000isalreadytaken.",
null,AlertType.ERROR);
a.setTimeout(Alert.FOREVER);
a.setCommandListener(
this);
display.setCurrent(a);
}

else
...{
if(!stop)
...{
ioe.printStackTrace();
}

}

}

catch(Exceptione)
...{
e.printStackTrace();
}


}


//释放资源
publicvoidstop()
...{
try
...{
stop
=true;
if(is!=null)
...{
is.close();
}

if(os!=null)
...{
os.close();
}

if(sc!=null)
...{
sc.close();
}

if(scn!=null)
...{
scn.close();
}

}

catch(IOExceptione)
...{
//TODOAuto-generatedcatchblock
e.printStackTrace();
}

}


}

packagesocketText;

importjava.io.IOException;
importjava.io.InputStream;
importjava.io.OutputStream;

importjavax.microedition.io.ConnectionNotFoundException;
importjavax.microedition.io.Connector;
importjavax.microedition.io.SocketConnection;
importjavax.microedition.lcdui.Alert;
importjavax.microedition.lcdui.AlertType;
importjavax.microedition.lcdui.Command;
importjavax.microedition.lcdui.CommandListener;
importjavax.microedition.lcdui.Display;
importjavax.microedition.lcdui.Displayable;
importjavax.microedition.lcdui.Form;
importjavax.microedition.lcdui.StringItem;
importjavax.microedition.lcdui.TextField;
importjavax.microedition.midlet.MIDlet;
importjavax.microedition.midlet.MIDletStateChangeException;

publicclassSocketClientextendscolor: #00
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics