import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.net.InetSocketAddress;import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketConnector;/**
* Mina框架客户端演示.
*
*/
public class MinaClient {
private static final int CLIENTPORT=527;
private static final int SERVERPORT=428;
public static void main(String args[]){
MinaClient mina=new MinaClient();
mina.startClient();
}
/**
* 开启客户端.
*/
public void startClient(){
String address="192.168.16.14";
NioSocketConnector connector=new NioSocketConnector();
/*
* 这里注意点:
* 1:TextLineCodecFactory设置这个过滤器一行一行(/r/n)的发送/读取数据
* 2.ObjectSerializationCodecFactory一般发送/接收的是对象等形象,以对象形式读取
*/
connector.setConnectTimeoutMillis(30000);
connector.getFilterChain().addLast("codec",
new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
connector.getFilterChain().addLast("logging", new LoggingFilter()); connector.setHandler(new FileUploadClientHandler());
connector.getSessionConfig().setReuseAddress(true);//设置每一个非主监听连接的端口可以重用
connector.getSessionConfig().setReceiveBufferSize(1024);//设置输入缓冲区的大小
connector.getSessionConfig().setSendBufferSize(10240);//设置输出缓冲区的大小
//设置为非延迟发送,为true则不组装成大包发送,收到东西马上发出
connector.getSessionConfig().setTcpNoDelay(true);
//本句需要加上,否则无法调用下面的readFuture来从session中读取到服务端返回的信息。
connector.getSessionConfig().setUseReadOperation(true);
ConnectFuture cf = connector.connect(new InetSocketAddress(address,SERVERPORT));
if (!cf.isConnected()) {
System.out.println("不能建立网络连接。" + address);
}else{}
IoSession session;
红颜色的字体部分,这个问题怎么搞啊,The import org.apache.mina cannot be resolved 啥意思啊!
NioSocketConnector cannot be resolved to a type啥意思!
ObjectSerializationCodecFactory cannot be resolved to a type啥意思啊
import java.io.FileNotFoundException;
import java.io.IOException;
import java.net.InetSocketAddress;import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketConnector;/**
* Mina框架客户端演示.
*
*/
public class MinaClient {
private static final int CLIENTPORT=527;
private static final int SERVERPORT=428;
public static void main(String args[]){
MinaClient mina=new MinaClient();
mina.startClient();
}
/**
* 开启客户端.
*/
public void startClient(){
String address="192.168.16.14";
NioSocketConnector connector=new NioSocketConnector();
/*
* 这里注意点:
* 1:TextLineCodecFactory设置这个过滤器一行一行(/r/n)的发送/读取数据
* 2.ObjectSerializationCodecFactory一般发送/接收的是对象等形象,以对象形式读取
*/
connector.setConnectTimeoutMillis(30000);
connector.getFilterChain().addLast("codec",
new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
connector.getFilterChain().addLast("logging", new LoggingFilter()); connector.setHandler(new FileUploadClientHandler());
connector.getSessionConfig().setReuseAddress(true);//设置每一个非主监听连接的端口可以重用
connector.getSessionConfig().setReceiveBufferSize(1024);//设置输入缓冲区的大小
connector.getSessionConfig().setSendBufferSize(10240);//设置输出缓冲区的大小
//设置为非延迟发送,为true则不组装成大包发送,收到东西马上发出
connector.getSessionConfig().setTcpNoDelay(true);
//本句需要加上,否则无法调用下面的readFuture来从session中读取到服务端返回的信息。
connector.getSessionConfig().setUseReadOperation(true);
ConnectFuture cf = connector.connect(new InetSocketAddress(address,SERVERPORT));
if (!cf.isConnected()) {
System.out.println("不能建立网络连接。" + address);
}else{}
IoSession session;
红颜色的字体部分,这个问题怎么搞啊,The import org.apache.mina cannot be resolved 啥意思啊!
NioSocketConnector cannot be resolved to a type啥意思!
ObjectSerializationCodecFactory cannot be resolved to a type啥意思啊
解决方案 »
- Java的switch语句支持byte、short、char、int、long、String和enum(枚举)吗?
- 字符串格式转换的问题
- 如何正确卸载JDK6.0
- 通过jndi连接池,java对oracle的blob字段取出时会发生"java.lang.ClassCastException"错误,有什么解决方法嘛?
- 求助,如何让鼠标单击的地方,出现一个图标??
- hibernate一对一问题
- 奇怪的问题,ping 的时候用ip可以
- 如何在一字符串中查询是否还有某一字符??????????????????
- JTable空间中如何才能在表格框中显示图片?
- Java基本类型和引用类型
- equals " " 和 " " equalse有区别吗
- 关于会话的死锁问题,求高人指点!
下载org.apache.mina这个包放到classpath即可
http://archive.apache.org/dist/mina/2.0.4/
这个是最新版。