个人联网笔记本

个人信息：就读于燕大本科软件project专业 眼下大四;

本人博客：google搜索“cqs_2012”就可以;

个人爱好：酷爱数据结构和算法，希望将来从事算法工作为人民作出自己的贡献;

编程语言：java ;

编程坏境：Windows 7 专业版 x64;

编程工具：jdk，eclipse，AVD;

制图工具：office 2010 powerpoint;

硬件信息：7G-3 笔记本;

引言

个人第一部联网andriod作品诞生，andriod生涯里程碑的出现。

主要技术点

通信socket技术。使用多线程通信。

在socket使用中，使用一次打开一次，关闭一次，传输数据一去一回。

socket与应用程序主线程的切换;

对主线程进行枷锁。数据传送完后，在socket线程里对主线程的唤醒，防止主线程没有等待数据通信完成就開始运行。

对主线程设置锁；

// 线程锁（事实上就是定义一个全局变量，在myapplication（全局变量）中定义）

public static String loginThreadState = "off";

加锁操作

MyApplication.loginThreadState =“off”;

检查锁操作

// 推断当前线程是否唤醒

while(MyApplication.loginThreadState.equals("off"));

开锁以及唤醒操作

// 唤醒 login 进程

MyApplication.loginThreadState = "on";

MyApplication.loginThreadState.notify();

然后这样就能够实现通信了，而且能够等待通信返回来的数据，然后去处理。

个人笔记server端socket实现

import java.net.*;

import java.io.*;

import java.text.SimpleDateFormat;

import java.util.*;

import DBData.DataApplication;

import DBData.NoteBookClass;

import DBData.User;

import DBOperation.NoteDao;

import DBOperation.UserDao;

import DataChange.NoteChange;

public class MyAppNoteBookInfor extends Thread

{

	// 链接变量

	private static int port;

	private static ServerSocket serverSocket ;

	static Socket server;

	private DataInputStream input;

	private DataOutputStream output;

	static

	{

		try

		{

			// 设置服务器端口

			port = 8899;

			serverSocket = new ServerSocket(port);

		}

		catch(Exception e)

		{

			e.printStackTrace();

		}

	}

	public MyAppNoteBookInfor()throws Exception

	{

		// 成功启动

		System.out.println("accept ready");

		server = serverSocket.accept(); 

		// 成功启动

		System.out.println("accept start");

		// 获取数据流

		input = new DataInputStream(server.getInputStream());

		output = new DataOutputStream(server.getOutputStream());

	}

	// run 主函数

	public void run()

	{

		try

		{

			// 接收数据

			String commondData = getCommondData();

			// 处理数据,并发送数据

			if(commondData != null)

				selectCommond( commondData );

			server.close();

		}

		catch (Exception e)

		{

			// TODO: handle exception

			e.printStackTrace();

		}

	}

	// 选择函数 not over 数据处理

	public void selectCommond(String data)throws Exception

