「java安装mina」java安装后在电脑上找不到

本篇文章给大家谈谈java安装mina，以及java安装后在电脑上找不到对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

• 1、java 采用mina进行网络连接，怎样在客户端绑定本地的ip和port，下面的程序只指定了服务器端
• 2、如何使用Java的网络库Mina
• 3、Java 中Mina框架的问题。
• 4、Java使用Mina开发即时通讯服务器的时候遇到的问题

java 采用mina进行网络连接，怎样在客户端绑定本地的ip和port，下面的程序只指定了服务器端

ConnectFuture future = connector.connect(new InetSocketAddress(

host, port));// 创建连接

future.awaitUninterruptibly();// 等待连接创建完成

如何使用Java的网络库Mina

mina 这个网络资源包。是不是通过重写了CumulativeProtocolDecoder 中的doDecoded  方法中的Iosession对象。然后对方法事事的监测，在这个方法里面加上需要监测的函数。

（1）package mina.client;

import java.net.InetSocketAddress;

import java.nio.charset.Charset;

import java.util.Scanner;

import mina.common.BaseConfig;

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.prefixedstring.PrefixedStringCodecFactory;

import org.apache.mina.filter.logging.LoggingFilter;

import org.apache.mina.transport.socket.nio.NioSocketConnector;

public class MinaTimeClient {

public static void main(String[] args) {

//用于TCP/TP连接的NioSocketConnector类

IoConnector connector = new NioSocketConnector();

//增加日志过滤链

connector.getFilterChain().addLast("logger", new LoggingFilter());

//增加协议过滤链,一个Filter用于转换二进制数据或者特定的协议数据为消息对象

connector.getFilterChain().addLast(

"codec",

new ProtocolCodecFilter(new PrefixedStringCodecFactory(Charset

.forName("UTF-8"))));

//设置会处理所有被service管理的连接的handler

connector.setHandler(new TimeClientHander());

//连接到特定的remote地址，InetSocketAddress封装IP和port,Java网络编程规范，

//不提供直接的ip地址和端口的connect方法

ConnectFuture connectFuture = connector.connect(new InetSocketAddress(

"127.0.0.1", BaseConfig.PORT));

// 等待建立连接

connectFuture.awaitUninterruptibly();

System.out.println("连接成功");

//返回代表两端连接的一个对象,有读写方法以及获取本端网络设置的相关方法

IoSession session = connectFuture.getSession();

Scanner sc = new Scanner(System.in);

boolean quit = false;

//一直读取输入，并发送到对端（服务端），直到输入quit

while (!quit) {

String str = sc.next();

if (str.equalsIgnoreCase("quit")) {

quit = true;

}

//利用session写出数据

session.write(str);

}

// 关闭

if (session != null) {

if (session.isConnected()) {

session.getCloseFuture().awaitUninterruptibly();

}

//Releases any resources allocated by this service

connector.dispose(true);

}

}

}

（2）package mina.client;

import org.apache.mina.core.service.IoHandler;

import org.apache.mina.core.session.IdleStatus;

import org.apache.mina.core.session.IoSession;

/**

* service所绑定的handler，当手打送消息或者发送消息等等事件发生的时候

* 就会首先触发这里的方法

* IoHandler  Handles all I/O events fired by MINA.

*/

public class TimeClientHander implements IoHandler {

@Override

public void exceptionCaught(IoSession arg0, Throwable arg1)

throws Exception {

// TODO Auto-generated method stub

arg1.printStackTrace();

}

@Override

public void messageReceived(IoSession arg0, Object message)

throws Exception {

// TODO Auto-generated method stub

System.out.println("client接受信息:" + message.toString());

}

@Override

public void messageSent(IoSession arg0, Object message) throws Exception {

// TODO Auto-generated method stub

System.out.println("client发送信息" + message.toString());

}

@Override

public void sessionClosed(IoSession session) throws Exception {

// TODO Auto-generated method stub

System.out.println("client与:" + session.getRemoteAddress().toString()

+ "断开连接");

}

@Override

public void sessionCreated(IoSession session) throws Exception {

// TODO Auto-generated method stub

System.out.println("client与:" + session.getRemoteAddress().toString()

+ "建立连接");

}

@Override

public void sessionIdle(IoSession session, IdleStatus status)

throws Exception {

// TODO Auto-generated method stub

System.out.println("IDLE " + session.getIdleCount(status));

}

@Override

public void sessionOpened(IoSession arg0) throws Exception {

// TODO Auto-generated method stub

System.out.println("打开连接");

}

}

