StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

POWhy used heap is always increasing in my MINA application?
primarykey
Id
13699010
data
AcceptedAnswerId
0
AnswerCount
3
ClosedDate
CommentCount
8
CommunityOwnedDate
CreationDate
2012-12-04T08:48:03.517
FavoriteCount
0
LastActivityDate
2013-07-24T02:06:24.980
LastEditDate
2012-12-04T08:55:27.533
LastEditorUserId
1845238
OwnerUserId
1845238
ParentId
0
PostTypeId
1
Score
0
ViewCount
1148
LastEditorDisplayName
text
Body
I have an application which consists of two parts as server and client. It works like this : Client connects to the server and sends a string; server receives the string and returns an ArrayList (by converting string) which contains 10000 elements. I wrote a class (ClientConnector.java) which simulates many clients use one connection to take those 10000 elements from server. When I run this two programs, server side is ok. However on the client side, used heap is always increasing ! I tried to release the used objects by "null" but the used memory is still getting larger and larger. <a href="http://s10.postimage.org/egf4ugrd5/mem.png" rel="nofollow">http://s10.postimage.org/egf4ugrd5/mem.png</a> My Server Side Codes : Client.java public class Client { <pre><code>private static final int PORT = 7571; ClientHandler handler = new ClientHandler("hey"); IoConnector connector; boolean available = true; public synchronized void setAvailable(boolean available) { this.available = available; } public synchronized boolean isAvailable() { return available; } public void starter() throws InterruptedException { Thread t = new Thread(new Runnable() { @Override public void run() { connector = new NioSocketConnector(); connector.getSessionConfig().setReadBufferSize(2048); TextLineCodecFactory t = new TextLineCodecFactory(Charset.forName("UTF-8")); t.setEncoderMaxLineLength(20 * 150000); t.setDecoderMaxLineLength(20 * 150000); connector.getFilterChain().addLast("logger", new LoggingFilter()); connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(t)); connector.setHandler(handler); ConnectFuture future = connector.connect(new InetSocketAddress("localhost", PORT)); future.awaitUninterruptibly(); if (!future.isConnected()) { return; } IoSession session = future.getSession(); session.getConfig().setUseReadOperation(true); session.getCloseFuture().awaitUninterruptibly(); connector.dispose(); } }); t.start(); Thread.sleep(300); } public void conClose() { connector.dispose(); } public ClientHandler getHandler() { return handler; } public void reqInf() { handler.reqInfo(); } public static void main(String[] args) { try { Client c = new Client(); c.starter(); } catch (InterruptedException ex) { System.out.println("error"); } } </code></pre> } ClientHandler.java public class ClientHandler extends IoHandlerAdapter { <pre><code>long time; private final String values; IoSession session; public ClientHandler(String values) { this.values = values; } @Override public void sessionOpened(IoSession session) throws InterruptedException { this.session = session; } public ArrayList<String> convert(String str) { Gson gson = new Gson(); return gson.fromJson(str, ArrayList.class); } @Override public void messageReceived(IoSession session, Object message) throws InterruptedException { try { ArrayList<String> test = convert(message.toString()); System.out.println("TIME : " + (System.currentTimeMillis() - time) + " strList:" + test.size()); message = null; test = null; } catch (Exception ex) { ex.printStackTrace(); } } @Override public void exceptionCaught(IoSession session, Throwable cause) { session.close(); System.out.println(cause.toString()); } @Override public void sessionClosed(IoSession session) { System.out.println("Connection Lost"); } public void reqInfo() { time = System.currentTimeMillis(); session.write("test"); } </code></pre> } My Server Side : Server.java public class Server { <pre><code>private static final int PORT = 7571; //TEST PORT IoAcceptor acceptor = new NioSocketAcceptor(); public Server() throws IOException { TextLineCodecFactory t = new TextLineCodecFactory(Charset.forName("UTF-8")); t.setEncoderMaxLineLength(20*150000); t.setDecoderMaxLineLength(20*150000); acceptor.getFilterChain().addLast("logger", new LoggingFilter()); acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(t)); // acceptor.getFilterChain().addLast("threadPool", new ExecutorFilter(Executors.newCachedThreadPool())); Executor executor = new ThreadPoolExecutor(5, 70, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()); acceptor.getFilterChain().addLast("threadPool", new ExecutorFilter(executor)); acceptor.setHandler(new ServerHandler()); acceptor.getSessionConfig().setReadBufferSize(2048); acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 1000); //timer(); acceptor.bind(new InetSocketAddress(PORT)); System.out.println("***Mina Server is ready !"); System.out.println(""); System.out.println(""); } public static void main(String[] args) throws IOException { Server m = new Server(); } </code></pre> } ServerHandler.java public class ServerHandler extends IoHandlerAdapter { <pre><code>private final Logger logger = (Logger) LoggerFactory.getLogger(getClass()); IoSession sessions; //Communication communication; public ServerHandler() throws IOException { loader(); // communication = new Communication(this); } @Override public void sessionOpened(IoSession session) { // set idle time to 10 seconds session.getConfig().setIdleTime(IdleStatus.BOTH_IDLE, 1000); System.out.println("Client Connected !!!"); //session.setAttribute("Values: "); this.sessions = session; } public String toGSon(ArrayList<String> list) { Gson gson = new Gson(); String str = gson.toJson(list); return str; } ArrayList<String> str = new ArrayList<String>(); public void loader() { for (int i = 0; i < 10000; i++) { str.add("test" + i); } } @Override public void messageReceived(IoSession session, Object message) throws InterruptedException { long time = System.currentTimeMillis(); session.write(toGSon(str)); System.out.println("TIME : " + (System.currentTimeMillis() - time)); } @Override public void sessionIdle(IoSession session, IdleStatus status) { System.out.println("Socket #" + session.getId() + " is disconnecting... (IDLE)"); session.close(); } @Override public void exceptionCaught(IoSession session, Throwable cause) { System.out.println("------------>" + cause.toString()); session.close(); } </code></pre> } And my Main Class public class ClientConnector { <pre><code>public ClientConnector() throws InterruptedException { Client cl = new Client(); cl.starter(); while (true) { cl.reqInf(); Thread.sleep(100); } } public static void main(String[] args) throws InterruptedException { ClientConnector cl = new ClientConnector(); } </code></pre> }
Tags
<java><performance><memory><mina>
Title
Why used heap is always increasing in my MINA application?
singulars
PostAcceptedAnswerId
1. This table or related slice is empty.
PostParentId
1. This table or related slice is empty.
PostTypePostTypeId
1. PTQuestion
UserLastEditorUserId
1. USftb
UserOwnerUserId
1. USftb
plurals
PostLinksPostIdRelatedPostId
1. This table or related slice is empty.
PostLinksRelatedPostIdPostId
1. This table or related slice is empty.
PostsAcceptedAnswerId
1. This table or related slice is empty.
PostsParentIdCreationDate
1. PO
 singulars
 PostTypePostTypeId
 PTAnswer
2. PO
 singulars
 PostTypePostTypeId
 PTAnswer
3. PO
 singulars
 PostTypePostTypeId
 PTAnswer
VotesPostIdCreationDate
1. This table or related slice is empty.
CommentsPostId

Querying!

Guidance

A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.