	{

		// 接收数据。处理

		String formatdata[] = data.split( DataApplication.commondGetDataStyle );

		// 选择操作命令

		switch( Integer.parseInt(formatdata[0]))

		{

			// check

			case DataApplication.commond_check_user:

			{

				// 数据转换

				User user = new User();

				user.setId( formatdata[1] );

				user.setPwd( formatdata[2] );

				// 数据处理

				Boolean result = MyAppNoteBookServer.checkUser(user);

				// 转换格式

				String senddata = result.toString();

				// 发送数据

				sendData(senddata);

			}

			break; 

			// select-all

			case DataApplication.commond_get_my_all_note:

			{

				// 数据处理

				String userid = formatdata[1];

				ArrayList<NoteBookClass> noteList = MyAppNoteBookServer.getUserNoteList(userid);

				String senddata = "null" ;

				if(noteList != null && noteList.size() > 0)

					// 数据转换

					senddata = NoteChange.noteListToStringWithSendForSelect(noteList); 

				// 发送数据

				sendData(senddata);

			}

			break;

			// new - note

			case DataApplication.commond_insert_note:

			{

				// 数据转换

				NoteBookClass noteBookClass = NoteChange.stringToNoteBookWithGetForInsert(formatdata[1]);

				// 数据处理

				Integer result = MyAppNoteBookServer.insertNote(noteBookClass);

				// 数据转换

				String senddata = result.toString();

				// 数据发送

				sendData(senddata);

			}

			break;

			// new user

			case DataApplication.commond_insert_user:

			{

				// 数据转换

				User user = new User();

				user.toUser(formatdata[1]);

				// 数据处理

				Integer result = MyAppNoteBookServer.insertUser(user);

				// 数据转换

				String senddata = result.toString();

				// 数据发送

				sendData(senddata);

			}

			break;

			case DataApplication.commond_search_note_by_key:

			{

				// 转换数据

				String[] keystStrings = NoteChange.dataToStringWithGetForSelectByKey(formatdata[1]);

				String useridString = keystStrings[0];

				String keywordString =keystStrings[1];

				// 数据处理

				ArrayList<NoteBookClass> noteList = MyAppNoteBookServer.getUserNoteListByKeywords(useridString,keywordString);

				// 数据转换

				String senddata = "null" ;

				if(noteList != null && noteList.size() > 0)

					senddata = NoteChange.noteListToStringWithSendForSelect(noteList); 

				// 发送数据

				sendData(senddata);

			}

			break;

			case DataApplication.commond_alter_note:

			{

				// 转换数据

				NoteBookClass noteBookClass  = NoteChange.stringToNoteBookWithGetForAlter( formatdata[1] );

				// 数据处理

				MyAppNoteBookServer.AlterNoteBook(noteBookClass);

				ArrayList<NoteBookClass> noteList = MyAppNoteBookServer.getUserNoteList(noteBookClass.getUserId());

				String senddata = "null" ;

				if(noteList != null && noteList.size() > 0)

					// 数据转换

					senddata = NoteChange.noteListToStringWithSendForSelect(noteList); 

				// 发送数据

				sendData(senddata);

			}

			break;

			case DataApplication.commond_delete_note:

			{

				// 获取并转换数据

				int id = Integer.parseInt(formatdata[1]);

				// 处理数据

				int result = MyAppNoteBookServer.DeleteNoteBookById(id);

				//  转换数据

				String senddata = String.valueOf(result);

				// 发送数据

				sendData(senddata);	

			}

			break;

		}

	}

	// 发送信息函数

	public void sendData(String data)

	{

		try

		{

			// 发送消息

			output.writeUTF(data);

			output.flush();

		}

		catch (Exception e)

		{

			e.printStackTrace();

		}

	}

	// 接收命令函数

	public String getCommondData()

	{

		String data = null;

		try

		{

			// 接收消息

			data = input.readUTF();

		}

		catch (Exception e)

		{

			// TODO: handle exception

		}

		return data;

	}

	// 主函数 main

	public static void main(String args[]) throws Exception

	{

		MyAppNoteBookInfor myAppNoteBookInfor;

		while(true)

		{

			myAppNoteBookInfor = new MyAppNoteBookInfor();

			myAppNoteBookInfor.start();

		}

	}

}

个人clientsocket实现

package Thread;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.net.Socket;

import com.icss.myappnotebook.MyApplication;

public class SocektThread extends Thread

{

	// 设置链接server

	private  String ip = "120.6.72.65" ;

	private  int port = 8899 ;	// 链接客户端程序 变量

	private  Socket clientSocket ;

	// 设置数据流

	public  DataInputStream input ;

	public  DataOutputStream output ;

	// 线程主函数

	public void run()