（3）package mina.common;

public class BaseConfig {

// 服务器端口

public static final int PORT = 9123;

}

package mina.server;

import java.io.IOException;

import java.net.InetSocketAddress;

import java.nio.charset.Charset;

import mina.common.BaseConfig;

import org.apache.mina.core.service.IoAcceptor;

import org.apache.mina.core.session.IdleStatus;

import org.apache.mina.filter.codec.ProtocolCodecFilter;

import org.apache.mina.filter.codec.prefixedstring.PrefixedStringCodecFactory;

import org.apache.mina.filter.logging.LoggingFilter;

import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

public class MinaTimeServer {

private static final int PORT = BaseConfig.PORT;

public static void main(String[] args) throws IOException {

IoAcceptor acceptor = new NioSocketAcceptor();

acceptor.getFilterChain().addLast("logger", new LoggingFilter());

acceptor.getFilterChain().addLast(

"codec",

new ProtocolCodecFilter(new PrefixedStringCodecFactory(Charset

.forName("UTF-8"))));

acceptor.setHandler(new TimeServerHandler());

/*Sets the size of the read buffer that I/O processor allocates

* per each read.  It's unusual to adjust this property because

* it's often adjusted automatically by the I/O processor

* 一次最多读取这么多字节，不足也返回

*/

acceptor.getSessionConfig().setReadBufferSize(2048);

//设置空转时间

acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);

acceptor.bind(new InetSocketAddress(PORT));

}

}

（4）package mina.server;

import java.util.Date;

import org.apache.mina.core.service.IoHandler;

import org.apache.mina.core.session.IdleStatus;

import org.apache.mina.core.session.IoSession;

public class TimeServerHandler implements IoHandler {

@Override

public void exceptionCaught(IoSession arg0, Throwable arg1)

throws Exception {

arg1.printStackTrace();

}

@Override

public void messageReceived(IoSession session, Object message)

throws Exception {

String str = message.toString();

System.out.println("接受到的消息:" + str);

if (str.trim().equalsIgnoreCase("quit")) {

session.close(true);

return;

}

Date date = new Date();

session.write(date.toString());

System.out.println("Message written...");

}

@Override

public void messageSent(IoSession arg0, Object arg1) throws Exception {

// TODO Auto-generated method stub

System.out.println("发送信息:" + arg1.toString());

}

@Override

public void sessionClosed(IoSession session) throws Exception {

// TODO Auto-generated method stub

System.out.println("IP:" + session.getRemoteAddress().toString()

+ "断开连接");

}

@Override

public void sessionCreated(IoSession session) throws Exception {

// TODO Auto-generated method stub

System.out.println("IP:" + session.getRemoteAddress().toString());

}

@Override

public void sessionIdle(IoSession session, IdleStatus status)

throws Exception {

// TODO Auto-generated method stub

System.out.println("IDLE " + session.getIdleCount(status));

}

@Override

public void sessionOpened(IoSession arg0) throws Exception {

// TODO Auto-generated method stub

}

}

Java 中Mina框架的问题。

长连接的话，服务端推送信息给客户端后，你客户端可以选择通知服务端已收到，也可以不通知

不过如果你要等待客户端响应后才能发送其他消息的话，你可以选择加标识 你可以弄个静态map 每次服务端发送一个消息给客户端 就 把 sessionid 作为key 放进去， 待客户端通知消息已接受再remove掉，服务端发送消息客户端方法里面弄个while循环体，如果map里面有这个客户端的sessionid时放入一个消息队列里面，待前面一个消息客户端告诉你已经收到了再去消费队列里面的消息，所以服务端发客户端消息方法 最好起个异步线程 用消费者模式去发消息

不过我不建议这么做，长连接的好处 就是你可以再对方为响应的时候 去做其他事情， 你的需求还不如用短连接

Java使用Mina开发即时通讯服务器的时候遇到的问题

做一个心跳保持协议，发送一个心跳请求包，请求里包含一个随机数。手机收到心跳后，回个应答包，应答包的内容要和心跳请求包的随机数一致。 但是最好在链路空闲监听里发送。

java安装mina的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于java安装后在电脑上找不到、java安装mina的信息别忘了在本站进行查找喔。