实例介绍
【实例简介】高仿qq源码,含 服务器端源码以及数据库sql
【实例截图】
【核心代码】
android端:
package com.way.chat.activity; import java.text.SimpleDateFormat; import java.util.Date; import com.way.util.MyDate; import android.content.Context; import android.util.AttributeSet; import android.util.Log; import android.view.LayoutInflater; import android.view.MotionEvent; import android.view.View; import android.view.ViewGroup; import android.view.animation.LinearInterpolator; import android.view.animation.RotateAnimation; import android.widget.AbsListView; import android.widget.AbsListView.OnScrollListener; import android.widget.BaseAdapter; import android.widget.ExpandableListView; import android.widget.ImageView; import android.widget.LinearLayout; import android.widget.ListView; import android.widget.ProgressBar; import android.widget.TextView; /** * 重写一个ListView,主要是添加一个下拉事件 * * @author way * */ public class MyListView extends ExpandableListView implements OnScrollListener { private static final String TAG = "listview"; private final static int RELEASE_To_REFRESH = 0; // 松开刷新状态 private final static int PULL_To_REFRESH = 1;// 拉动刷新状态 private final static int REFRESHING = 2;// 正在刷新状态 private final static int DONE = 3;// 已经加载完毕状态 private final static int LOADING = 4;// 正在加载数据状态 private final static int RATIO = 3;// 实际的padding的距离与界面上偏移距离的比例 private LayoutInflater inflater; private LinearLayout headView;// ListView头部的View private TextView tipsTextview;// 提示信息“下拉刷新”的TextView private TextView lastUpdatedTextView;// 上次更新时间的TextView private ImageView arrowImageView;// 箭头的图片 private ProgressBar progressBar;// 刷新进度 private RotateAnimation animation;// 箭头向下动画 private RotateAnimation reverseAnimation;// 逆向箭头动画 private boolean isRecored;// 用于保证startY的值在一个完整的touch事件中只被记录一次 private int headContentWidth;// 头部View内容的宽度 private int headContentHeight;// 头部view内容的高度 private int startY;// 向下触屏事件时的手指起始y轴位置 private int firstItemIndex;// ListView第一项的索引 private int state;// 刷新状态 private boolean isBack;// 是否反弹 private OnRefreshListener refreshListener;// 给外面预留的刷新的接口 private boolean isRefreshable;// 是否刷新的标志位 /** * 第一个构造器 * * @param context * 上下文对象 */ public MyListView(Context context) { super(context); init(context); } /** * 第二个构造器 * * @param context * 上下文对象 * @param attrs * 属性 */ public MyListView(Context context, AttributeSet attrs) { super(context, attrs); init(context); } public MyListView(Context context, AttributeSet attrs, int defStyle) { super(context, attrs, defStyle); init(context); } /** * 初始化数据 * * @param context * 上下文对象 */ private void init(Context context) { // setCacheColorHint(context.getResources().getColor(R.color.transparent)); inflater = LayoutInflater.from(context); headView = (LinearLayout) inflater.inflate(R.layout.head, null);// 获取ListView头部的view arrowImageView = (ImageView) headView .findViewById(R.id.head_arrowImageView);// 从头部的View获取箭头图片 arrowImageView.setMinimumWidth(70); arrowImageView.setMinimumHeight(50); progressBar = (ProgressBar) headView .findViewById(R.id.head_progressBar);// 获取刷新进度条 tipsTextview = (TextView) headView.findViewById(R.id.head_tipsTextView);// 提示信息的TextView lastUpdatedTextView = (TextView) headView .findViewById(R.id.head_lastUpdatedTextView);// 最后刷新时间的TextView measureView(headView);// 自己写的一个方法,没有很理解 headContentHeight = headView.getMeasuredHeight();// 得到headView的原始高度 headContentWidth = headView.getMeasuredWidth(); headView.setPadding(0, -1 * headContentHeight, 0, 0);// 设置内容的内部偏移量 headView.invalidate(); Log.v("size", "width:" headContentWidth " height:" headContentHeight); addHeaderView(headView, null, false);// 加到ListView的头部view,ListView组件提供了两个很实用的功能,那就是可以在顶部和底部添加自定义的视图 setOnScrollListener(this); // 箭头向下动画 animation = new RotateAnimation(0, -180, RotateAnimation.RELATIVE_TO_SELF, 0.5f, RotateAnimation.RELATIVE_TO_SELF, 0.5f); animation.setInterpolator(new LinearInterpolator()); animation.setDuration(250); animation.setFillAfter(true); // 逆向箭头动画 reverseAnimation = new RotateAnimation(-180, 0, RotateAnimation.RELATIVE_TO_SELF, 0.5f, RotateAnimation.RELATIVE_TO_SELF, 0.5f); reverseAnimation.setInterpolator(new LinearInterpolator()); reverseAnimation.setDuration(200); reverseAnimation.setFillAfter(true); state = DONE;// 第一次加载默认完成的状态 isRefreshable = false;// 刷新标志位默认为false } /** * 滑动时被调用 */ public void onScroll(AbsListView view, int firstVisiableItem, int visibleItemCount, int totalItemCount) { firstItemIndex = firstVisiableItem;// ListView第一个索引值为ListView数据中第一个可见项 } /** * 滑动状态改变时被调用 */ public void onScrollStateChanged(AbsListView view, int scrollState) { } /** * 触摸事件 */ public boolean onTouchEvent(MotionEvent event) { if (isRefreshable) {// 如果刷新标志为true switch (event.getAction()) { case MotionEvent.ACTION_DOWN:// 向下 if (firstItemIndex == 0 && !isRecored) { isRecored = true; startY = (int) event.getY(); Log.v(TAG, "在down时候记录当前位置"); } break; case MotionEvent.ACTION_UP:// 向上 if (state != REFRESHING && state != LOADING) { if (state == DONE) { // 什么都不做 } if (state == PULL_To_REFRESH) {// 下拉刷新 state = DONE; changeHeaderViewByState();// 更新头部view Log.v(TAG, "由下拉刷新状态,到done状态"); } if (state == RELEASE_To_REFRESH) {// 释放刷新 state = REFRESHING; changeHeaderViewByState(); onRefresh();// 调用接口的方法,通知外面 Log.v(TAG, "由松开刷新状态,到done状态"); } } isRecored = false; isBack = false; break; case MotionEvent.ACTION_MOVE:// 手指移动 int tempY = (int) event.getY(); if (!isRecored && firstItemIndex == 0) { Log.v(TAG, "在move时候记录下位置"); isRecored = true; startY = tempY; } if (state != REFRESHING && isRecored && state != LOADING) { // 保证在设置padding的过程中,当前的位置一直是在head,否则如果当列表超出屏幕的话,当在上推的时候,列表会同时进行滚动 // 可以松手去刷新了 if (state == RELEASE_To_REFRESH) { setSelection(0); // 往上推了,推到了屏幕足够掩盖head的程度,但是还没有推到全部掩盖的地步 if (((tempY - startY) / RATIO < headContentHeight) && (tempY - startY) > 0) { state = PULL_To_REFRESH; changeHeaderViewByState(); Log.v(TAG, "由松开刷新状态转变到下拉刷新状态"); } // 一下子推到顶了 else if (tempY - startY <= 0) { state = DONE; changeHeaderViewByState(); Log.v(TAG, "由松开刷新状态转变到done状态"); } // 往下拉了,或者还没有上推到屏幕顶部掩盖head的地步 else { // 不用进行特别的操作,只用更新paddingTop的值就行了 } } // 还没有到达显示松开刷新的时候,DONE或者是PULL_To_REFRESH状态 if (state == PULL_To_REFRESH) { setSelection(0); // 下拉到可以进入RELEASE_TO_REFRESH的状态 if ((tempY - startY) / RATIO >= headContentHeight) { state = RELEASE_To_REFRESH; isBack = true; changeHeaderViewByState(); Log.v(TAG, "由done或者下拉刷新状态转变到松开刷新"); } // 上推到顶了 else if (tempY - startY <= 0) { state = DONE; changeHeaderViewByState(); Log.v(TAG, "由DOne或者下拉刷新状态转变到done状态"); } } // done状态下 if (state == DONE) { if (tempY - startY > 0) { state = PULL_To_REFRESH; changeHeaderViewByState(); } } // 更新headView的size if (state == PULL_To_REFRESH) { headView.setPadding(0, -1 * headContentHeight (tempY - startY) / RATIO, 0, 0); } // 更新headView的paddingTop if (state == RELEASE_To_REFRESH) { headView.setPadding(0, (tempY - startY) / RATIO - headContentHeight, 0, 0); } } break; } } return super.onTouchEvent(event); } // 当状态改变时候,调用该方法,以更新界面 private void changeHeaderViewByState() { switch (state) { case RELEASE_To_REFRESH:// 松开刷新状态 arrowImageView.setVisibility(View.VISIBLE);// 显示箭头 progressBar.setVisibility(View.GONE);// 移除进度条 tipsTextview.setVisibility(View.VISIBLE);// 显示提示信息 lastUpdatedTextView.setVisibility(View.VISIBLE);// 显示最后刷新时间 arrowImageView.clearAnimation();// 先移除所有动画 arrowImageView.startAnimation(animation);// 加载箭头向下动画 tipsTextview.setText("松开刷新"); Log.v(TAG, "当前状态,松开刷新"); break; case PULL_To_REFRESH:// 下拉刷新状态 progressBar.setVisibility(View.GONE);// 移除进度条 tipsTextview.setVisibility(View.VISIBLE);// 显示提示信息 lastUpdatedTextView.setVisibility(View.VISIBLE);// 显示最后刷新时间 arrowImageView.clearAnimation();// 先移除所有动画 arrowImageView.setVisibility(View.VISIBLE);// 箭头图片可见 // 如果是由RELEASE_To_REFRESH状态转变来的,就加载动画 if (isBack) { isBack = false; arrowImageView.clearAnimation(); arrowImageView.startAnimation(reverseAnimation); tipsTextview.setText("下拉刷新"); } else { tipsTextview.setText("下拉刷新"); } Log.v(TAG, "当前状态,下拉刷新"); break; case REFRESHING:// 正在刷新状态 headView.setPadding(0, 0, 0, 0);// 无内部偏移 progressBar.setVisibility(View.VISIBLE);// 进度条可见 arrowImageView.clearAnimation();// 先清除动画 arrowImageView.setVisibility(View.GONE);// 再移除箭头动画 tipsTextview.setText("正在刷新...");// 提示信息变成正在刷新... lastUpdatedTextView.setVisibility(View.VISIBLE);// 最后刷新时间可见 Log.v(TAG, "当前状态,正在刷新..."); break; case DONE:// 完成状态 headView.setPadding(0, -1 * headContentHeight, 0, 0); progressBar.setVisibility(View.GONE); arrowImageView.clearAnimation(); arrowImageView.setImageResource(R.drawable.arrow_down); tipsTextview.setText("下拉刷新"); lastUpdatedTextView.setVisibility(View.VISIBLE); Log.v(TAG, "当前状态,done"); break; } } // 刷新完成 public void onRefreshComplete() { state = DONE; SimpleDateFormat format = new SimpleDateFormat("yyyy年MM月dd日 HH:mm"); String date = format.format(new Date()); lastUpdatedTextView.setText("最近更新:" date); changeHeaderViewByState(); } /** * 一个下拉刷新的监听接口 * */ public interface OnRefreshListener { public void onRefresh(); } // 监听方法 public void setonRefreshListener(OnRefreshListener refreshListener) { this.refreshListener = refreshListener; isRefreshable = true; } // 正在刷新 private void onRefresh() { if (refreshListener != null) { refreshListener.onRefresh(); } } /** * 此方法是“估计”headView的width以及height * * @param child * 传入进来的headView */ private void measureView(View child) { ViewGroup.LayoutParams p = child.getLayoutParams(); if (p == null) { p = new ViewGroup.LayoutParams(ViewGroup.LayoutParams.FILL_PARENT, ViewGroup.LayoutParams.WRAP_CONTENT); } int childWidthSpec = ViewGroup.getChildMeasureSpec(0, 0 0, p.width); int lpHeight = p.height; int childHeightSpec; if (lpHeight > 0) { childHeightSpec = MeasureSpec.makeMeasureSpec(lpHeight, MeasureSpec.EXACTLY); } else { childHeightSpec = MeasureSpec.makeMeasureSpec(0, MeasureSpec.UNSPECIFIED); } child.measure(childWidthSpec, childHeightSpec); } // ListView添加Adapter方法 public void setAdapter(BaseAdapter adapter) { lastUpdatedTextView.setText("最近更新:" MyDate.getDateCN()); super.setAdapter(adapter); } }
服务器端:
package com.way.chat.server; import java.io.IOException; import java.io.ObjectInputStream; import java.net.Socket; import java.util.ArrayList; import com.way.chat.common.bean.TextMessage; import com.way.chat.common.bean.User; import com.way.chat.common.tran.bean.TranObject; import com.way.chat.common.tran.bean.TranObjectType; import com.way.chat.common.util.MyDate; import com.way.chat.dao.UserDao; import com.way.chat.dao.impl.UserDaoFactory; public class InputThread extends Thread { private Socket socket; private OutputThread out; private OutputThreadMap map; private ObjectInputStream ois; private boolean isStart = true; public InputThread(Socket socket, OutputThread out, OutputThreadMap map) { this.socket = socket; this.out = out; this.map = map; try { ois = new ObjectInputStream(socket.getInputStream()); } catch (IOException e) { e.printStackTrace(); } } public boolean isStart() { return isStart; } public void setStart(boolean isStart) { this.isStart = isStart; } @Override public void run() { try { while (isStart) { // 读取消息 readMessage(); } if (ois != null) ois.close(); if (socket != null) socket.close(); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (IOException e) { // e.printStackTrace(); // isStart = false; } } public void readMessage() throws IOException, ClassNotFoundException { Object readObject = ois.readObject();// 从流中读取对象 UserDao dao = UserDaoFactory.getInstance();// 通过dao模式管理后台 if (readObject != null && readObject instanceof TranObject) { TranObject read_tranObject = (TranObject) readObject;// 转换成传输对象 switch (read_tranObject.getType()) { case REGISTER:// 如果用户是注册 User registerUser = (User) read_tranObject.getObject(); int registerResult = dao.register(registerUser); System.out.println("注册:" registerResult); // 给用户回复消息 TranObject<User> register2TranObject = new TranObject<User>( TranObjectType.REGISTER); User register2user = new User(); register2user.setId(registerResult); register2TranObject.setObject(register2user); out.setMessage(register2TranObject); break; case LOGIN: User loginUser = (User) read_tranObject.getObject(); ArrayList<User> list = dao.login(loginUser); TranObject<ArrayList<User>> login2Object = new TranObject<ArrayList<User>>( TranObjectType.LOGIN); if (list != null) {// 如果登录成功 TranObject<User> onObject = new TranObject<User>( TranObjectType.LOGIN); User login2User = new User(); login2User.setId(loginUser.getId()); onObject.setObject(login2User); for (OutputThread onOut : map.getAll()) { onOut.setMessage(onObject);// 广播一下用户上线 } map.add(loginUser.getId(), out);// 先广播,再把对应用户id的写线程存入map中,以便转发消息时调用 login2Object.setObject(list);// 把好友列表加入回复的对象中 } else { login2Object.setObject(null); } out.setMessage(login2Object);// 同时把登录信息回复给用户 System.out.println(MyDate.getDateCN() " 用户:" loginUser.getId() " 上线了"); break; case LOGOUT:// 如果是退出,更新数据库在线状态,同时群发告诉所有在线用户 User logoutUser = (User) read_tranObject.getObject(); int offId = logoutUser.getId(); System.out.println(MyDate.getDateCN() " 用户:" offId " 下线了"); dao.logout(offId); isStart = false;// 结束自己的读循环 out.removeThread();// 从缓存的线程中移除 out.setMessage(null);// 先要设置一个空消息去唤醒写线程 out.setStart(false);// 再结束写线程循环 TranObject<User> offObject = new TranObject<User>( TranObjectType.LOGOUT); User logout2User = new User(); logout2User.setId(logoutUser.getId()); offObject.setObject(logout2User); for (OutputThread offOut : map.getAll()) {// 广播用户下线消息 offOut.setMessage(offObject); } break; case MESSAGE:// 如果是转发消息(可添加群发) // 获取消息中要转发的对象id,然后获取缓存的该对象的写线程 int id2 = read_tranObject.getToUser(); OutputThread toOut = map.getById(id2); if (toOut != null) {// 如果用户在线 toOut.setMessage(read_tranObject); } else {// 如果为空,说明用户已经下线,回复用户 TextMessage text = new TextMessage(); text.setMessage("发送消息失败,用户可能已经离线!"); TranObject<TextMessage> offText = new TranObject<TextMessage>( TranObjectType.MESSAGE); offText.setObject(text); offText.setFromUser(0); out.setMessage(offText); } break; case FILE: break; default: break; } } } }
好例子网口号:伸出你的我的手 — 分享!
小贴士
感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享,对搜索内容的合法性不具有预见性、识别性、控制性,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论平台是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定,若资源存在侵权或相关问题请联系本站客服人员,点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论