	{	

		try

		{

			// 链接server

			clientSocket = new Socket(ip,port);

			// 获取server输入流

			input = new DataInputStream(clientSocket.getInputStream());

			// 获取server输入流

			output = new DataOutputStream(clientSocket.getOutputStream());	

			switch (MyApplication.commond)

			{

			// check-核对username和password

			case MyApplication.commond_check_user:

				// 发送数据 2点

				output.writeUTF(MyApplication.senddata);

				output.flush();

				// 发送成功

				System.out.println("send ok");

				// 接收数据

				MyApplication.getdata = input.readUTF();

				// 唤醒 login 进程

				MyApplication.loginThreadState = "on";

				MyApplication.loginThreadState.notify();

				break;

				// 获得全部notes

			case MyApplication.commond_get_my_all_note:

				// 发送数据 2点

				output.writeUTF(MyApplication.senddata);

				output.flush();	

				// 接收数据

				MyApplication.getdata = input.readUTF();

				// 唤醒 menu 线程

				MyApplication.menuThreadState="on";

				MyApplication.menuThreadState.notify();	

				break;

			case MyApplication.commond_insert_note:

				// 发送数据

				output.writeUTF(MyApplication.senddata);

				output.flush();	

				// 接收数据

				MyApplication.getdata = input.readUTF();

				// 唤醒 new  线程

				MyApplication.newNoteBookThreadState = "on";

				MyApplication.newNoteBookThreadState.notify();	

				break;

			case MyApplication.commond_insert_user:

				// 发送数据

				output.writeUTF(MyApplication.senddata);

				output.flush();	

				// 接收数据

				MyApplication.getdata = input.readUTF();

				// 唤醒 register 线程

				MyApplication.registerUserThreadState = "on";

				MyApplication.registerUserThreadState.notify();

				break;

			case MyApplication.commond_search_note_by_key:

				// 发送数据

				output.writeUTF(MyApplication.senddata);

				output.flush();	

				// 接收数据

				MyApplication.getdata = input.readUTF();

				// 唤醒 search 线程

				MyApplication.searchNoteBookThreadState = "on";

				MyApplication.searchNoteBookThreadState.notify();

				break;

			case MyApplication.commond_alter_note:

				// 发送数据

				output.writeUTF(MyApplication.senddata);

				output.flush();	

				// 接收数据

				MyApplication.getdata = input.readUTF();

				// 唤醒 show one notebook 线程

				MyApplication.showOneNoteThreadState = "on";

				MyApplication.showOneNoteThreadState.notify();

				break;

			case MyApplication.commond_delete_note:

				// 发送数据

				output.writeUTF(MyApplication.senddata);

				output.flush();	

				// 接收数据

				MyApplication.getdata = input.readUTF();

				// 唤醒 show one notebook 线程

				MyApplication.openAllThreadState = "on";

				MyApplication.openAllThreadState.notify();

				break;

			default:

				break;

			}

			clientSocket.close();

		}

		catch(Exception e)

		{

			e.printStackTrace();

		}

	}

}

希望对于想实现通信的好友有帮助，谢谢大家

最新文章

  1. printf的特殊用法
  2. 二十二、Java基础--------GUI入门
  3. 在RHEL6p5中设置网卡
  4. Address already in use: JVM_Bind&lt;null&gt;:80
  5. Apache中RewriteCond规则参数介绍
  6. 转换时间对象和字符串对象&amp;添加时间
  7. vs调试正确显示utf8格式字符串
  8. Python 自动刷博客浏览量
  9. HQL: The Hibernate Query Language
  10. DSAPI HTTP监听服务端与客户端
  11. jmeter笔记（2）--组件介绍
  12. Median
  13. Pycharm 2018 Activation code 在线激活
  14. bzoj5016
  15. Vue.js基础拾遗
  16. mysql 限制sql执行时间
  17. h5 rem
  18. C++设计模式 之 “数据结构” 模式：Composite、Iterator、Chain of Resposibility
  19. 让node支持es模块化(export、import)的方法
  20. 批量得到/修改word超链接

热门文章

  1. Linux系统编程——多线程实现多任务
  2. Android编程获取手机型号，本机电话号码，sdk版本号及firmware版本号号(即系统版本号号)
  3. listView 多个item布局
  4. 【刷题笔记】LeetCode 606. Construct String from Binary Tree
  5. Flask-上传文件和访问上传的文件
  6. Re：从0开始的微服务架构--(二)快速快速体验微服务架构？--转
  7. SQL*PLUS命令的使用大全
  8. sql语句获取本周、本月、本年数据
  9. Mediator 基于内存的发布订阅
  10. 双向链表C++实现